app

Documentation

Index

• Constants
• Variables
• func NewDefaultRelayer(cfg config.NeutronQueryRelayerConfig, logRegistry *nlogger.Registry, ...) (*relay.Relayer, error)
• func NewDefaultStorage(cfg config.NeutronQueryRelayerConfig, logger *zap.Logger) (relay.Storage, error)
• func NewDefaultTxSubmitChecker(cfg config.NeutronQueryRelayerConfig, logRegistry *nlogger.Registry, ...) (relay.TxSubmitChecker, error)
• type DependencyContainer
  • func NewDefaultDependencyContainer(ctx context.Context, cfg config.NeutronQueryRelayerConfig, ...) (*DependencyContainer, error)
  • func (c DependencyContainer) GetKvProcessor() relay.KVProcessor
  • func (c DependencyContainer) GetNeutronChain() *cosmosrelayer.Chain
  • func (c DependencyContainer) GetProofSubmitter() relay.Submitter
  • func (c DependencyContainer) GetTargetChain() *cosmosrelayer.Chain
  • func (c DependencyContainer) GetTargetQuerier() *tmquerier.Querier
  • func (c DependencyContainer) GetTrustedHeaderFetcher() relay.TrustedHeaderFetcher
  • func (c DependencyContainer) GetTxProcessor() relay.TXProcessor
  • func (c DependencyContainer) GetTxQuerier() relay.TXQuerier

Constants

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

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

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

func NewDefaultTxSubmitChecker

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

Types

type DependencyContainer

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

func NewDefaultDependencyContainer

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

func (DependencyContainer) GetKvProcessor

func (c DependencyContainer) GetKvProcessor() relay.KVProcessor

func (DependencyContainer) GetNeutronChain

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

func (DependencyContainer) GetProofSubmitter

func (c DependencyContainer) GetProofSubmitter() relay.Submitter

func (DependencyContainer) GetTargetChain

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

func (DependencyContainer) GetTargetQuerier

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

func (DependencyContainer) GetTrustedHeaderFetcher

func (c DependencyContainer) GetTrustedHeaderFetcher() relay.TrustedHeaderFetcher

func (DependencyContainer) GetTxProcessor

func (c DependencyContainer) GetTxProcessor() relay.TXProcessor

func (DependencyContainer) GetTxQuerier

func (c DependencyContainer) GetTxQuerier() relay.TXQuerier