The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ImpressionRecorder ¶
type ImpressionRecorder interface {
SynchronizeImpressions(bulkSize int64) error
FlushImpressions(bulkSize int64) error
}
ImpressionRecorder interface
func NewRecorderRedis ¶ added in v4.2.0
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 ¶ added in v4.2.0
type RecorderRedis struct {
// contains filtered or unexported fields
}
func (*RecorderRedis) FlushImpressions ¶ added in v4.2.0
func (i *RecorderRedis) FlushImpressions(bulkSize int64) error
FlushImpressions flushes impressions
func (*RecorderRedis) SynchronizeImpressions ¶ added in v4.2.0
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
Source Files
Click to show internal directories.
Click to hide internal directories.