impressionscount

Documentation

Index

• type ImpressionsCountRecorder
  • func NewRecorderRedis(impressionsCounter *strategy.ImpressionsCounter, ...) ImpressionsCountRecorder
  • func NewRecorderSingle(impressionsCounter *strategy.ImpressionsCounter, ...) ImpressionsCountRecorder
• type RecorderRedis
  • func (m *RecorderRedis) SynchronizeImpressionsCount() error
• type RecorderSingle
  • func (m *RecorderSingle) SynchronizeImpressionsCount() error

Types

type ImpressionsCountRecorder

type ImpressionsCountRecorder interface {
	SynchronizeImpressionsCount() error
}

ImpressionsCountRecorder interface

func NewRecorderRedis

func NewRecorderRedis(
	impressionsCounter *strategy.ImpressionsCounter,
	impressionsCountStorage storage.ImpressionsCountProducer,
	logger logging.LoggerInterface,
) ImpressionsCountRecorder

NewRecorderRedis creates new impressionsCount synchronizer for log impressionsCount in redis

func NewRecorderSingle

func NewRecorderSingle(
	impressionsCounter *strategy.ImpressionsCounter,
	impressionRecorder service.ImpressionsRecorder,
	metadata dtos.Metadata,
	logger logging.LoggerInterface,
	runtimeTelemetry storage.TelemetryRuntimeProducer,
) ImpressionsCountRecorder

NewRecorderSingle creates new impressionsCount synchronizer for posting impressionsCount

type RecorderRedis

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

RecorderRedis struct for impressionsCount sync

func (*RecorderRedis) SynchronizeImpressionsCount

func (m *RecorderRedis) SynchronizeImpressionsCount() error

SynchronizeImpressionsCount syncs imp counts

type RecorderSingle

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

RecorderSingle struct for impressionsCount sync

func (*RecorderSingle) SynchronizeImpressionsCount

func (m *RecorderSingle) SynchronizeImpressionsCount() error

SynchronizeImpressionsCount syncs imp counts