mocks

package
v2.1.1-beta0 Latest Latest
Warning

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

 Go to latest Published: May 19, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FeeEstimator 

type FeeEstimator[H types.Head, F types.Fee, MAXPRICE interface{}, TX_HASH commontypes.Hashable] struct {
	mock.Mock
}

FeeEstimator is an autogenerated mock type for the FeeEstimator type

func NewFeeEstimator 

func NewFeeEstimator[H types.Head, F types.Fee, MAXPRICE interface{}, TX_HASH commontypes.Hashable](t mockConstructorTestingTNewFeeEstimator) *FeeEstimator[H, F, MAXPRICE, TX_HASH]

NewFeeEstimator creates a new instance of FeeEstimator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*FeeEstimator[H, F, MAXPRICE, TX_HASH]) BumpFee 

func (_m *FeeEstimator[H, F, MAXPRICE, TX_HASH]) BumpFee(ctx context.Context, originalFee F, feeLimit uint32, maxFeePrice MAXPRICE, attempts []types.PriorAttempt[F, TX_HASH]) (F, uint32, error)

BumpFee provides a mock function with given fields: ctx, originalFee, feeLimit, maxFeePrice, attempts

func (*FeeEstimator[H, F, MAXPRICE, TX_HASH]) Close 

func (_m *FeeEstimator[H, F, MAXPRICE, TX_HASH]) Close() error

Close provides a mock function with given fields:

func (*FeeEstimator[H, F, MAXPRICE, TX_HASH]) GetFee 

func (_m *FeeEstimator[H, F, MAXPRICE, TX_HASH]) GetFee(ctx context.Context, calldata []byte, feeLimit uint32, maxFeePrice MAXPRICE, opts ...types.Opt) (F, uint32, error)

GetFee provides a mock function with given fields: ctx, calldata, feeLimit, maxFeePrice, opts

func (*FeeEstimator[H, F, MAXPRICE, TX_HASH]) HealthReport 

func (_m *FeeEstimator[H, F, MAXPRICE, TX_HASH]) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*FeeEstimator[H, F, MAXPRICE, TX_HASH]) Name 

func (_m *FeeEstimator[H, F, MAXPRICE, TX_HASH]) Name() string

Name provides a mock function with given fields:

func (*FeeEstimator[H, F, MAXPRICE, TX_HASH]) OnNewLongestChain 

func (_m *FeeEstimator[H, F, MAXPRICE, TX_HASH]) OnNewLongestChain(ctx context.Context, head H)

OnNewLongestChain provides a mock function with given fields: ctx, head

func (*FeeEstimator[H, F, MAXPRICE, TX_HASH]) Ready 

func (_m *FeeEstimator[H, F, MAXPRICE, TX_HASH]) Ready() error

Ready provides a mock function with given fields:

func (*FeeEstimator[H, F, MAXPRICE, TX_HASH]) Start 

func (_m *FeeEstimator[H, F, MAXPRICE, TX_HASH]) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

type ForwarderManager added in v2.1.0 

type ForwarderManager[ADDR types.Hashable] struct {
	mock.Mock
}

ForwarderManager is an autogenerated mock type for the ForwarderManager type

func NewForwarderManager added in v2.1.0 

func NewForwarderManager[ADDR types.Hashable](t mockConstructorTestingTNewForwarderManager) *ForwarderManager[ADDR]

NewForwarderManager creates a new instance of ForwarderManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ForwarderManager[ADDR]) Close added in v2.1.0 

func (_m *ForwarderManager[ADDR]) Close() error

Close provides a mock function with given fields:

func (*ForwarderManager[ADDR]) ConvertPayload added in v2.1.0 

func (_m *ForwarderManager[ADDR]) ConvertPayload(dest ADDR, origPayload []byte) ([]byte, error)

ConvertPayload provides a mock function with given fields: dest, origPayload

func (*ForwarderManager[ADDR]) ForwarderFor added in v2.1.0 

