telemetry

Documentation

Index

• Constants
• func Bucket(latency int64) int
• func GetStreamingEvent(eventType int, data int64) *dtos.StreamingEvent
• func IsMethodValid(method *string) bool
• type InitConfig
• type RecorderSingle
  • func (e *RecorderSingle) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...)
  • func (e *RecorderSingle) SynchronizeStats() error
• type SynchronizerRedis
  • func (r *SynchronizerRedis) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, ...)
  • func (r *SynchronizerRedis) SynchronizeStats() error
• type TelemetrySynchronizer
  • func NewSynchronizerRedis(storage storage.TelemetryConfigProducer, logger logging.LoggerInterface) TelemetrySynchronizer
  • func NewTelemetrySynchronizer(telemetryStorage storage.TelemetryStorageConsumer, ...) TelemetrySynchronizer

Constants

const (
	// Treatment getTreatment
	Treatment = "treatment"
	// Treatments getTreatments
	Treatments = "treatments"
	// TreatmentWithConfig getTreatmentWithConfig
	TreatmentWithConfig = "treatmentWithConfig"
	// TreatmentsWithConfig getTreatmentsWithConfig
	TreatmentsWithConfig = "treatmentsWithConfig"
	// Track track
	Track = "track"
)

const (
	// SplitSync splitChanges
	SplitSync = iota
	// SegmentSync segmentChanges
	SegmentSync
	// ImpressionSync impressions
	ImpressionSync
	// ImpressionCountSync impressionsCount
	ImpressionCountSync
	// EventSync events
	EventSync
	// TelemetrySync telemetry
	TelemetrySync
	// TokenSync auth
	TokenSync
)

const (
	// ImpressionsDropped dropped
	ImpressionsDropped = iota
	// ImpressionsDeduped deduped
	ImpressionsDeduped
	// ImpressionsQueued queued
	ImpressionsQueued
)

const (
	// EventsDropped dropped
	EventsDropped = iota
	// EventsQueued queued
	EventsQueued
)

const (
	// LatencyBucketCount Max buckets
	LatencyBucketCount = 23
	// MaxStreamingEvents Max streaming events allowed
	MaxStreamingEvents = 20
	// MaxTags Max tags
	MaxTags = 10
)

const (
	EventTypeSSEConnectionEstablished = iota * 10
	EventTypeOccupancyPri
	EventTypeOccupancySec
	EventTypeStreamingStatus
	EventTypeConnectionError
	EventTypeTokenRefresh
	EventTypeAblyError
	EventTypeSyncMode
)

const (
	StreamingDisabled = iota
	StreamingEnabled
	StreamingPaused
)

const (
	Requested = iota
	NonRequested
)

const (
	Streaming = iota
	Polling
)

const (
	Standalone = iota
	Consumer
	Producer
)

const (
	ImpressionsModeOptimized = iota
	ImpressionsModeDebug
)

const (
	Redis  = "redis"
	Memory = "memory"
)

Functions

func Bucket

func Bucket(latency int64) int

Bucket returns the bucket where the received latency falls

func GetStreamingEvent

func GetStreamingEvent(eventType int, data int64) *dtos.StreamingEvent

func IsMethodValid

func IsMethodValid(method *string) bool

IsMethodValid returs true if the supplied method name is valid

Types

type InitConfig

type InitConfig struct {
	AdvancedConfig conf.AdvancedConfig
	TaskPeriods    conf.TaskPeriods
	ManagerConfig  conf.ManagerConfig
}

InitConfig involves entire config for init

type RecorderSingle

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

RecorderSingle struct for telemetry sync

func (*RecorderSingle) SynchronizeConfig

func (e *RecorderSingle) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, tags []string)

SynchronizeConfig syncs telemetry config

func (*RecorderSingle) SynchronizeStats

func (e *RecorderSingle) SynchronizeStats() error

SynchronizeStats syncs telemetry stats

type SynchronizerRedis

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

func (*SynchronizerRedis) SynchronizeConfig

func (r *SynchronizerRedis) SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, tags []string)

func (*SynchronizerRedis) SynchronizeStats

func (r *SynchronizerRedis) SynchronizeStats() error

type TelemetrySynchronizer

type TelemetrySynchronizer interface {
	SynchronizeConfig(cfg InitConfig, timedUntilReady int64, factoryInstances map[string]int64, tags []string)
	SynchronizeStats() error
}

TelemetrySynchronizer interface

func NewSynchronizerRedis

func NewSynchronizerRedis(storage storage.TelemetryConfigProducer, logger logging.LoggerInterface) TelemetrySynchronizer

func NewTelemetrySynchronizer

func NewTelemetrySynchronizer(
	telemetryStorage storage.TelemetryStorageConsumer,
	telemetryRecorder service.TelemetryRecorder,
	splitStorage storage.SplitStorageConsumer,
	segmentStorage storage.SegmentStorageConsumer,
	logger logging.LoggerInterface,
	metadata dtos.Metadata,
	runtimeTelemetry storage.TelemetryRuntimeProducer,
) TelemetrySynchronizer

NewTelemetrySynchronizer creates new event synchronizer for posting events