Documentation
¶
Index ¶
- Constants
- type InMemoryStore
- func (m *InMemoryStore) AbandonPendingTransactions()
- func (m *InMemoryStore) AppendAttemptToTransaction(txNonce uint64, attempt *types.Attempt) error
- func (m *InMemoryStore) CountUnstartedTransactions() int
- func (m *InMemoryStore) CreateEmptyUnconfirmedTransaction(nonce uint64, gasLimit uint64) (*types.Transaction, error)
- func (m *InMemoryStore) CreateTransaction(txRequest *types.TxRequest) *types.Transaction
- func (m *InMemoryStore) DeleteAttemptForUnconfirmedTx(transactionNonce uint64, attempt *types.Attempt) error
- func (m *InMemoryStore) FetchUnconfirmedTransactionAtNonceWithCount(latestNonce uint64) (txCopy *types.Transaction, unconfirmedCount int)
- func (m *InMemoryStore) FindTxWithIdempotencyKey(idempotencyKey string) *types.Transaction
- func (m *InMemoryStore) MarkConfirmedAndReorgedTransactions(latestNonce uint64) ([]*types.Transaction, []uint64, error)
- func (m *InMemoryStore) MarkTxFatal(*types.Transaction) error
- func (m *InMemoryStore) MarkUnconfirmedTransactionPurgeable(nonce uint64) error
- func (m *InMemoryStore) UpdateTransactionBroadcast(txID uint64, txNonce uint64, attemptHash common.Hash) error
- func (m *InMemoryStore) UpdateUnstartedTransactionWithNonce(nonce uint64) (*types.Transaction, error)
- type InMemoryStoreManager
- func (m *InMemoryStoreManager) AbandonPendingTransactions(_ context.Context, fromAddress common.Address) error
- func (m *InMemoryStoreManager) Add(addresses ...common.Address) (err error)
- func (m *InMemoryStoreManager) AppendAttemptToTransaction(_ context.Context, txNonce uint64, fromAddress common.Address, ...) error
- func (m *InMemoryStoreManager) CountUnstartedTransactions(fromAddress common.Address) (int, error)
- func (m *InMemoryStoreManager) CreateEmptyUnconfirmedTransaction(_ context.Context, fromAddress common.Address, nonce uint64, gasLimit uint64) (*types.Transaction, error)
- func (m *InMemoryStoreManager) CreateTransaction(_ context.Context, txRequest *types.TxRequest) (*types.Transaction, error)
- func (m *InMemoryStoreManager) DeleteAttemptForUnconfirmedTx(_ context.Context, nonce uint64, attempt *types.Attempt, ...) error
- func (m *InMemoryStoreManager) FetchUnconfirmedTransactionAtNonceWithCount(_ context.Context, nonce uint64, fromAddress common.Address) (tx *types.Transaction, count int, err error)
- func (m *InMemoryStoreManager) FindTxWithIdempotencyKey(_ context.Context, idempotencyKey string) (*types.Transaction, error)
- func (m *InMemoryStoreManager) MarkConfirmedAndReorgedTransactions(_ context.Context, nonce uint64, fromAddress common.Address) (confirmedTxs []*types.Transaction, unconfirmedTxIDs []uint64, err error)
- func (m *InMemoryStoreManager) MarkTxFatal(_ context.Context, tx *types.Transaction, fromAddress common.Address) error
- func (m *InMemoryStoreManager) MarkUnconfirmedTransactionPurgeable(_ context.Context, nonce uint64, fromAddress common.Address) error
- func (m *InMemoryStoreManager) UpdateTransactionBroadcast(_ context.Context, txID uint64, nonce uint64, attemptHash common.Hash, ...) error
- func (m *InMemoryStoreManager) UpdateUnstartedTransactionWithNonce(_ context.Context, fromAddress common.Address, nonce uint64) (*types.Transaction, error)
Constants ¶
View Source
const StoreNotFoundForAddress string = "InMemoryStore for address: %v not found"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InMemoryStore ¶
type InMemoryStore struct {
sync.RWMutex
UnstartedTransactions []*types.Transaction
UnconfirmedTransactions map[uint64]*types.Transaction
ConfirmedTransactions map[uint64]*types.Transaction
FatalTransactions []*types.Transaction
Transactions map[uint64]*types.Transaction
// contains filtered or unexported fields
}
func NewInMemoryStore ¶
func (*InMemoryStore) AbandonPendingTransactions ¶
func (m *InMemoryStore) AbandonPendingTransactions()
func (*InMemoryStore) AppendAttemptToTransaction ¶
func (m *InMemoryStore) AppendAttemptToTransaction(txNonce uint64, attempt *types.Attempt) error
func (*InMemoryStore) CountUnstartedTransactions ¶
func (m *InMemoryStore) CountUnstartedTransactions() int
func (*InMemoryStore) CreateEmptyUnconfirmedTransaction ¶
func (m *InMemoryStore) CreateEmptyUnconfirmedTransaction(nonce uint64, gasLimit uint64) (*types.Transaction, error)
func (*InMemoryStore) CreateTransaction ¶
func (m *InMemoryStore) CreateTransaction(txRequest *types.TxRequest) *types.Transaction
func (*InMemoryStore) DeleteAttemptForUnconfirmedTx ¶
func (m *InMemoryStore) DeleteAttemptForUnconfirmedTx(transactionNonce uint64, attempt *types.Attempt) error
Error Handler
func (*InMemoryStore) FetchUnconfirmedTransactionAtNonceWithCount ¶
func (m *InMemoryStore) FetchUnconfirmedTransactionAtNonceWithCount(latestNonce uint64) (txCopy *types.Transaction, unconfirmedCount int)
func (*InMemoryStore) FindTxWithIdempotencyKey ¶
func (m *InMemoryStore) FindTxWithIdempotencyKey(idempotencyKey string) *types.Transaction
Orchestrator
func (*InMemoryStore) MarkConfirmedAndReorgedTransactions ¶
func (m *InMemoryStore) MarkConfirmedAndReorgedTransactions(latestNonce uint64) ([]*types.Transaction, []uint64, error)
func (*InMemoryStore) MarkTxFatal ¶
func (m *InMemoryStore) MarkTxFatal(*types.Transaction) error
func (*InMemoryStore) MarkUnconfirmedTransactionPurgeable ¶
func (m *InMemoryStore) MarkUnconfirmedTransactionPurgeable(nonce uint64) error
func (*InMemoryStore) UpdateTransactionBroadcast ¶
func (*InMemoryStore) UpdateUnstartedTransactionWithNonce ¶
func (m *InMemoryStore) UpdateUnstartedTransactionWithNonce(nonce uint64) (*types.Transaction, error)
type InMemoryStoreManager ¶
type InMemoryStoreManager struct {
InMemoryStoreMap map[common.Address]*InMemoryStore
// contains filtered or unexported fields
}
func NewInMemoryStoreManager ¶
func NewInMemoryStoreManager(lggr logger.Logger, chainID *big.Int) *InMemoryStoreManager
func (*InMemoryStoreManager) AbandonPendingTransactions ¶
func (*InMemoryStoreManager) Add ¶
func (m *InMemoryStoreManager) Add(addresses ...common.Address) (err error)
func (*InMemoryStoreManager) AppendAttemptToTransaction ¶
func (*InMemoryStoreManager) CountUnstartedTransactions ¶
func (m *InMemoryStoreManager) CountUnstartedTransactions(fromAddress common.Address) (int, error)
func (*InMemoryStoreManager) CreateEmptyUnconfirmedTransaction ¶
func (m *InMemoryStoreManager) CreateEmptyUnconfirmedTransaction(_ context.Context, fromAddress common.Address, nonce uint64, gasLimit uint64) (*types.Transaction, error)
func (*InMemoryStoreManager) CreateTransaction ¶
func (m *InMemoryStoreManager) CreateTransaction(_ context.Context, txRequest *types.TxRequest) (*types.Transaction, error)
func (*InMemoryStoreManager) DeleteAttemptForUnconfirmedTx ¶
func (*InMemoryStoreManager) FetchUnconfirmedTransactionAtNonceWithCount ¶
func (m *InMemoryStoreManager) FetchUnconfirmedTransactionAtNonceWithCount(_ context.Context, nonce uint64, fromAddress common.Address) (tx *types.Transaction, count int, err error)
func (*InMemoryStoreManager) FindTxWithIdempotencyKey ¶
func (m *InMemoryStoreManager) FindTxWithIdempotencyKey(_ context.Context, idempotencyKey string) (*types.Transaction, error)
func (*InMemoryStoreManager) MarkConfirmedAndReorgedTransactions ¶
func (m *InMemoryStoreManager) MarkConfirmedAndReorgedTransactions(_ context.Context, nonce uint64, fromAddress common.Address) (confirmedTxs []*types.Transaction, unconfirmedTxIDs []uint64, err error)
func (*InMemoryStoreManager) MarkTxFatal ¶
func (m *InMemoryStoreManager) MarkTxFatal(_ context.Context, tx *types.Transaction, fromAddress common.Address) error
func (*InMemoryStoreManager) MarkUnconfirmedTransactionPurgeable ¶
func (*InMemoryStoreManager) UpdateTransactionBroadcast ¶
func (*InMemoryStoreManager) UpdateUnstartedTransactionWithNonce ¶
func (m *InMemoryStoreManager) UpdateUnstartedTransactionWithNonce(_ context.Context, fromAddress common.Address, nonce uint64) (*types.Transaction, error)
Source Files
Click to show internal directories.
Click to hide internal directories.