event

Documentation

Index

• type EventRecorder
  • func NewEventRecorderSingle(eventStorage storage.EventStorageConsumer, ...) EventRecorder
• type RecorderSingle
  • func (e *RecorderSingle) FlushEvents(bulkSize int64) error
  • func (e *RecorderSingle) SynchronizeEvents(bulkSize int64) error

Types

type EventRecorder

type EventRecorder interface {
	SynchronizeEvents(bulkSize int64) error
	FlushEvents(bulkSize int64) error
}

EventRecorder interface

func NewEventRecorderSingle

func NewEventRecorderSingle(
	eventStorage storage.EventStorageConsumer,
	eventRecorder service.EventsRecorder,
	logger logging.LoggerInterface,
	metadata dtos.Metadata,
	runtimeTelemetry storage.TelemetryRuntimeProducer,
) EventRecorder

NewEventRecorderSingle creates new event synchronizer for posting events

type RecorderSingle

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

RecorderSingle struct for event sync

func (*RecorderSingle) FlushEvents

func (e *RecorderSingle) FlushEvents(bulkSize int64) error

FlushEvents flushes events

func (*RecorderSingle) SynchronizeEvents

func (e *RecorderSingle) SynchronizeEvents(bulkSize int64) error

SynchronizeEvents syncs events