func (_m *ForwarderManager[ADDR]) ForwarderFor(addr ADDR) (ADDR, error)

ForwarderFor provides a mock function with given fields: addr

func (*ForwarderManager[ADDR]) HealthReport added in v2.1.0 

func (_m *ForwarderManager[ADDR]) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*ForwarderManager[ADDR]) Name added in v2.1.0 

func (_m *ForwarderManager[ADDR]) Name() string

Name provides a mock function with given fields:

func (*ForwarderManager[ADDR]) Ready added in v2.1.0 

func (_m *ForwarderManager[ADDR]) Ready() error

Ready provides a mock function with given fields:

func (*ForwarderManager[ADDR]) Start added in v2.1.0 

func (_m *ForwarderManager[ADDR]) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0 

type Head struct {
	mock.Mock
}

Head is an autogenerated mock type for the Head type

func NewHead 

func NewHead(t mockConstructorTestingTNewHead) *Head

NewHead creates a new instance of Head. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Head) BlockHash 

func (_m *Head) BlockHash() common.Hash

BlockHash provides a mock function with given fields:

func (*Head) BlockNumber 

func (_m *Head) BlockNumber() int64

BlockNumber provides a mock function with given fields:

func (*Head) ChainLength 

func (_m *Head) ChainLength() uint32

ChainLength provides a mock function with given fields:

func (*Head) EarliestHeadInChain 

func (_m *Head) EarliestHeadInChain() types.Head

EarliestHeadInChain provides a mock function with given fields:

func (*Head) GetParent 

func (_m *Head) GetParent() types.Head

GetParent provides a mock function with given fields:

func (*Head) HashAtHeight 

func (_m *Head) HashAtHeight(blockNum int64) common.Hash

HashAtHeight provides a mock function with given fields: blockNum

type HeadTrackable 

type HeadTrackable[H types.Head] struct {
	mock.Mock
}

HeadTrackable is an autogenerated mock type for the HeadTrackable type

func NewHeadTrackable 

func NewHeadTrackable[H types.Head](t mockConstructorTestingTNewHeadTrackable) *HeadTrackable[H]

NewHeadTrackable creates a new instance of HeadTrackable. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*HeadTrackable[H]) OnNewLongestChain 

func (_m *HeadTrackable[H]) OnNewLongestChain(ctx context.Context, head H)

OnNewLongestChain provides a mock function with given fields: ctx, head

type KeyStore added in v2.1.0 

type KeyStore[ADDR types.Hashable, CHAIN_ID txmgrtypes.ID, SEQ txmgrtypes.Sequence] struct {
	mock.Mock
}

KeyStore is an autogenerated mock type for the KeyStore type

func NewKeyStore added in v2.1.0 

func NewKeyStore[ADDR types.Hashable, CHAIN_ID txmgrtypes.ID, SEQ txmgrtypes.Sequence](t mockConstructorTestingTNewKeyStore) *KeyStore[ADDR, CHAIN_ID, SEQ]

NewKeyStore creates a new instance of KeyStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*KeyStore[ADDR, CHAIN_ID, SEQ]) CheckEnabled added in v2.1.0 

func (_m *KeyStore[ADDR, CHAIN_ID, SEQ]) CheckEnabled(address ADDR, chainID CHAIN_ID) error

CheckEnabled provides a mock function with given fields: address, chainID

func (*KeyStore[ADDR, CHAIN_ID, SEQ]) EnabledAddressesForChain added in v2.1.0 

func (_m *KeyStore[ADDR, CHAIN_ID, SEQ]) EnabledAddressesForChain(chainId CHAIN_ID) ([]ADDR, error)

EnabledAddressesForChain provides a mock function with given fields: chainId

func (*KeyStore[ADDR, CHAIN_ID, SEQ]) IncrementNextSequence added in v2.1.0 

func (_m *KeyStore[ADDR, CHAIN_ID, SEQ]) IncrementNextSequence(address ADDR, chainID CHAIN_ID, currentSequence SEQ, qopts ...pg.QOpt) error

