config

package
v0.3.3 Latest Latest
Warning

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

Go to latest
Published: Sep 5, 2025 License: LGPL-3.0, MIT Imports: 10 Imported by: 27

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AutoPurgeConfig

type AutoPurgeConfig interface {
	Enabled() bool
	Threshold() *uint32
	MinAttempts() *uint32
	DetectionApiUrl() *url.URL
}

type BalanceMonitor

type BalanceMonitor interface {
	Enabled() bool
}

type BlockHistory

type BlockHistory interface {
	BatchSize() uint32
	BlockHistorySize() uint16
	BlockDelay() uint16
	CheckInclusionBlocks() uint16
	CheckInclusionPercentile() uint16
	EIP1559FeeCapBufferBlocks() uint16
	TransactionPercentile() uint16
}

type ChainScoped

type ChainScoped struct {
	// contains filtered or unexported fields
}

ChainScoped implements config.ChainScopedConfig with EVMConfig.

func NewTOMLChainScopedConfig

func NewTOMLChainScopedConfig(tomlConfig *toml.EVMConfig) *ChainScoped

func (*ChainScoped) BlockEmissionIdleWarningThreshold

func (c *ChainScoped) BlockEmissionIdleWarningThreshold() time.Duration

func (*ChainScoped) EVM

func (c *ChainScoped) EVM() EVM

func (*ChainScoped) Nodes

func (c *ChainScoped) Nodes() toml.EVMNodes

type ChainScopedConfig

type ChainScopedConfig interface {
	EVM() EVM
}

type ClientErrors

type ClientErrors interface {
	NonceTooLow() string
	NonceTooHigh() string
	ReplacementTransactionUnderpriced() string
	LimitReached() string
	TransactionAlreadyInMempool() string
	TerminallyUnderpriced() string
	InsufficientEth() string
	TxFeeExceedsCap() string
	L2FeeTooLow() string
	L2FeeTooHigh() string
	L2Full() string
	TransactionAlreadyMined() string
	Fatal() string
	ServiceUnavailable() string
	TooManyResults() string
	MissingBlocks() string
}

type DAOracle

type DAOracle interface {
	OracleType() *toml.DAOracleType
	OracleAddress() *types.EIP55Address
	CustomGasPriceCalldata() *string
}

type EVM

type EVM interface {
	HeadTracker() HeadTracker
	BalanceMonitor() BalanceMonitor
	Transactions() Transactions
	GasEstimator() GasEstimator
	OCR() OCR
	OCR2() OCR2
	Workflow() Workflow
	NodePool() NodePool

	AutoCreateKey() bool
	BlockBackfillDepth() uint64
	BlockBackfillSkip() bool
	BlockEmissionIdleWarningThreshold() time.Duration
	ChainID() *big.Int
	ChainType() chaintype.ChainType
	FinalityDepth() uint32
	SafeDepth() uint32
	FinalityTagEnabled() bool
	FlagsContractAddress() string
	LinkContractAddress() string
	LogBackfillBatchSize() uint32
	LogKeepBlocksDepth() uint32
	BackupLogPollerBlockDelay() uint64
	LogPollInterval() time.Duration
	LogPrunePageSize() uint32
	MinContractPayment() *commonassets.Link
	MinIncomingConfirmations() uint32
	NonceAutoSync() bool
	OperatorFactoryAddress() string
	LogBroadcasterEnabled() bool
	RPCDefaultBatchSize() uint32
	NodeNoNewHeadsThreshold() time.Duration
	FinalizedBlockOffset() uint32
	NoNewFinalizedHeadsThreshold() time.Duration
	// Applies to EVMService. This is the maximum amount of time we will wait for a TX to get confirmed in the chain.
	ConfirmationTimeout() time.Duration

	IsEnabled() bool
	TOMLString() (string, error)
}

type EVMConfig

type EVMConfig struct {
	C *toml.EVMConfig
}

func (*EVMConfig) AutoCreateKey

func (e *EVMConfig) AutoCreateKey() bool

func (*EVMConfig) BackupLogPollerBlockDelay

func (e *EVMConfig) BackupLogPollerBlockDelay() uint64

func (*EVMConfig) BalanceMonitor

func (e *EVMConfig) BalanceMonitor() BalanceMonitor

func (*EVMConfig) BlockBackfillDepth

func (e *EVMConfig) BlockBackfillDepth() uint64

func (*EVMConfig) BlockBackfillSkip

