cosmos

Documentation

Index

• Constants
• Variables
• func NewConfigs(cfgs chains.ConfigsV2[string, db.Node]) types.Configs
• type ChainSet
  • func NewChainSet(opts ChainSetOpts, cfgs CosmosConfigs) (ChainSet, error)
• type ChainSetOpts
  • func (o *ChainSetOpts) ConfigsAndLogger() (chains.Configs[string, db.Node], logger.Logger)
  • func (o *ChainSetOpts) NewTOMLChain(cfg *CosmosConfig) (adapters.Chain, error)
  • func (o *ChainSetOpts) Validate() (err error)
• type CosmosConfig
  • func (c *CosmosConfig) BlockRate() time.Duration
  • func (c *CosmosConfig) BlocksUntilTxTimeout() int64
  • func (c *CosmosConfig) ConfirmPollPeriod() time.Duration
  • func (c *CosmosConfig) FCDURL() url.URL
  • func (c *CosmosConfig) FallbackGasPriceUAtom() sdk.Dec
  • func (c *CosmosConfig) GasLimitMultiplier() float64
  • func (c *CosmosConfig) IsEnabled() bool
  • 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) Chains(ids ...string) (r []relaytypes.ChainStatus, err error)
  • func (cs CosmosConfigs) Node(name string) (n db.Node, err error)
  • func (cs CosmosConfigs) NodeStatus(name string) (n relaytypes.NodeStatus, err error)
  • func (cs CosmosConfigs) NodeStatuses(chainIDs ...string) (ns []relaytypes.NodeStatus, err error)
  • func (cs CosmosConfigs) Nodes(chainID string) (ns []db.Node, err error)
  • func (cs *CosmosConfigs) SetFrom(fs *CosmosConfigs)
  • func (cs CosmosConfigs) ValidateConfig() (err error)
• type CosmosNodes
  • func (ns *CosmosNodes) SetFrom(fs *CosmosNodes)

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 NewConfigs

func NewConfigs(cfgs chains.ConfigsV2[string, db.Node]) types.Configs

Types

type ChainSet

type ChainSet = adapters.ChainSet

func NewChainSet

func NewChainSet(opts ChainSetOpts, cfgs CosmosConfigs) (ChainSet, error)

type ChainSetOpts

type ChainSetOpts struct {
	Config           coreconfig.AppConfig
	Logger           logger.Logger
	DB               *sqlx.DB
	KeyStore         keystore.Cosmos
	EventBroadcaster pg.EventBroadcaster
	Configs          types.Configs
}

ChainSetOpts holds options for configuring a ChainSet.

func (*ChainSetOpts) ConfigsAndLogger

func (o *ChainSetOpts) ConfigsAndLogger() (chains.Configs[string, db.Node], logger.Logger)

func (*ChainSetOpts) NewTOMLChain

func (o *ChainSetOpts) NewTOMLChain(cfg *CosmosConfig) (adapters.Chain, error)

func (*ChainSetOpts) Validate

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

type CosmosConfig

type CosmosConfig struct {
	ChainID *string
	Enabled *bool
	coscfg.Chain
	Nodes CosmosNodes
}

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) FCDURL

func (c *CosmosConfig) FCDURL() url.URL

func (*CosmosConfig) FallbackGasPriceUAtom

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

func (*CosmosConfig) GasLimitMultiplier

func (c *CosmosConfig) GasLimitMultiplier() float64

func (*CosmosConfig) IsEnabled

func (c *CosmosConfig) IsEnabled() bool

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) Chains

func (cs CosmosConfigs) Chains(ids ...string) (r []relaytypes.ChainStatus, err error)

func (CosmosConfigs) Node

func (cs CosmosConfigs) Node(name string) (n db.Node, err error)

func (CosmosConfigs) NodeStatus

func (cs CosmosConfigs) NodeStatus(name string) (n relaytypes.NodeStatus, err error)

func (CosmosConfigs) NodeStatuses

func (cs CosmosConfigs) NodeStatuses(chainIDs ...string) (ns []relaytypes.NodeStatus, err error)

func (CosmosConfigs) Nodes

func (cs CosmosConfigs) Nodes(chainID string) (ns []db.Node, err error)

func (*CosmosConfigs) SetFrom

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

func (CosmosConfigs) ValidateConfig

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

type CosmosNodes

type CosmosNodes []*coscfg.Node

func (*CosmosNodes) SetFrom

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