IncrementNextSequence provides a mock function with given fields: address, chainID, currentSequence, qopts

func (*KeyStore[ADDR, CHAIN_ID, SEQ]) NextSequence added in v2.1.0 

func (_m *KeyStore[ADDR, CHAIN_ID, SEQ]) NextSequence(address ADDR, chainID CHAIN_ID, qopts ...pg.QOpt) (SEQ, error)

NextSequence provides a mock function with given fields: address, chainID, qopts

func (*KeyStore[ADDR, CHAIN_ID, SEQ]) SubscribeToKeyChanges added in v2.1.0 

func (_m *KeyStore[ADDR, CHAIN_ID, SEQ]) SubscribeToKeyChanges() (chan struct{}, func())

SubscribeToKeyChanges provides a mock function with given fields:

type PriorAttempt added in v2.1.0 

type PriorAttempt[F types.Fee, TX_HASH commontypes.Hashable] struct {
	mock.Mock
}

PriorAttempt is an autogenerated mock type for the PriorAttempt type

func NewPriorAttempt added in v2.1.0 

func NewPriorAttempt[F types.Fee, TX_HASH commontypes.Hashable](t mockConstructorTestingTNewPriorAttempt) *PriorAttempt[F, TX_HASH]

NewPriorAttempt creates a new instance of PriorAttempt. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*PriorAttempt[F, TX_HASH]) Fee added in v2.1.0 

func (_m *PriorAttempt[F, TX_HASH]) Fee() F

Fee provides a mock function with given fields:

func (*PriorAttempt[F, TX_HASH]) GetBroadcastBeforeBlockNum added in v2.1.0 

func (_m *PriorAttempt[F, TX_HASH]) GetBroadcastBeforeBlockNum() *int64

GetBroadcastBeforeBlockNum provides a mock function with given fields:

func (*PriorAttempt[F, TX_HASH]) GetChainSpecificGasLimit added in v2.1.0 

func (_m *PriorAttempt[F, TX_HASH]) GetChainSpecificGasLimit() uint32

GetChainSpecificGasLimit provides a mock function with given fields:

func (*PriorAttempt[F, TX_HASH]) GetHash added in v2.1.0 

func (_m *PriorAttempt[F, TX_HASH]) GetHash() TX_HASH

GetHash provides a mock function with given fields:

func (*PriorAttempt[F, TX_HASH]) GetTxType added in v2.1.0 

func (_m *PriorAttempt[F, TX_HASH]) GetTxType() int

GetTxType provides a mock function with given fields:

type ReaperConfig added in v2.1.0 

type ReaperConfig struct {
	mock.Mock
}

ReaperConfig is an autogenerated mock type for the ReaperConfig type

func NewReaperConfig added in v2.1.0 

func NewReaperConfig(t mockConstructorTestingTNewReaperConfig) *ReaperConfig

NewReaperConfig creates a new instance of ReaperConfig. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ReaperConfig) FinalityDepth added in v2.1.0 

func (_m *ReaperConfig) FinalityDepth() uint32

FinalityDepth provides a mock function with given fields:

func (*ReaperConfig) TxReaperInterval added in v2.1.0 

func (_m *ReaperConfig) TxReaperInterval() time.Duration

TxReaperInterval provides a mock function with given fields:

func (*ReaperConfig) TxReaperThreshold added in v2.1.0 

func (_m *ReaperConfig) TxReaperThreshold() time.Duration

TxReaperThreshold provides a mock function with given fields:

type TxAttemptBuilder 

type TxAttemptBuilder[HEAD types.Head, FEE types.Fee, ADDR commontypes.Hashable, TX_HASH commontypes.Hashable, TX interface{}, TXATTEMPT interface{}, SEQ types.Sequence] struct {
	mock.Mock
}

TxAttemptBuilder is an autogenerated mock type for the TxAttemptBuilder type