func (e *EVMConfig) BlockBackfillSkip() bool

func (*EVMConfig) BlockEmissionIdleWarningThreshold

func (e *EVMConfig) BlockEmissionIdleWarningThreshold() time.Duration

func (*EVMConfig) ChainID

func (e *EVMConfig) ChainID() *big.Int

func (*EVMConfig) ChainType

func (e *EVMConfig) ChainType() chaintype.ChainType

func (*EVMConfig) ClientErrors

func (e *EVMConfig) ClientErrors() ClientErrors

func (*EVMConfig) ConfirmationTimeout

func (e *EVMConfig) ConfirmationTimeout() time.Duration

func (*EVMConfig) FinalityDepth

func (e *EVMConfig) FinalityDepth() uint32

func (*EVMConfig) FinalityTagEnabled

func (e *EVMConfig) FinalityTagEnabled() bool

func (*EVMConfig) FinalizedBlockOffset

func (e *EVMConfig) FinalizedBlockOffset() uint32

func (*EVMConfig) FlagsContractAddress

func (e *EVMConfig) FlagsContractAddress() string

func (*EVMConfig) GasEstimator

func (e *EVMConfig) GasEstimator() GasEstimator

func (*EVMConfig) HeadTracker

func (e *EVMConfig) HeadTracker() HeadTracker

func (*EVMConfig) IsEnabled

func (e *EVMConfig) IsEnabled() bool

func (*EVMConfig) LinkContractAddress

func (e *EVMConfig) LinkContractAddress() string

func (*EVMConfig) LogBackfillBatchSize

func (e *EVMConfig) LogBackfillBatchSize() uint32

func (*EVMConfig) LogBroadcasterEnabled

func (e *EVMConfig) LogBroadcasterEnabled() bool

func (*EVMConfig) LogKeepBlocksDepth

func (e *EVMConfig) LogKeepBlocksDepth() uint32

func (*EVMConfig) LogPollInterval

func (e *EVMConfig) LogPollInterval() time.Duration

func (*EVMConfig) LogPrunePageSize

func (e *EVMConfig) LogPrunePageSize() uint32

func (*EVMConfig) MinContractPayment

func (e *EVMConfig) MinContractPayment() *assets.Link

func (*EVMConfig) MinIncomingConfirmations

func (e *EVMConfig) MinIncomingConfirmations() uint32

func (*EVMConfig) NoNewFinalizedHeadsThreshold

func (e *EVMConfig) NoNewFinalizedHeadsThreshold() time.Duration

func (*EVMConfig) NodeNoNewHeadsThreshold

func (e *EVMConfig) NodeNoNewHeadsThreshold() time.Duration

func (*EVMConfig) NodePool

func (e *EVMConfig) NodePool() NodePool

func (*EVMConfig) NonceAutoSync

func (e *EVMConfig) NonceAutoSync() bool

func (*EVMConfig) OCR

func (e *EVMConfig) OCR() OCR

func (*EVMConfig) OCR2

func (e *EVMConfig) OCR2() OCR2

func (*EVMConfig) OperatorFactoryAddress

func (e *EVMConfig) OperatorFactoryAddress() string

func (*EVMConfig) RPCDefaultBatchSize

func (e *EVMConfig) RPCDefaultBatchSize() uint32

func (*EVMConfig) SafeDepth

func (e *EVMConfig) SafeDepth() uint32

func (*EVMConfig) TOMLString

func (e *EVMConfig) TOMLString() (string, error)

func (*EVMConfig) Transactions

func (e *EVMConfig) Transactions() Transactions

func (*EVMConfig) Workflow

func (e *EVMConfig) Workflow() Workflow

type FeeHistory

type FeeHistory interface {
	CacheTimeout() time.Duration
}

type GasEstimator

type GasEstimator interface {
	BlockHistory() BlockHistory
	FeeHistory() FeeHistory
	LimitJobType() LimitJobType

	EIP1559DynamicFees() bool
	BumpPercent() uint16
	BumpThreshold() uint64
	BumpTxDepth() uint32
	BumpMin() *assets.Wei
	FeeCapDefault() *assets.Wei
	LimitDefault() uint64
	LimitMax() uint64
	LimitMultiplier() float32
	LimitTransfer() uint64
	PriceDefault() *assets.Wei
	TipCapDefault() *assets.Wei
	TipCapMin() *assets.Wei
	PriceMax() *assets.Wei
	PriceMin() *assets.Wei
	Mode() string
	PriceMaxKey(gethcommon.Address) *assets.Wei
	EstimateLimit() bool
	SenderAddress() *types.EIP55Address
	DAOracle() DAOracle
}

