Versions in this module Expand all Collapse all v0 v0.5.0 Jun 23, 2023 v0.4.0 Jun 22, 2023 v0.3.0 Jun 22, 2023 v0.2.0 Jun 22, 2023 Changes in this version + const DefaultRequestTimeout + func SetupNodes(db *sqlx.DB, cfg SetupConfig, lggr logger.Logger) (err error) + type ChainSet interface + Add func(context.Context, string, *db.ChainCfg) (DBChain, error) + Configure func(ctx context.Context, id string, enabled bool, config *db.ChainCfg) (DBChain, error) + CreateNode func(ctx context.Context, data db.Node) (db.Node, error) + DeleteNode func(ctx context.Context, id int32) error + GetNodes func(ctx context.Context, offset, limit int) (nodes []db.Node, count int, err error) + GetNodesForChain func(ctx context.Context, chainID string, offset, limit int) (nodes []db.Node, count int, err error) + Index func(offset, limit int) ([]DBChain, int, error) + Remove func(string) error + Show func(id string) (DBChain, error) + func NewChainSet(opts ChainSetOpts) (ChainSet, error) + func NewChainSetImmut(opts ChainSetOpts, cfgs SolanaConfigs) (ChainSet, error) + type ChainSetOpts struct + DB *sqlx.DB + KeyStore keystore.Solana + Logger logger.Logger + ORM ORM + func (o *ChainSetOpts) NewChain(dbchain DBChain) (solana.Chain, error) + func (o *ChainSetOpts) NewTOMLChain(cfg *SolanaConfig) (solana.Chain, error) + func (o *ChainSetOpts) ORMAndLogger() (chains.ORM[string, *db.ChainCfg, db.Node], logger.Logger) + func (o *ChainSetOpts) Validate() (err error) + type DBChain = chains.DBChain[string, *soldb.ChainCfg] + type ORM interface + Chain func(string, ...pg.QOpt) (DBChain, error) + Chains func(offset, limit int, qopts ...pg.QOpt) ([]DBChain, int, error) + Clear func(chainID string, key string) error + CreateChain func(id string, config *soldb.ChainCfg, qopts ...pg.QOpt) (DBChain, error) + CreateNode func(soldb.Node, ...pg.QOpt) (soldb.Node, error) + DeleteChain func(id string, qopts ...pg.QOpt) error + DeleteNode func(int32, ...pg.QOpt) error + EnabledChains func(...pg.QOpt) ([]DBChain, error) + EnsureChains func([]string, ...pg.QOpt) error + GetChainsByIDs func(ids []string) (chains []DBChain, err error) + GetNodesByChainIDs func(chainIDs []string, qopts ...pg.QOpt) (nodes []soldb.Node, err error) + NodeNamed func(string, ...pg.QOpt) (soldb.Node, error) + Nodes func(offset, limit int, qopts ...pg.QOpt) (nodes []soldb.Node, count int, err error) + NodesForChain func(chainID string, offset, limit int, qopts ...pg.QOpt) (nodes []soldb.Node, count int, err error) + SetupNodes func([]soldb.Node, []string) error + StoreString func(chainID string, key, val string) error + UpdateChain func(id string, enabled bool, config *soldb.ChainCfg, qopts ...pg.QOpt) (DBChain, error) + func NewORM(db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig) ORM + func NewORMImmut(cfgs chains.ChainConfig[string, *soldb.ChainCfg, soldb.Node]) ORM + type SetupConfig interface + SolanaNodes func() string + type SolanaConfig struct + ChainID *string + Enabled *bool + Nodes SolanaNodes + func (c *SolanaConfig) AsV1() DBChain + func (c *SolanaConfig) BalancePollPeriod() time.Duration + func (c *SolanaConfig) Commitment() rpc.CommitmentType + func (c *SolanaConfig) ComputeUnitPriceDefault() uint64 + func (c *SolanaConfig) ComputeUnitPriceMax() uint64 + func (c *SolanaConfig) ComputeUnitPriceMin() uint64 + func (c *SolanaConfig) ConfirmPollPeriod() time.Duration + func (c *SolanaConfig) FeeBumpPeriod() time.Duration + func (c *SolanaConfig) FeeEstimatorMode() string + func (c *SolanaConfig) IsEnabled() bool + func (c *SolanaConfig) MaxRetries() *uint + func (c *SolanaConfig) OCR2CachePollPeriod() time.Duration + func (c *SolanaConfig) OCR2CacheTTL() time.Duration + func (c *SolanaConfig) SetFrom(f *SolanaConfig) + func (c *SolanaConfig) SetFromDB(ch DBChain, nodes []soldb.Node) error + func (c *SolanaConfig) SkipPreflight() bool + func (c *SolanaConfig) TxConfirmTimeout() time.Duration + func (c *SolanaConfig) TxRetryTimeout() time.Duration + func (c *SolanaConfig) TxTimeout() time.Duration + func (c *SolanaConfig) Update(cfg soldb.ChainCfg) + func (c *SolanaConfig) ValidateConfig() (err error) + type SolanaConfigs []*SolanaConfig + func (cs *SolanaConfigs) SetFrom(fs *SolanaConfigs) + func (cs SolanaConfigs) Chains(ids ...string) (chains []DBChain) + func (cs SolanaConfigs) Node(name string) (soldb.Node, error) + func (cs SolanaConfigs) Nodes() (ns []soldb.Node) + func (cs SolanaConfigs) NodesByID(chainIDs ...string) (ns []soldb.Node) + func (cs SolanaConfigs) ValidateConfig() (err error) + type SolanaNodes []*solcfg.Node + func (ns *SolanaNodes) SetFrom(fs *SolanaNodes)