worker

Documentation

Index

• type BatchFetchResult
• type BlockFetchResult
• type LogsFetchResult
• type RawBlock
• type RawLogs
• type RawTraces
• type TracesFetchResult
• type Worker
  • func NewWorker(rpc common.RPC) *Worker
  • func (w *Worker) Run(blockNumbers []*big.Int) []WorkerResult
• type WorkerResult
  • func SerializeWorkerResults(chainId *big.Int, blocks []BatchFetchResult[RawBlock], ...) []WorkerResult

Types

type BatchFetchResult

type BatchFetchResult[T any] struct {
	BlockNumber *big.Int
	Error       error
	Result      T
}

type BlockFetchResult

type BlockFetchResult struct {
	BlockNumber  *big.Int
	Error        error
	Block        common.Block
	Transactions []common.Transaction
}

type LogsFetchResult

type LogsFetchResult struct {
	BlockNumber *big.Int
	Error       error
	Logs        []common.Log
}

type RawBlock

type RawBlock = map[string]interface{}

type RawLogs

type RawLogs = []map[string]interface{}

type RawTraces

type RawTraces = []map[string]interface{}

type TracesFetchResult

type TracesFetchResult struct {
	BlockNumber *big.Int
	Error       error
	Traces      []common.Trace
}

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(rpc common.RPC) *Worker

func (*Worker) Run

func (w *Worker) Run(blockNumbers []*big.Int) []WorkerResult

type WorkerResult

type WorkerResult struct {
	BlockNumber  *big.Int
	Error        error
	Block        common.Block
	Transactions []common.Transaction
	Logs         []common.Log
	Traces       []common.Trace
}

func SerializeWorkerResults

func SerializeWorkerResults(chainId *big.Int, blocks []BatchFetchResult[RawBlock], logs []BatchFetchResult[RawLogs], traces []BatchFetchResult[RawTraces]) []WorkerResult