type HeadTracker

type HeadTracker interface {
	HistoryDepth() uint32
	MaxBufferSize() uint32
	SamplingInterval() time.Duration
	FinalityTagBypass() bool
	MaxAllowedFinalityDepth() uint32
	PersistenceEnabled() bool
	PersistenceBatchSize() int64
}

type LimitJobType

type LimitJobType interface {
	OCR() *uint32
	OCR2() *uint32
	DR() *uint32
	FM() *uint32
	Keeper() *uint32
	VRF() *uint32
}

type NodePool

type NodePool interface {
	PollFailureThreshold() uint32
	PollInterval() time.Duration
	SelectionMode() string
	SyncThreshold() uint32
	LeaseDuration() time.Duration
	NodeIsSyncingEnabled() bool
	FinalizedBlockPollInterval() time.Duration
	Errors() ClientErrors
	EnforceRepeatableRead() bool
	DeathDeclarationDelay() time.Duration
	NewHeadsPollInterval() time.Duration
	VerifyChainID() bool
	ExternalRequestMaxResponseSize() uint32
}

type NodePoolConfig

type NodePoolConfig struct {
	C toml.NodePool
}

func (*NodePoolConfig) DeathDeclarationDelay

func (n *NodePoolConfig) DeathDeclarationDelay() time.Duration

func (*NodePoolConfig) EnforceRepeatableRead

func (n *NodePoolConfig) EnforceRepeatableRead() bool

func (*NodePoolConfig) Errors

func (n *NodePoolConfig) Errors() ClientErrors

func (*NodePoolConfig) ExternalRequestMaxResponseSize added in v0.2.0

func (n *NodePoolConfig) ExternalRequestMaxResponseSize() uint32

func (*NodePoolConfig) FinalizedBlockPollInterval

func (n *NodePoolConfig) FinalizedBlockPollInterval() time.Duration

func (*NodePoolConfig) LeaseDuration

func (n *NodePoolConfig) LeaseDuration() time.Duration

func (*NodePoolConfig) NewHeadsPollInterval

func (n *NodePoolConfig) NewHeadsPollInterval() time.Duration

func (*NodePoolConfig) NodeIsSyncingEnabled

func (n *NodePoolConfig) NodeIsSyncingEnabled() bool

func (*NodePoolConfig) PollFailureThreshold

func (n *NodePoolConfig) PollFailureThreshold() uint32

func (*NodePoolConfig) PollInterval

func (n *NodePoolConfig) PollInterval() time.Duration

func (*NodePoolConfig) SelectionMode

func (n *NodePoolConfig) SelectionMode() string

func (*NodePoolConfig) SyncThreshold

func (n *NodePoolConfig) SyncThreshold() uint32

func (*NodePoolConfig) VerifyChainID

func (n *NodePoolConfig) VerifyChainID() bool

type OCR

type OCR interface {
	ContractConfirmations() uint16
	ContractTransmitterTransmitTimeout() time.Duration
	ObservationGracePeriod() time.Duration
	DatabaseTimeout() time.Duration
	DeltaCOverride() time.Duration
	DeltaCJitterOverride() time.Duration
}

type OCR2

type OCR2 interface {
	Automation() OCR2Automation
}

type OCR2Automation

type OCR2Automation interface {
	GasLimit() uint32
}

type TransactionManagerV2

type TransactionManagerV2 interface {
	Enabled() bool
	BlockTime() *time.Duration
	CustomURL() *url.URL
	DualBroadcast() *bool
}

type Transactions

type Transactions interface {
	Enabled() bool
	ForwardersEnabled() bool
	ReaperInterval() time.Duration
	ResendAfterThreshold() time.Duration
	ReaperThreshold() time.Duration
	MaxInFlight() uint32
	MaxQueued() uint64
	AutoPurge() AutoPurgeConfig
	TransactionManagerV2() TransactionManagerV2
}

type Workflow

type Workflow interface {
	AcceptanceTimeout() time.Duration
	ForwarderAddress() *types.EIP55Address
	FromAddress() *types.EIP55Address
	GasLimitDefault() *uint64
	PollPeriod() time.Duration
	TxAcceptanceState() *commontypes.TransactionStatus
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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