Versions in this module Expand all Collapse all v0 v0.1.4 Apr 12, 2024 v0.1.3 Apr 5, 2024 Changes in this version + const MonitoredTxStatusConfirmed + const MonitoredTxStatusCreated + const MonitoredTxStatusDone + const MonitoredTxStatusFailed + const MonitoredTxStatusReorged + const MonitoredTxStatusSent + var ErrAlreadyExists = errors.New("already exists") + var ErrExecutionReverted = errors.New("execution reverted") + var ErrNotFound = errors.New("not found") + type EthermanInterface interface + CheckTxWasMined func(ctx context.Context, txHash common.Hash) (bool, *types.Receipt, error) + EstimateGas func(ctx context.Context, from common.Address, to *common.Address, value *big.Int, ...) (uint64, error) + GetRevertMessage func(ctx context.Context, tx *types.Transaction) (string, error) + GetTx func(ctx context.Context, txHash common.Hash) (*types.Transaction, bool, error) + GetTxReceipt func(ctx context.Context, txHash common.Hash) (*types.Receipt, error) + PendingNonce func(ctx context.Context, account common.Address) (uint64, error) + SendTx func(ctx context.Context, tx *types.Transaction) error + SignTx func(ctx context.Context, sender common.Address, tx *types.Transaction) (*types.Transaction, error) + SuggestedGasPrice func(ctx context.Context) (*big.Int, error) + WaitTxToBeMined func(ctx context.Context, tx *types.Transaction, timeout time.Duration) (bool, error) + type MonitoredTx struct + BlockNumber *big.Int + CreatedAt time.Time + Data []byte + From common.Address + Gas uint64 + GasOffset uint64 + GasPrice *big.Int + History map[common.Hash]bool + ID string + Nonce uint64 + NumRetries uint64 + Owner string + Status MonitoredTxStatus + To *common.Address + UpdatedAt time.Time + Value *big.Int + func (mTx *MonitoredTx) AddHistory(tx *types.Transaction) error + func (mTx *MonitoredTx) BlockNumberU64Ptr() *uint64 + func (mTx *MonitoredTx) DataStringPtr() *string + func (mTx *MonitoredTx) HistoryHashSlice() []common.Hash + func (mTx *MonitoredTx) HistoryStringSlice() []string + func (mTx *MonitoredTx) ToStringPtr() *string + func (mTx *MonitoredTx) ValueU64Ptr() *uint64 + func (mTx MonitoredTx) Tx() *types.Transaction + type MonitoredTxResult struct + ID string + Status MonitoredTxStatus + Txs map[common.Hash]TxResult + type MonitoredTxStatus string + func (s MonitoredTxStatus) String() string + type StateInterface interface + GetLastBlock func(ctx context.Context, dbTx pgx.Tx) (*state.Block, error) + type StorageInterface interface + Add func(ctx context.Context, mTx MonitoredTx, dbTx pgx.Tx) error + Get func(ctx context.Context, owner, id string, dbTx pgx.Tx) (MonitoredTx, error) + GetBySenderAndStatus func(ctx context.Context, sender common.Address, statuses []MonitoredTxStatus, ...) ([]MonitoredTx, error) + GetByStatus func(ctx context.Context, owner *string, statuses []MonitoredTxStatus, dbTx pgx.Tx) ([]MonitoredTx, error) + Update func(ctx context.Context, mTx MonitoredTx, dbTx pgx.Tx) error + type TxResult struct + Receipt *types.Receipt + RevertMessage string + Tx *types.Transaction