chunker

Documentation

Index

• type Chunker
• type LogChunker
  • func NewLogChunker() *LogChunker
  • func (chunker *LogChunker) AddConfig(transformerConfig transformer.EventTransformerConfig)
  • func (chunker *LogChunker) ChunkLogs(logs []core.HeaderSyncLog) map[string][]core.HeaderSyncLog

Types

type Chunker

type Chunker interface {
	AddConfig(transformerConfig transformer.EventTransformerConfig)
	ChunkLogs(logs []core.HeaderSyncLog) map[string][]core.HeaderSyncLog
}

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) AddConfig

func (chunker *LogChunker) AddConfig(transformerConfig transformer.EventTransformerConfig)

Configures the chunker by adding one config with more addresses and topics to consider.

func (*LogChunker) ChunkLogs

func (chunker *LogChunker) ChunkLogs(logs []core.HeaderSyncLog) map[string][]core.HeaderSyncLog

Goes through a slice of logs, associating relevant logs (matching addresses and topic) with transformers