func NewTxAttemptBuilder 

func NewTxAttemptBuilder[HEAD types.Head, FEE types.Fee, ADDR commontypes.Hashable, TX_HASH commontypes.Hashable, TX interface{}, TXATTEMPT interface{}, SEQ types.Sequence](t mockConstructorTestingTNewTxAttemptBuilder) *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]

NewTxAttemptBuilder creates a new instance of TxAttemptBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) Close 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) Close() error

Close provides a mock function with given fields:

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) HealthReport 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) Name 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) Name() string

Name provides a mock function with given fields:

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewBumpTxAttempt 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewBumpTxAttempt(ctx context.Context, tx TX, previousAttempt TXATTEMPT, priorAttempts []types.PriorAttempt[FEE, TX_HASH], lggr logger.Logger) (TXATTEMPT, FEE, uint32, bool, error)

NewBumpTxAttempt provides a mock function with given fields: ctx, tx, previousAttempt, priorAttempts, lggr

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewCustomTxAttempt 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewCustomTxAttempt(tx TX, fee FEE, gasLimit uint32, txType int, lggr logger.Logger) (TXATTEMPT, bool, error)

NewCustomTxAttempt provides a mock function with given fields: tx, fee, gasLimit, txType, lggr

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewEmptyTxAttempt 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewEmptyTxAttempt(seq SEQ, feeLimit uint32, fee FEE, fromAddress ADDR) (TXATTEMPT, error)

NewEmptyTxAttempt provides a mock function with given fields: seq, feeLimit, fee, fromAddress

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewTxAttempt 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewTxAttempt(ctx context.Context, tx TX, lggr logger.Logger, opts ...types.Opt) (TXATTEMPT, FEE, uint32, bool, error)

NewTxAttempt provides a mock function with given fields: ctx, tx, lggr, opts

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewTxAttemptWithType 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) NewTxAttemptWithType(ctx context.Context, tx TX, lggr logger.Logger, txType int, opts ...types.Opt) (TXATTEMPT, FEE, uint32, bool, error)

NewTxAttemptWithType provides a mock function with given fields: ctx, tx, lggr, txType, opts

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) OnNewLongestChain 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) OnNewLongestChain(ctx context.Context, head HEAD)

OnNewLongestChain provides a mock function with given fields: ctx, head

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) Ready 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) Ready() error

Ready provides a mock function with given fields:

func (*TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) Start 

func (_m *TxAttemptBuilder[HEAD, FEE, ADDR, TX_HASH, TX, TXATTEMPT, SEQ]) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

type TxStore added in v2.1.0 

type TxStore[ADDR types.Hashable, CHAIN_ID txmgrtypes.ID, TX_HASH types.Hashable, BLOCK_HASH types.Hashable, NEWTX interface{}, R interface{}, TX interface{}, TXATTEMPT interface{}, SEQ txmgrtypes.Sequence] struct {
	mock.Mock
}

TxStore is an autogenerated mock type for the TxStore type

func NewTxStore added in v2.1.0 

func NewTxStore[ADDR types.Hashable, CHAIN_ID txmgrtypes.ID, TX_HASH types.Hashable, BLOCK_HASH types.Hashable, NEWTX interface{}, R interface{}, TX interface{}, TXATTEMPT interface{}, SEQ txmgrtypes.Sequence](t mockConstructorTestingTNewTxStore) *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]

NewTxStore creates a new instance of TxStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) CheckEthTxQueueCapacity added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) CheckEthTxQueueCapacity(fromAddress ADDR, maxQueuedTransactions uint64, chainID CHAIN_ID, qopts ...pg.QOpt) error

CheckEthTxQueueCapacity provides a mock function with given fields: fromAddress, maxQueuedTransactions, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) Close added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) Close()

Close provides a mock function with given fields:

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) CountUnconfirmedTransactions added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) CountUnconfirmedTransactions(fromAddress ADDR, chainID CHAIN_ID, qopts ...pg.QOpt) (uint32, error)

