cosmos

Documentation

Index

• Constants
• Variables
• func NewChain(cfg *CosmosConfig, opts ChainOpts) (adapters.Chain, error)
• type Chain
• type ChainOpts
  • func (o *ChainOpts) Validate() (err error)
• type CosmosConfig
  • func (c *CosmosConfig) Bech32Prefix() string
  • func (c *CosmosConfig) BlockRate() time.Duration
  • func (c *CosmosConfig) BlocksUntilTxTimeout() int64
  • func (c *CosmosConfig) ConfirmPollPeriod() time.Duration
  • func (c *CosmosConfig) FallbackGasPrice() sdk.Dec
  • func (c *CosmosConfig) GasLimitMultiplier() float64
  • func (c *CosmosConfig) GasToken() string
  • func (c *CosmosConfig) GetNode(name string) (db.Node, error)
  • func (c *CosmosConfig) IsEnabled() bool
  • func (c *CosmosConfig) ListNodes() ([]db.Node, error)
  • func (c *CosmosConfig) MaxMsgsPerBatch() int64
  • func (c *CosmosConfig) OCR2CachePollPeriod() time.Duration
  • func (c *CosmosConfig) OCR2CacheTTL() time.Duration
  • func (c *CosmosConfig) SetFrom(f *CosmosConfig)
  • func (c *CosmosConfig) TOMLString() (string, error)
  • func (c *CosmosConfig) TxMsgTimeout() time.Duration
  • func (c *CosmosConfig) ValidateConfig() (err error)
• type CosmosConfigs
  • func (cs *CosmosConfigs) SetFrom(fs *CosmosConfigs) (err error)
  • func (cs CosmosConfigs) ValidateConfig() (err error)
• type CosmosNodes
  • func (ns *CosmosNodes) SetFrom(fs *CosmosNodes)
• type LegacyChainContainer
• type LegacyChains
  • func NewLegacyChains(m map[string]adapters.Chain) *LegacyChains
• type LoopRelayerChain
  • func NewLoopRelayerChain(r *pkgcosmos.Relayer, s adapters.Chain) *LoopRelayerChain
  • func (r *LoopRelayerChain) Chain() adapters.Chain
• type LoopRelayerChainer

Constants

const DefaultRequestTimeout = 30 * time.Second

DefaultRequestTimeout is the default Cosmos client timeout. Note that while the cosmos node is processing a heavy block, requests can be delayed significantly (https://github.com/tendermint/tendermint/issues/6899), however there's nothing we can do but wait until the block is processed. So we set a fairly high timeout here. TODO(BCI-979): Remove this, or make this configurable with the updated client.

Variables

var (
	// ErrChainIDEmpty is returned when chain is required but was empty.
	ErrChainIDEmpty = errors.New("chain id empty")
	// ErrChainIDInvalid is returned when a chain id does not match any configured chains.
	ErrChainIDInvalid = errors.New("chain id does not match any local chains")
)

Functions

func NewChain

func NewChain(cfg *CosmosConfig, opts ChainOpts) (adapters.Chain, error)

Types

type Chain

type Chain = adapters.Chain

Chain is a wrap for easy use in other places in the core node

type ChainOpts

type ChainOpts struct {
	QueryConfig      pg.QConfig
	Logger           logger.Logger
	DB               *sqlx.DB
	KeyStore         loop.Keystore
	EventBroadcaster pg.EventBroadcaster
}

ChainOpts holds options for configuring a Chain.

func (*ChainOpts) Validate

func (o *ChainOpts) Validate() (err error)

type CosmosConfig

type CosmosConfig struct {
	ChainID *string
	// Do not access directly. Use [IsEnabled]
	Enabled *bool
	coscfg.Chain
	Nodes CosmosNodes
}

func (*CosmosConfig) Bech32Prefix

func (c *CosmosConfig) Bech32Prefix() string

func (*CosmosConfig) BlockRate

func (c *CosmosConfig) BlockRate() time.Duration

func (*CosmosConfig) BlocksUntilTxTimeout

func (c *CosmosConfig) BlocksUntilTxTimeout() int64

func (*CosmosConfig) ConfirmPollPeriod

func (c *CosmosConfig) ConfirmPollPeriod() time.Duration

func (*CosmosConfig) FallbackGasPrice

func (c *CosmosConfig) FallbackGasPrice() sdk.Dec

func (*CosmosConfig) GasLimitMultiplier

func (c *CosmosConfig) GasLimitMultiplier() float64

func (*CosmosConfig) GasToken

func (c *CosmosConfig) GasToken() string

func (*CosmosConfig) GetNode

func (c *CosmosConfig) GetNode(name string) (db.Node, error)

func (*CosmosConfig) IsEnabled

func (c *CosmosConfig) IsEnabled() bool

func (*CosmosConfig) ListNodes

func (c *CosmosConfig) ListNodes() ([]db.Node, error)

func (*CosmosConfig) MaxMsgsPerBatch

func (c *CosmosConfig) MaxMsgsPerBatch() int64

func (*CosmosConfig) OCR2CachePollPeriod

func (c *CosmosConfig) OCR2CachePollPeriod() time.Duration

func (*CosmosConfig) OCR2CacheTTL

func (c *CosmosConfig) OCR2CacheTTL() time.Duration

func (*CosmosConfig) SetFrom

func (c *CosmosConfig) SetFrom(f *CosmosConfig)

func (*CosmosConfig) TOMLString

func (c *CosmosConfig) TOMLString() (string, error)

func (*CosmosConfig) TxMsgTimeout

func (c *CosmosConfig) TxMsgTimeout() time.Duration

func (*CosmosConfig) ValidateConfig

func (c *CosmosConfig) ValidateConfig() (err error)

type CosmosConfigs

type CosmosConfigs []*CosmosConfig

func (*CosmosConfigs) SetFrom

func (cs *CosmosConfigs) SetFrom(fs *CosmosConfigs) (err error)

func (CosmosConfigs) ValidateConfig

func (cs CosmosConfigs) ValidateConfig() (err error)

type CosmosNodes

type CosmosNodes []*coscfg.Node

func (*CosmosNodes) SetFrom

func (ns *CosmosNodes) SetFrom(fs *CosmosNodes)

type LegacyChainContainer

type LegacyChainContainer interface {
	Get(id string) (adapters.Chain, error)
	Len() int
	List(ids ...string) ([]adapters.Chain, error)
	Slice() []adapters.Chain
}

LegacyChainContainer is container interface for Cosmos chains

type LegacyChains

type LegacyChains = chains.ChainsKV[adapters.Chain]

func NewLegacyChains

func NewLegacyChains(m map[string]adapters.Chain) *LegacyChains

type LoopRelayerChain

type LoopRelayerChain struct {
	loop.Relayer
	// contains filtered or unexported fields
}

func NewLoopRelayerChain

func NewLoopRelayerChain(r *pkgcosmos.Relayer, s adapters.Chain) *LoopRelayerChain

func (*LoopRelayerChain) Chain

func (r *LoopRelayerChain) Chain() adapters.Chain

type LoopRelayerChainer

type LoopRelayerChainer interface {
	loop.Relayer
	Chain() adapters.Chain
}