bulletprooftxmanager

Jan 25, 2022

Changes in this version

+ const SimulationTimeout

+ var Max256BitUInt = big.NewInt(0).Exp(big.NewInt(2), big.NewInt(256), nil)

+ type ChainKeyStore struct

+ func NewChainKeyStore(chainID big.Int, config Config, keystore KeyStore) ChainKeyStore

+ func (c *ChainKeyStore) NewDynamicFeeAttempt(etx EthTx, fee gas.DynamicFee, gasLimit uint64) (attempt EthTxAttempt, err error)

+ func (c *ChainKeyStore) NewLegacyAttempt(etx EthTx, gasPrice *big.Int, gasLimit uint64) (attempt EthTxAttempt, err error)

+ func (c *ChainKeyStore) SignTx(address common.Address, tx *gethTypes.Transaction) (common.Hash, []byte, error)

type Config

+ KeySpecificMaxGasPriceWei func(addr common.Address) *big.Int

+ LogSQL func() bool

type DropOldestStrategy

+ func (s DropOldestStrategy) Simulate() bool

type EthTx

+ AccessList NullableEIP2930AccessList

+ EVMChainID utils.Big

+ MinConfirmations cnull.Uint32

+ PipelineTaskRunID uuid.NullUUID

+ Simulate bool

type EthTxAttempt

+ GasFeeCap *utils.Big

+ GasTipCap *utils.Big

+ TxType int

+ func (a EthTxAttempt) DynamicFee() gas.DynamicFee

type EthTxMeta

+ MaxLink string

+ SubID uint64

type KeyStore

+ GetStatesForChain func(chainID *big.Int) ([]ethkey.State, error)

+ type NullableEIP2930AccessList struct

+ AccessList types.AccessList

+ Valid bool

+ func NullableEIP2930AccessListFrom(al types.AccessList) (n NullableEIP2930AccessList)

+ func (e *NullableEIP2930AccessList) Scan(value interface{}) error

+ func (e *NullableEIP2930AccessList) UnmarshalJSON(input []byte) error

+ func (e NullableEIP2930AccessList) MarshalJSON() ([]byte, error)

+ func (e NullableEIP2930AccessList) Value() (driver.Value, error)

+ type ORM interface

+ EthTransactionsWithAttempts func(offset, limit int) ([]EthTx, int, error)

+ EthTxAttempts func(offset, limit int) ([]EthTxAttempt, int, error)

+ FindEthTxAttempt func(hash common.Hash) (*EthTxAttempt, error)

+ FindEthTxWithAttempts func(etxID int64) (etx EthTx, err error)

+ InsertEthReceipt func(receipt *EthReceipt) error

+ InsertEthTx func(etx *EthTx) error

+ InsertEthTxAttempt func(attempt *EthTxAttempt) error

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

+ type ResumeCallback func(id uuid.UUID, result interface{}, err error) error

type SendEveryStrategy

+ func (s SendEveryStrategy) Simulate() bool

type TxStrategy

+ func NewSendEveryStrategy(simulate bool) TxStrategy

+ Simulate func() bool

Oct 19, 2021

Changes in this version

+ func SignTx(keyStore KeyStore, address common.Address, tx *gethTypes.Transaction, ...) (common.Hash, []byte, error)

type BulletproofTxManager

+ func (b *BulletproofTxManager) RegisterResumeCallback(fn func(id uuid.UUID, value interface{}) error)

type Config

+ EvmFinalityDepth func() uint

+ EvmGasBumpPercent func() uint16

+ EvmGasBumpThreshold func() uint64

+ EvmGasBumpTxDepth func() uint16

+ EvmGasBumpWei func() *big.Int

+ EvmGasLimitDefault func() uint64

+ EvmGasLimitMultiplier func() float32

+ EvmGasPriceDefault func() *big.Int

+ EvmMaxGasPriceWei func() *big.Int

+ EvmMaxInFlightTransactions func() uint32

+ EvmMaxQueuedTransactions func() uint64

+ EvmMinGasPriceWei func() *big.Int

+ EvmNonceAutoSync func() bool

+ EvmRPCDefaultBatchSize func() uint32

type EthConfirmer

+ func (ec *EthConfirmer) ResumePendingTaskRuns(ctx context.Context, head models.Head) error

+ type EthTxMeta struct

+ JobID int32

+ RequestID common.Hash

+ RequestTxHash common.Hash

