chunker

Documentation

Index

• type Chunker
• type LogChunker
  • func NewLogChunker() *LogChunker
  • func (chunker *LogChunker) AddConfigs(transformerConfigs []shared_t.EventTransformerConfig)
  • func (chunker *LogChunker) ChunkLogs(logs []types.Log) map[string][]types.Log

Types

type Chunker

type Chunker interface {
	AddConfigs(transformerConfigs []shared_t.EventTransformerConfig)
	ChunkLogs(logs []types.Log) map[string][]types.Log
}

type LogChunker

type LogChunker struct {
	AddressToNames map[string][]string
	NameToTopic0   map[string]common.Hash
}

func NewLogChunker

func NewLogChunker() *LogChunker

Returns a new log chunker with initialised maps. Needs to have configs added with `AddConfigs` to consider logs for the respective transformer.

func (*LogChunker) AddConfigs

func (chunker *LogChunker) AddConfigs(transformerConfigs []shared_t.EventTransformerConfig)

Configures the chunker by adding more addreses and topics to consider.

func (*LogChunker) ChunkLogs

func (chunker *LogChunker) ChunkLogs(logs []types.Log) map[string][]types.Log

Goes through an array of logs, associating relevant logs (matching addresses and topic) with transformers