blockswithtx

Documentation

Overview

Get blocks with receipts from a geth node, as fast as possible (concurrent)

Index

• func GetBlocksWithTxReceipts(client *ethclient.Client, blockChan chan<- *BlockWithTxReceipts, ...)
• type BlockWithTxReceipts
  • func GetBlockWithTxReceipts(client *ethclient.Client, height int64) (res *BlockWithTxReceipts, err error)

Functions

func GetBlocksWithTxReceipts

func GetBlocksWithTxReceipts(client *ethclient.Client, blockChan chan<- *BlockWithTxReceipts, startBlock int64, endBlock int64, concurrency int)

GetBlocksWithTxReceipts downloads a range of blocks with tx receipts, and sends each to a channel once it is ready. Uses concurrency parallel connections to get data from the eth node fast. 5 seems a good number for a direct IPC connection.

Types

type BlockWithTxReceipts

type BlockWithTxReceipts struct {
	Block      *types.Block
	TxReceipts map[common.Hash]*types.Receipt
}

BlockWithTxReceipts contains a single block and receipts for all its transactions (eth does not guarantee that every tx has a receipt)

func GetBlockWithTxReceipts

func GetBlockWithTxReceipts(client *ethclient.Client, height int64) (res *BlockWithTxReceipts, err error)

GetBlockWithTxReceipts returns a single block with receipts for all transactions