listen

Documentation

Index

• func ProcessBlock(ctx context.Context, client *ethclient.Client, number *big.Int, ...) bool
• func SubscribeHead(ctx context.Context, client *ethclient.Client, lastSeenBlock uint64, ...)
• type CaughtTx
• type CaughtTxs

Functions

func ProcessBlock

func ProcessBlock(ctx context.Context, client *ethclient.Client, number *big.Int, commChan chan<- CaughtTxs, lastSeenBlockChan chan<- uint64) bool

ProcessBlock - Fetches all txs present in mined block & passes those to pending pool pruning worker

func SubscribeHead

func SubscribeHead(ctx context.Context, client *ethclient.Client, lastSeenBlock uint64, commChan chan<- CaughtTxs, lastSeenBlockChan chan<- uint64, healthChan chan struct{})

SubscribeHead - Subscribe to block headers & as soon as new block gets mined its txs are picked up & published on a go channel, which will be listened to by pending pool watcher, so that it can prune its state

Types

type CaughtTx

type CaughtTx struct {
	Hash  common.Hash
	Nonce uint64
}

CaughtTx - Tx caught by block head subscriber, passed to pending pool watcher, so that it can prune its state

type CaughtTxs

type CaughtTxs []*CaughtTx

CaughtTxs - Just a slice of txs, which we found to be present in a recently mined block