convert

Documentation

Index

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

Functions

func NewEventConverter

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

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 *armadacontext.Context, eventsWithIds *utils.EventsWithIds[*armadaevents.EventSequence]) *model.BatchUpdate