convert

Documentation

Index

• func NewEventConverter(compressor compress.Compressor, maxMessageBatchSize uint, ...) ingest.InstructionConverter[*model.BatchUpdate]
• type EventConverter
  • func (ec *EventConverter) Convert(ctx context.Context, sequencesWithIds *ingest.EventSequencesWithIds) *model.BatchUpdate

Functions

func NewEventConverter

func NewEventConverter(compressor compress.Compressor, maxMessageBatchSize uint, metrics *metrics.Metrics) ingest.InstructionConverter[*model.BatchUpdate]

Types

type EventConverter

type EventConverter struct {
	Compressor          compress.Compressor
	MaxMessageBatchSize uint
	// contains filtered or unexported fields
}

EventConverter converts event sequences into events that we can store in Redis

func (*EventConverter) Convert

func (ec *EventConverter) Convert(ctx context.Context, sequencesWithIds *ingest.EventSequencesWithIds) *model.BatchUpdate