CountUnconfirmedTransactions provides a mock function with given fields: fromAddress, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) CountUnstartedTransactions added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) CountUnstartedTransactions(fromAddress ADDR, chainID CHAIN_ID, qopts ...pg.QOpt) (uint32, error)

CountUnstartedTransactions provides a mock function with given fields: fromAddress, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) CreateEthTransaction added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) CreateEthTransaction(newTx NEWTX, chainID CHAIN_ID, qopts ...pg.QOpt) (txmgrtypes.Transaction, error)

CreateEthTransaction provides a mock function with given fields: newTx, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) DeleteInProgressAttempt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) DeleteInProgressAttempt(ctx context.Context, attempt TXATTEMPT) error

DeleteInProgressAttempt provides a mock function with given fields: ctx, attempt

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) EthTransactions added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) EthTransactions(offset int, limit int) ([]TX, int, error)

EthTransactions provides a mock function with given fields: offset, limit

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) EthTransactionsWithAttempts added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) EthTransactionsWithAttempts(offset int, limit int) ([]TX, int, error)

EthTransactionsWithAttempts provides a mock function with given fields: offset, limit

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) EthTxAttempts added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) EthTxAttempts(offset int, limit int) ([]TXATTEMPT, int, error)

EthTxAttempts provides a mock function with given fields: offset, limit

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthReceiptsPendingConfirmation added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthReceiptsPendingConfirmation(ctx context.Context, blockNum int64, chainID CHAIN_ID) ([]txmgrtypes.ReceiptPlus[R], error)

FindEthReceiptsPendingConfirmation provides a mock function with given fields: ctx, blockNum, chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttempt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttempt(hash TX_HASH) (*TXATTEMPT, error)

FindEthTxAttempt provides a mock function with given fields: hash

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttemptConfirmedByEthTxIDs added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttemptConfirmedByEthTxIDs(ids []int64) ([]TXATTEMPT, error)

FindEthTxAttemptConfirmedByEthTxIDs provides a mock function with given fields: ids

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttemptsByEthTxIDs added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttemptsByEthTxIDs(ids []int64) ([]TXATTEMPT, error)

FindEthTxAttemptsByEthTxIDs provides a mock function with given fields: ids

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttemptsRequiringReceiptFetch added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttemptsRequiringReceiptFetch(chainID CHAIN_ID) ([]TXATTEMPT, error)

FindEthTxAttemptsRequiringReceiptFetch provides a mock function with given fields: chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttemptsRequiringResend added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxAttemptsRequiringResend(olderThan time.Time, maxInFlightTransactions uint32, chainID CHAIN_ID, address ADDR) ([]TXATTEMPT, error)

FindEthTxAttemptsRequiringResend provides a mock function with given fields: olderThan, maxInFlightTransactions, chainID, address

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxByHash added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxByHash(hash TX_HASH) (*TX, error)

FindEthTxByHash provides a mock function with given fields: hash

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxWithAttempts added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxWithAttempts(etxID int64) (TX, error)

FindEthTxWithAttempts provides a mock function with given fields: etxID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxWithNonce added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxWithNonce(fromAddress ADDR, seq SEQ) (*TX, error)

FindEthTxWithNonce provides a mock function with given fields: fromAddress, seq

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxsRequiringGasBump added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxsRequiringGasBump(ctx context.Context, address ADDR, blockNum int64, gasBumpThreshold int64, depth int64, chainID CHAIN_ID) ([]*TX, error)

FindEthTxsRequiringGasBump provides a mock function with given fields: ctx, address, blockNum, gasBumpThreshold, depth, chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxsRequiringResubmissionDueToInsufficientEth added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEthTxsRequiringResubmissionDueToInsufficientEth(address ADDR, chainID CHAIN_ID, qopts ...pg.QOpt) ([]*TX, error)