+ func (EthTxMeta) GormDataType() string

type KeyStore

+ GetAll func() (keys []ethkey.KeyV2, err error)

+ GetState func(id string) (ethkey.State, error)

+ type NewTx struct

+ EncodedPayload []byte

+ FromAddress common.Address

+ GasLimit uint64

+ Meta *EthTxMeta

+ MinConfirmations null.Uint32

+ PipelineTaskRunID *uuid.UUID

+ Strategy TxStrategy

+ ToAddress common.Address

type NullTxManager

+ func (n *NullTxManager) RegisterResumeCallback(fn func(id uuid.UUID, value interface{}) error)

type ReaperConfig

+ EvmFinalityDepth func() uint

type TxManager

+ RegisterResumeCallback func(fn func(id uuid.UUID, value interface{}) error)

Aug 9, 2021

Changes in this version

+ func CountUnstartedTransactions(db *gorm.DB, fromAddress common.Address) (count uint32, err error)

Jul 26, 2021

Changes in this version

+ const EthTxAttemptBroadcast

+ const EthTxAttemptInProgress

+ const EthTxAttemptInsufficientEth

+ const EthTxConfirmed

+ const EthTxConfirmedMissingReceipt

+ const EthTxFatalError

+ const EthTxInProgress

+ const EthTxUnconfirmed

+ const EthTxUnstarted

type BulletproofTxManager

+ func (b *BulletproofTxManager) GetGasEstimator() gas.Estimator

type Config

+ BlockHistoryEstimatorBatchSize func() uint32

+ BlockHistoryEstimatorBlockDelay func() uint16

+ BlockHistoryEstimatorBlockHistorySize func() uint16

+ BlockHistoryEstimatorTransactionPercentile func() uint16

+ EthMinGasPriceWei func() *big.Int

+ GasEstimatorMode func() string

+ type EthReceipt struct

+ BlockHash common.Hash

+ BlockNumber int64

+ CreatedAt time.Time

+ ID int64

+ Receipt []byte

+ TransactionIndex uint

+ TxHash common.Hash

+ type EthTaskRunTx struct

+ EthTx EthTx

+ EthTxID int64

+ TaskRunID uuid.UUID

+ type EthTx struct

+ BroadcastAt *time.Time

+ CreatedAt time.Time

+ EncodedPayload []byte

+ Error null.String

+ EthTxAttempts []EthTxAttempt

+ FromAddress common.Address

+ GasLimit uint64

+ ID int64

+ Meta postgres.Jsonb

+ Nonce *int64

+ State EthTxState

+ Subject uuid.NullUUID

+ ToAddress common.Address

+ Value assets.Eth

+ func (e EthTx) GetError() error

+ func (e EthTx) GetID() string

+ type EthTxAttempt struct

+ BroadcastBeforeBlockNum *int64

+ ChainSpecificGasLimit uint64

+ CreatedAt time.Time

+ EthReceipts []EthReceipt

+ EthTx EthTx

+ EthTxID int64

+ GasPrice utils.Big

+ Hash common.Hash

+ ID int64

+ SignedRawTx []byte

+ State EthTxAttemptState

+ func (a EthTxAttempt) GetSignedTx() (*types.Transaction, error)

+ type EthTxAttemptState string

+ type EthTxState string

type NullTxManager

+ func (n *NullTxManager) GetGasEstimator() gas.Estimator

type TxManager

+ GetGasEstimator func() gas.Estimator

Jul 6, 2021

Changes in this version

+ type DropOldestStrategy struct

+ func NewDropOldestStrategy(subject uuid.UUID, queueSize uint32) DropOldestStrategy

+ func (s DropOldestStrategy) PruneQueue(tx *gorm.DB) (n int64, err error)

+ func (s DropOldestStrategy) Subject() uuid.NullUUID

+ type SendEveryStrategy struct

+ func (SendEveryStrategy) PruneQueue(*gorm.DB) (int64, error)

+ func (SendEveryStrategy) Subject() uuid.NullUUID

+ type TxStrategy interface

+ PruneQueue func(tx *gorm.DB) (n int64, err error)

+ Subject func() uuid.NullUUID

+ func NewQueueingTxStrategy(subject uuid.UUID, queueSize uint32) (strategy TxStrategy)

Jun 21, 2021

Changes in this version

+ const EthMaxInFlightTransactionsWarningLabel

+ const EthMaxQueuedTransactionsLabel

