app

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 7, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AppContext                   = "app"
	SubscriberContext            = "subscriber"
	RelayerContext               = "relayer"
	TargetChainRPCClientContext  = "target_chain_rpc"
	NeutronChainRPCClientContext = "neutron_chain_rpc"
	TargetChainProviderContext   = "target_chain_provider"
	NeutronChainProviderContext  = "neutron_chain_provider"
	TxSenderContext              = "tx_sender"
	TxProcessorContext           = "tx_processor"
	TxSubmitCheckerContext       = "tx_submit_checker"
	TrustedHeadersFetcherContext = "trusted_headers_fetcher"
	KVProcessorContext           = "kv_processor"
)

Variables

View Source
var (
	Version = ""
	Commit  = ""
)

Functions

func NewDefaultRelayer

func NewDefaultRelayer(
	cfg config.NeutronQueryRelayerConfig,
	logRegistry *nlogger.Registry,
	storage relay.Storage,
	deps *DependencyContainer,
) (*relay.Relayer, error)

NewDefaultRelayer returns a relayer built with cfg.

func NewDefaultStorage added in v0.2.0

func NewDefaultStorage(cfg config.NeutronQueryRelayerConfig, logger *zap.Logger) (relay.Storage, error)

func NewDefaultSubscriber

func NewDefaultSubscriber(cfg config.NeutronQueryRelayerConfig, logRegistry *nlogger.Registry) (relay.Subscriber, error)

func NewDefaultTxSubmitChecker added in v0.2.0

func NewDefaultTxSubmitChecker(cfg config.NeutronQueryRelayerConfig, logRegistry *nlogger.Registry,
	storage relay.Storage) (relay.TxSubmitChecker, error)

Types

type DependencyContainer added in v0.2.0

type DependencyContainer struct {
	// contains filtered or unexported fields
}

func NewDefaultDependencyContainer added in v0.2.0

func NewDefaultDependencyContainer(ctx context.Context,
	cfg config.NeutronQueryRelayerConfig,
	logRegistry *nlogger.Registry,
	storage relay.Storage) (*DependencyContainer, error)

func (DependencyContainer) GetKvProcessor added in v0.2.0

func (c DependencyContainer) GetKvProcessor() relay.KVProcessor

func (DependencyContainer) GetNeutronChain added in v0.2.0

func (c DependencyContainer) GetNeutronChain() *cosmosrelayer.Chain

func (DependencyContainer) GetProofSubmitter added in v0.2.0

func (c DependencyContainer) GetProofSubmitter() relay.Submitter

func (DependencyContainer) GetTargetChain added in v0.2.0

func (c DependencyContainer) GetTargetChain() *cosmosrelayer.Chain

func (DependencyContainer) GetTargetQuerier added in v0.2.0

func (c DependencyContainer) GetTargetQuerier() *tmquerier.Querier

func (DependencyContainer) GetTrustedHeaderFetcher added in v0.2.0

func (c DependencyContainer) GetTrustedHeaderFetcher() relay.TrustedHeaderFetcher

func (DependencyContainer) GetTxProcessor added in v0.2.0

func (c DependencyContainer) GetTxProcessor() relay.TXProcessor

func (DependencyContainer) GetTxQuerier added in v0.2.0

func (c DependencyContainer) GetTxQuerier() relay.TXQuerier

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL