terra

package
v1.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 14, 2023 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultRequestTimeout = 30 * time.Second

DefaultRequestTimeout is the default Terra client timeout. Note that while the terra 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.

Variables

View Source
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 NewORM

func NewORM(db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig) types.ORM

NewORM returns an ORM backed by db. https://app.shortcut.com/chainlinklabs/story/33622/remove-legacy-config

func NewORMImmut added in v1.10.0

func SetupNodes added in v1.4.0

func SetupNodes(db *sqlx.DB, cfg SetupConfig, lggr logger.Logger) (err error)

SetupNodes is a hack/shim method to allow node operators to specify multiple nodes via ENV. See: https://app.shortcut.com/chainlinklabs/epic/33587/overhaul-config?cf_workflow=500000005&ct_workflow=all

Types

type ChainSet

type ChainSet interface {
	terra.ChainSet

	Add(context.Context, string, *db.ChainCfg) (types.DBChain, error)
	Remove(string) error
	Configure(ctx context.Context, id string, enabled bool, config *db.ChainCfg) (types.DBChain, error)
	Show(id string) (types.DBChain, error)
	Index(offset, limit int) ([]types.DBChain, int, error)
	GetNodes(ctx context.Context, offset, limit int) (nodes []db.Node, count int, err error)
	GetNodesForChain(ctx context.Context, chainID string, offset, limit int) (nodes []db.Node, count int, err error)
	CreateNode(ctx context.Context, data db.Node) (db.Node, error)
	DeleteNode(ctx context.Context, id int32) error
}

ChainSet extends terra.ChainSet with mutability and exposes the underlying ORM.

func NewChainSet

func NewChainSet(opts ChainSetOpts) (ChainSet, error)

NewChainSet returns a new chain set for opts. https://app.shortcut.com/chainlinklabs/story/33622/remove-legacy-config

func NewChainSetImmut added in v1.10.0

func NewChainSetImmut(opts ChainSetOpts, cfgs TerraConfigs) (ChainSet, error)

type ChainSetOpts

type ChainSetOpts struct {
	Config           coreconfig.BasicConfig
	Logger           logger.Logger
	DB               *sqlx.DB
	KeyStore         keystore.Terra
	EventBroadcaster pg.EventBroadcaster
	ORM              types.ORM
}

ChainSetOpts holds options for configuring a ChainSet.

func (*ChainSetOpts) NewTOMLChain added in v1.10.0

func (o *ChainSetOpts) NewTOMLChain(cfg *TerraConfig) (terra.Chain, error)

func (*ChainSetOpts) ORMAndLogger added in v1.5.0

func (o *ChainSetOpts) ORMAndLogger() (chains.ORM[string, *db.ChainCfg, db.Node], logger.Logger)

func (*ChainSetOpts) Validate added in v1.5.0

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

type SetupConfig added in v1.4.0

type SetupConfig interface {
	TerraNodes() string
	pg.QConfig
}

type TerraConfig added in v1.10.0

type TerraConfig struct {
	ChainID *string
	Enabled *bool
	tercfg.Chain
	Nodes TerraNodes
}

func (*TerraConfig) AsV1 added in v1.10.0

func (c *TerraConfig) AsV1() types.DBChain

func (*TerraConfig) BlockRate added in v1.10.0

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

func (*TerraConfig) BlocksUntilTxTimeout added in v1.10.0

func (c *TerraConfig) BlocksUntilTxTimeout() int64

func (*TerraConfig) ConfirmPollPeriod added in v1.10.0

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

func (*TerraConfig) FCDURL added in v1.10.0

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

func (*TerraConfig) FallbackGasPriceULuna added in v1.10.0

func (c *TerraConfig) FallbackGasPriceULuna() sdk.Dec

func (*TerraConfig) GasLimitMultiplier added in v1.10.0

func (c *TerraConfig) GasLimitMultiplier() float64

func (*TerraConfig) IsEnabled added in v1.10.0

func (c *TerraConfig) IsEnabled() bool

func (*TerraConfig) MaxMsgsPerBatch added in v1.10.0

func (c *TerraConfig) MaxMsgsPerBatch() int64

func (*TerraConfig) OCR2CachePollPeriod added in v1.10.0

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

func (*TerraConfig) OCR2CacheTTL added in v1.10.0

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

func (*TerraConfig) SetFrom added in v1.11.0

func (c *TerraConfig) SetFrom(f *TerraConfig)

func (*TerraConfig) SetFromDB added in v1.10.0

func (c *TerraConfig) SetFromDB(ch types.DBChain, nodes []db.Node) error

func (*TerraConfig) TxMsgTimeout added in v1.10.0

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

func (*TerraConfig) Update added in v1.10.0

func (c *TerraConfig) Update(cfg db.ChainCfg)

func (*TerraConfig) ValidateConfig added in v1.10.0

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

type TerraConfigs added in v1.10.0

type TerraConfigs []*TerraConfig

func (TerraConfigs) Chains added in v1.10.0

func (cs TerraConfigs) Chains(ids ...string) (chains []types.DBChain)

func (TerraConfigs) Node added in v1.10.0

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

func (TerraConfigs) Nodes added in v1.10.0

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

func (TerraConfigs) NodesByID added in v1.10.0

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

func (*TerraConfigs) SetFrom added in v1.11.0

func (cs *TerraConfigs) SetFrom(fs *TerraConfigs)

func (TerraConfigs) ValidateConfig added in v1.10.0

func (cs TerraConfigs) ValidateConfig() (err error)

type TerraNodes added in v1.10.0

type TerraNodes []*tercfg.Node

func (*TerraNodes) SetFrom added in v1.11.0

func (ns *TerraNodes) SetFrom(fs *TerraNodes)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL