worker

type ImpressionsCounstWorkerImp ¶ added in v5.2.0

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

func NewImpressionsCounstWorker(
	impressionsCounter strategy.ImpressionsCounter,
	storage storage.ImpressionsCountConsumer,
	logger logging.LoggerInterface,
) ImpressionsCounstWorkerImp

func (i *ImpressionsCounstWorkerImp) Process() error

type TelemetryMultiSyncError ¶

type TelemetryMultiSyncError struct {
	Errors map[dtos.Metadata]error
}

TelemetryMultiSyncError is used to signal errors on multiple calls to telemetry recording apis

func (t *TelemetryMultiSyncError) Error() string

type TelemetryMultiWorker ¶

type TelemetryMultiWorker interface {
	SynchronizeStats() error
	SyncrhonizeConfigs() error
}

TelemetryMultiWorker defines the interface for a telemetry syncrhonizer suitable for multiple sdk instances

type TelemetryMultiWorkerImpl ¶

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

TelemetryMultiWorkerImpl is a component used to syncrhonize telemetry posted in redis by sdk into the split servers

func NewTelemetryMultiWorker(logger logging.LoggerInterface, store storage.RedisTelemetryConsumerMulti, sync service.TelemetryRecorder) *TelemetryMultiWorkerImpl

func (w *TelemetryMultiWorkerImpl) SynchronizeStats() error

func (w *TelemetryMultiWorkerImpl) SyncrhonizeConfigs() error