Versions in this module Expand all Collapse all v0 v0.8.0 Mar 30, 2021 Changes in this version + const ACCEPT + const FULL + const REMOVE + const SKIP + type Batcher struct + func NewStatefulBatcher(ctx context.Context, db *txdb.TxDB, chainId *big.Int, ...) (*Batcher, error) + func NewStatelessBatcher(ctx context.Context, db *txdb.TxDB, chainId *big.Int, ...) *Batcher + func (m *Batcher) PendingSnapshot() (*snapshot.Snapshot, error) + func (m *Batcher) PendingTransactionCount(_ context.Context, account common.Address) *uint64 + func (m *Batcher) SendTransaction(_ context.Context, tx *types.Transaction) error + func (m *Batcher) SubscribeNewTxsEvent(ch chan<- core.NewTxsEvent) event.Subscription + type Forwarder struct + func NewForwarder(client *ethclient.Client) *Forwarder + func (b *Forwarder) PendingSnapshot() (*snapshot.Snapshot, error) + func (b *Forwarder) PendingTransactionCount(ctx context.Context, account common.Address) *uint64 + func (b *Forwarder) SendTransaction(ctx context.Context, tx *types.Transaction) error + func (b *Forwarder) SubscribeNewTxsEvent(ch chan<- core.NewTxsEvent) event.Subscription + type TransactionBatcher interface + PendingSnapshot func() (*snapshot.Snapshot, error) + PendingTransactionCount func(ctx context.Context, account common.Address) *uint64 + SendTransaction func(ctx context.Context, tx *types.Transaction) error + SubscribeNewTxsEvent func(ch chan<- core.NewTxsEvent) event.Subscription + type TxHeap []*types.Transaction + func (h *TxHeap) Pop() interface{} + func (h *TxHeap) Push(x interface{}) + func (h TxHeap) Len() int + func (h TxHeap) Less(i, j int) bool + func (h TxHeap) Swap(i, j int)
Go to main page