+ const EthNodeConnectivityProblemLabel

+ const InFlightTransactionRecheckInterval

+ func CheckEthTxQueueCapacity(db *gorm.DB, fromAddress common.Address, maxQueuedTransactions uint64) (err error)

+ func CountUnconfirmedTransactions(db *gorm.DB, fromAddress common.Address) (count uint32, err error)

+ type BulletproofTxManager struct

+ func NewBulletproofTxManager(db *gorm.DB, ethClient eth.Client, config Config, keyStore KeyStore, ...) *BulletproofTxManager

+ func (b *BulletproofTxManager) Close() (merr error)

+ func (b *BulletproofTxManager) Connect(*models.Head) error

+ func (b *BulletproofTxManager) CreateEthTransaction(db *gorm.DB, fromAddress, toAddress common.Address, payload []byte, ...) (etx models.EthTx, err error)

+ func (b *BulletproofTxManager) OnNewLongestChain(ctx context.Context, head models.Head)

+ func (b *BulletproofTxManager) Start() (merr error)

+ func (b *BulletproofTxManager) Trigger(addr common.Address)

+ type Config interface

+ ChainID func() *big.Int

+ EthFinalityDepth func() uint

+ EthGasBumpPercent func() uint16

+ EthGasBumpThreshold func() uint64

+ EthGasBumpTxDepth func() uint16

+ EthGasBumpWei func() *big.Int

+ EthGasLimitDefault func() uint64

+ EthGasLimitMultiplier func() float32

+ EthGasPriceDefault func() *big.Int

+ EthMaxGasPriceWei func() *big.Int

+ EthMaxInFlightTransactions func() uint32

+ EthMaxQueuedTransactions func() uint64

+ EthNonceAutoSync func() bool

+ EthRPCDefaultBatchSize func() uint32

+ EthTxReaperInterval func() time.Duration

+ EthTxReaperThreshold func() time.Duration

+ EthTxResendAfterThreshold func() time.Duration

+ OptimismGasFees func() bool

+ TriggerFallbackDBPollInterval func() time.Duration

type EthConfirmer

+ func (ec *EthConfirmer) CheckForReceipts(ctx context.Context, blockNum int64) error

+ func (ec *EthConfirmer) Close() error

+ func (ec *EthConfirmer) EnsureConfirmedTransactionsInLongestChain(ctx context.Context, head models.Head) error

+ func (ec *EthConfirmer) ForceRebroadcast(beginningNonce uint, endingNonce uint, gasPriceWei uint64, ...) error

+ func (ec *EthConfirmer) ProcessHead(ctx context.Context, head models.Head) error

+ func (ec *EthConfirmer) RebroadcastWhereNecessary(ctx context.Context, blockHeight int64) error

+ func (ec *EthConfirmer) SetBroadcastBeforeBlockNum(blockNum int64) error

+ func (ec *EthConfirmer) Start() error

+ type KeyStore interface

+ AllKeys func() (keys []ethkey.Key, err error)

+ SignTx func(fromAddress common.Address, tx *gethTypes.Transaction, chainID *big.Int) (*gethTypes.Transaction, error)

+ SubscribeToKeyChanges func() (ch chan struct{}, unsub func())

+ type NullTxManager struct

+ ErrMsg string

+ func (n *NullTxManager) Close() error

+ func (n *NullTxManager) Connect(*models.Head) error

+ func (n *NullTxManager) CreateEthTransaction(*gorm.DB, common.Address, common.Address, []byte, uint64, interface{}) (etx models.EthTx, err error)

+ func (n *NullTxManager) Healthy() error

+ func (n *NullTxManager) OnNewLongestChain(context.Context, models.Head)

+ func (n *NullTxManager) Ready() error

+ func (n *NullTxManager) Start() error

+ func (n *NullTxManager) Trigger(common.Address)

type Reaper

+ func (r *Reaper) ReapJobRuns() error

+ type TxManager interface

+ CreateEthTransaction func(db *gorm.DB, fromAddress, toAddress common.Address, payload []byte, ...) (etx models.EthTx, err error)

+ Trigger func(addr common.Address)

May 24, 2021

Changes in this version

+ type Reaper struct

+ func NewReaper(db *gorm.DB, config ReaperConfig) *Reaper

+ func (r *Reaper) ReapEthTxes(headNum int64) error

+ func (r *Reaper) SetLatestBlockNum(latestBlockNum int64)

