impression

Documentation

Index

• type ImpressionRecorder
  • func NewRecorderRedis(impsInMemoryStorage storage.ImpressionStorageConsumer, ...) ImpressionRecorder
  • func NewRecorderSingle(impressionStorage storage.ImpressionStorageConsumer, ...) ImpressionRecorder
• type RecorderRedis
  • func (i *RecorderRedis) FlushImpressions(bulkSize int64) error
  • func (i *RecorderRedis) SynchronizeImpressions(bulkSize int64) error
• type RecorderSingle
  • func (i *RecorderSingle) FlushImpressions(bulkSize int64) error
  • func (i *RecorderSingle) SynchronizeImpressions(bulkSize int64) error

Types

type ImpressionRecorder

type ImpressionRecorder interface {
	SynchronizeImpressions(bulkSize int64) error
	FlushImpressions(bulkSize int64) error
}

ImpressionRecorder interface

func NewRecorderRedis

func NewRecorderRedis(impsInMemoryStorage storage.ImpressionStorageConsumer, impsRedisStorage storage.ImpressionStorageProducer, logger logging.LoggerInterface) ImpressionRecorder

NewRecorderRedis creates new impressionsCount synchronizer for log impressionsCount in redis

func NewRecorderSingle

func NewRecorderSingle(
	impressionStorage storage.ImpressionStorageConsumer,
	impressionRecorder service.ImpressionsRecorder,
	logger logging.LoggerInterface,
	metadata dtos.Metadata,
	impressionsMode string,
	runtimeTelemetry storage.TelemetryRuntimeProducer,
) ImpressionRecorder

NewRecorderSingle creates new impression synchronizer for posting impressions

type RecorderRedis

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

func (*RecorderRedis) FlushImpressions

func (i *RecorderRedis) FlushImpressions(bulkSize int64) error

FlushImpressions flushes impressions

func (*RecorderRedis) SynchronizeImpressions

func (i *RecorderRedis) SynchronizeImpressions(bulkSize int64) error

SynchronizeImpressions syncs impressions

type RecorderSingle

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

RecorderSingle struct for impression sync

func (*RecorderSingle) FlushImpressions

func (i *RecorderSingle) FlushImpressions(bulkSize int64) error

FlushImpressions flushes impressions

func (*RecorderSingle) SynchronizeImpressions

func (i *RecorderSingle) SynchronizeImpressions(bulkSize int64) error

SynchronizeImpressions syncs impressions