cosmos

Documentation

Index

• Constants
• Variables
• func EnsureChains(db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig, ids []utils.Big) error
• 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 []chains.ChainConfig, err error)
  • func (cs CosmosConfigs) Node(name string) (n db.Node, err error)
  • func (cs CosmosConfigs) Nodes() (ns []db.Node)
  • func (cs CosmosConfigs) NodesByID(chainIDs ...string) (ns []db.Node)
  • 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 EnsureChains

func EnsureChains(db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig, ids []utils.Big) error

func NewConfigs

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

Types

type ChainSet

type ChainSet interface {
	adapters.ChainSet
	chains.Nodes[string, db.Node]
	chains.Chains[string]
}

ChainSet extends adapters.ChainSet with mutability and exposes the underlying Configs.

func NewChainSet

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

type ChainSetOpts

type ChainSetOpts struct {
	Config           coreconfig.BasicConfig
	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 []chains.ChainConfig, err error)

func (CosmosConfigs) Node

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

func (CosmosConfigs) Nodes

func (cs CosmosConfigs) Nodes() (ns []db.Node)

func (CosmosConfigs) NodesByID

func (cs CosmosConfigs) NodesByID(chainIDs ...string) (ns []db.Node)

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)