FindEthTxsRequiringResubmissionDueToInsufficientEth provides a mock function with given fields: address, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEtxAttemptsConfirmedMissingReceipt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindEtxAttemptsConfirmedMissingReceipt(chainID CHAIN_ID) ([]TXATTEMPT, error)

FindEtxAttemptsConfirmedMissingReceipt provides a mock function with given fields: chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindNextUnstartedTransactionFromAddress added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindNextUnstartedTransactionFromAddress(etx *TX, fromAddress ADDR, chainID CHAIN_ID, qopts ...pg.QOpt) error

FindNextUnstartedTransactionFromAddress provides a mock function with given fields: etx, fromAddress, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindTransactionsConfirmedInBlockRange added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) FindTransactionsConfirmedInBlockRange(highBlockNumber int64, lowBlockNumber int64, chainID CHAIN_ID) ([]*TX, error)

FindTransactionsConfirmedInBlockRange provides a mock function with given fields: highBlockNumber, lowBlockNumber, chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) GetEthTxInProgress added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) GetEthTxInProgress(fromAddress ADDR, qopts ...pg.QOpt) (*TX, error)

GetEthTxInProgress provides a mock function with given fields: fromAddress, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) GetInProgressEthTxAttempts added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) GetInProgressEthTxAttempts(ctx context.Context, address ADDR, chainID CHAIN_ID) ([]TXATTEMPT, error)

GetInProgressEthTxAttempts provides a mock function with given fields: ctx, address, chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) HasInProgressTransaction added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) HasInProgressTransaction(account ADDR, chainID CHAIN_ID, qopts ...pg.QOpt) (bool, error)

HasInProgressTransaction provides a mock function with given fields: account, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) InsertEthReceipt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) InsertEthReceipt(receipt *txmgrtypes.Receipt[R, TX_HASH, BLOCK_HASH]) error

InsertEthReceipt provides a mock function with given fields: receipt

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) InsertEthTx added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) InsertEthTx(etx *TX) error

InsertEthTx provides a mock function with given fields: etx

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) InsertEthTxAttempt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) InsertEthTxAttempt(attempt *TXATTEMPT) error

InsertEthTxAttempt provides a mock function with given fields: attempt

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) LoadEthTxAttempts added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) LoadEthTxAttempts(etx *TX, qopts ...pg.QOpt) error

LoadEthTxAttempts provides a mock function with given fields: etx, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) LoadEthTxesAttempts added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) LoadEthTxesAttempts(etxs []*TX, qopts ...pg.QOpt) error

LoadEthTxesAttempts provides a mock function with given fields: etxs, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) MarkAllConfirmedMissingReceipt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) MarkAllConfirmedMissingReceipt(chainID CHAIN_ID) error

MarkAllConfirmedMissingReceipt provides a mock function with given fields: chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) MarkOldTxesMissingReceiptAsErrored added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) MarkOldTxesMissingReceiptAsErrored(blockNum int64, finalityDepth uint32, chainID CHAIN_ID, qopts ...pg.QOpt) error

MarkOldTxesMissingReceiptAsErrored provides a mock function with given fields: blockNum, finalityDepth, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) PreloadEthTxes added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) PreloadEthTxes(attempts []TXATTEMPT, qopts ...pg.QOpt) error

PreloadEthTxes provides a mock function with given fields: attempts, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) PruneUnstartedTxQueue added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) PruneUnstartedTxQueue(queueSize uint32, subject uuid.UUID, qopts ...pg.QOpt) (int64, error)

PruneUnstartedTxQueue provides a mock function with given fields: queueSize, subject, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveConfirmedMissingReceiptAttempt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveConfirmedMissingReceiptAttempt(ctx context.Context, timeout time.Duration, attempt *TXATTEMPT, broadcastAt time.Time) error

SaveConfirmedMissingReceiptAttempt provides a mock function with given fields: ctx, timeout, attempt, broadcastAt

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveFetchedReceipts added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveFetchedReceipts(receipts []R, chainID CHAIN_ID) error

