app

Documentation

Index

• Constants
• Variables
• func NewDefaultChainClient(cfg config.NeutronQueryRelayerConfig, logRegistry *nlogger.Registry) (relay.Subscriber, error)
• func NewDefaultKVProcessor(logRegistry *nlogger.Registry, deps *DependencyContainer) (*kvprocessor.KVProcessor, error)
• func NewDefaultRelayer(cfg config.NeutronQueryRelayerConfig, logRegistry *nlogger.Registry, ...) (*relay.Relayer, 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

Constants

const (
	AppContext                   = "app"
	ChainClientContext           = "chain_client"
	RelayerContext               = "relayer"
	TargetChainRPCClientContext  = "target_chain_rpc"
	NeutronChainRPCClientContext = "neutron_chain_rpc"
	TargetChainProviderContext   = "target_chain_provider"
	NeutronChainProviderContext  = "neutron_chain_provider"
	TxSenderContext              = "tx_sender"
	TrustedHeadersFetcherContext = "trusted_headers_fetcher"
	KVProcessorContext           = "kv_processor"
)

Variables

var (
	Version = ""
	Commit  = ""
)

Functions

func NewDefaultChainClient

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

func NewDefaultKVProcessor

func NewDefaultKVProcessor(
	logRegistry *nlogger.Registry,
	deps *DependencyContainer,
) (*kvprocessor.KVProcessor, error)

NewDefaultRelayer returns a relayer built with cfg.

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.

Types

type DependencyContainer

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

func NewDefaultDependencyContainer

func NewDefaultDependencyContainer(ctx context.Context,
	cfg config.NeutronQueryRelayerConfig,
	logRegistry *nlogger.Registry) (*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