+ func (r *Reaper) Start()

+ func (r *Reaper) Stop()

+ type ReaperConfig interface

+ EthFinalityDepth func() uint

+ EthTxReaperInterval func() time.Duration

+ EthTxReaperThreshold func() time.Duration

Apr 12, 2021

Changes in this version

+ func FindEthTxesRequiringResend(db *gorm.DB, olderThan time.Time) (attempts []models.EthTxAttempt, err error)

+ type EthResender struct

+ func NewEthResender(db *gorm.DB, ethClient eth.Client, ...) *EthResender

+ func (er *EthResender) Start()

+ func (er *EthResender) Stop()

+ type NSinserttx struct

+ Attempt models.EthTxAttempt

+ Etx models.EthTx

+ type NonceSyncer struct

+ func NewNonceSyncer(store *store.Store, config orm.ConfigReader, ethClient eth.Client) *NonceSyncer

+ func (s NonceSyncer) MakeInsert(tx types.Transaction, acct accounts.Account, blockNum, nonce int64) (ins NSinserttx, err error)

+ func (s NonceSyncer) MakeZeroInsert(acct accounts.Account, blockNum, nonce int64) (ins NSinserttx, err error)

+ func (s NonceSyncer) SyncAll(ctx context.Context) (merr error)

Mar 22, 2021

Changes in this version

type EthBroadcaster

+ Close func() error

Feb 24, 2021

Changes in this version

+ func FindEthTxsRequiringGasBump(db *gorm.DB, address gethCommon.Address, ...) (etxs []models.EthTx, err error)

+ func FindEthTxsRequiringRebroadcast(db *gorm.DB, address gethCommon.Address, ...) (etxs []models.EthTx, err error)

+ func FindEthTxsRequiringResubmissionDueToInsufficientEth(db *gorm.DB, address gethCommon.Address) (etxs []models.EthTx, err error)

+ type Log struct

+ Address common.Address

+ BlockHash common.Hash

+ BlockNumber uint64

+ Data []byte

+ Index uint

+ Removed bool

+ Topics []common.Hash

+ TxHash common.Hash

+ TxIndex uint

+ func FromGethLog(gl *gethTypes.Log) *Log

+ func (l *Log) UnmarshalJSON(input []byte) error

+ func (l Log) MarshalJSON() ([]byte, error)

+ type Receipt struct

+ BlockHash common.Hash

+ BlockNumber *big.Int

+ Bloom gethTypes.Bloom

+ ContractAddress common.Address

+ CumulativeGasUsed uint64

+ GasUsed uint64

+ Logs []*Log

+ PostState []byte

+ Status uint64

+ TransactionIndex uint

+ TxHash common.Hash

+ func FromGethReceipt(gr *gethTypes.Receipt) *Receipt

+ func (r *Receipt) UnmarshalJSON(input []byte) error

+ func (r Receipt) IsUnmined() bool

+ func (r Receipt) IsZero() bool

+ func (r Receipt) MarshalJSON() ([]byte, error)

Oct 12, 2020

Changes in this version

+ var ErrCouldNotGetReceipt = "could not get receipt"

Jun 29, 2020

Changes in this version

+ func SendEther(s *strpkg.Store, from, to gethCommon.Address, value assets.Eth) (models.EthTx, error)

Jun 15, 2020

Changes in this version

+ var ErrExternalWalletUsedNonce = "external wallet used nonce"

+ func BumpGas(config orm.ConfigReader, originalGasPrice *big.Int) *big.Int

+ func FatalSendError(e error) *sendError

+ func FindEthTxsRequiringNewAttempt(db *gorm.DB, blockNum int64, gasBumpThreshold int64) ([]models.EthTx, error)

+ func GetNextNonce(db *gorm.DB, address gethCommon.Address) (int64, error)

+ func IncrementNextNonce(db *gorm.DB, address gethCommon.Address, currentNonce int64) error

+ func NewEthConfirmer(store *store.Store, config orm.ConfigReader) *ethConfirmer

+ func NewFatalSendError(s string) *sendError

+ func NewSendError(s string) *sendError

+ func SendError(e error) *sendError

+ type EthBroadcaster interface

+ ProcessUnstartedEthTxs func(models.Key) error

+ Start func() error

+ Stop func() error

+ Trigger func()

+ func NewEthBroadcaster(store *store.Store, config orm.ConfigReader) EthBroadcaster

+ type EthConfirmer interface