SaveFetchedReceipts provides a mock function with given fields: receipts, chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveInProgressAttempt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveInProgressAttempt(attempt *TXATTEMPT) error

SaveInProgressAttempt provides a mock function with given fields: attempt

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveInsufficientEthAttempt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveInsufficientEthAttempt(timeout time.Duration, attempt *TXATTEMPT, broadcastAt time.Time) error

SaveInsufficientEthAttempt provides a mock function with given fields: timeout, attempt, broadcastAt

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveReplacementInProgressAttempt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveReplacementInProgressAttempt(oldAttempt TXATTEMPT, replacementAttempt *TXATTEMPT, qopts ...pg.QOpt) error

SaveReplacementInProgressAttempt provides a mock function with given fields: oldAttempt, replacementAttempt, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveSentAttempt added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SaveSentAttempt(timeout time.Duration, attempt *TXATTEMPT, broadcastAt time.Time) error

SaveSentAttempt provides a mock function with given fields: timeout, attempt, broadcastAt

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SetBroadcastBeforeBlockNum added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) SetBroadcastBeforeBlockNum(blockNum int64, chainID CHAIN_ID) error

SetBroadcastBeforeBlockNum provides a mock function with given fields: blockNum, chainID

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateBroadcastAts added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateBroadcastAts(now time.Time, etxIDs []int64) error

UpdateBroadcastAts provides a mock function with given fields: now, etxIDs

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthKeyNextNonce added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthKeyNextNonce(newNextNonce SEQ, currentNextNonce SEQ, address ADDR, chainID CHAIN_ID, qopts ...pg.QOpt) error

UpdateEthKeyNextNonce provides a mock function with given fields: newNextNonce, currentNextNonce, address, chainID, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxAttemptInProgressToBroadcast added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxAttemptInProgressToBroadcast(etx *TX, attempt TXATTEMPT, NewAttemptState txmgrtypes.TxAttemptState, incrNextNonceCallback func(pg.Queryer) error, qopts ...pg.QOpt) error

UpdateEthTxAttemptInProgressToBroadcast provides a mock function with given fields: etx, attempt, NewAttemptState, incrNextNonceCallback, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxFatalError added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxFatalError(etx *TX, qopts ...pg.QOpt) error

UpdateEthTxFatalError provides a mock function with given fields: etx, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxForRebroadcast added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxForRebroadcast(etx TX, etxAttempt TXATTEMPT) error

UpdateEthTxForRebroadcast provides a mock function with given fields: etx, etxAttempt

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxUnstartedToInProgress added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxUnstartedToInProgress(etx *TX, attempt *TXATTEMPT, qopts ...pg.QOpt) error

UpdateEthTxUnstartedToInProgress provides a mock function with given fields: etx, attempt, qopts

func (*TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxsUnconfirmed added in v2.1.0 

func (_m *TxStore[ADDR, CHAIN_ID, TX_HASH, BLOCK_HASH, NEWTX, R, TX, TXATTEMPT, SEQ]) UpdateEthTxsUnconfirmed(ids []int64) error

UpdateEthTxsUnconfirmed provides a mock function with given fields: ids

type TxStrategy 

type TxStrategy struct {
	mock.Mock
}

TxStrategy is an autogenerated mock type for the TxStrategy type

func NewTxStrategy 

func NewTxStrategy(t mockConstructorTestingTNewTxStrategy) *TxStrategy

NewTxStrategy creates a new instance of TxStrategy. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*TxStrategy) PruneQueue 

func (_m *TxStrategy) PruneQueue(pruneService types.UnstartedTxQueuePruner, qopt pg.QOpt) (int64, error)

PruneQueue provides a mock function with given fields: pruneService, qopt

func (*TxStrategy) Subject 

func (_m *TxStrategy) Subject() uuid.NullUUID

Subject provides a mock function with given fields:

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.