telemetry

Documentation

Index

• Variables
• func FieldTypeForValue(value interface{}) int32
• type Aggregator
  • func NewContextAggregators(opts options.Options) []Aggregator
• type ContextShapeAggregator
  • func NewContextShapeAggregator() *ContextShapeAggregator
  • func (eca *ContextShapeAggregator) Clear()
  • func (eca *ContextShapeAggregator) GetData() *prefabProto.TelemetryEvent
  • func (eca *ContextShapeAggregator) Lock()
  • func (eca *ContextShapeAggregator) Record(ctxSet interface{})
  • func (eca *ContextShapeAggregator) Unlock()
• type EvaluationSummaryAggregator
  • func NewEvaluationSummaryAggregator() *EvaluationSummaryAggregator
  • func (esa *EvaluationSummaryAggregator) Clear()
  • func (esa *EvaluationSummaryAggregator) GetData() *prefabProto.TelemetryEvent
  • func (esa *EvaluationSummaryAggregator) Lock()
  • func (esa *EvaluationSummaryAggregator) Record(data interface{})
  • func (esa *EvaluationSummaryAggregator) Unlock()
• type ExampleContextAggregator
  • func NewExampleContextAggregator() *ExampleContextAggregator
  • func (eca *ExampleContextAggregator) Clear()
  • func (eca *ExampleContextAggregator) GetData() *prefabProto.TelemetryEvent
  • func (eca *ExampleContextAggregator) Lock()
  • func (eca *ExampleContextAggregator) Record(ctxSet interface{})
  • func (eca *ExampleContextAggregator) Unlock()
• type Payload
• type QueueItem
• type Submitter
  • func NewTelemetrySubmitter(options options.Options) *Submitter
  • func (ts *Submitter) RecordContext(data *contexts.ContextSet)
  • func (ts *Submitter) RecordEvaluation(data internal.ConfigMatch)
  • func (ts *Submitter) SetupQueueConsumer()
  • func (ts *Submitter) StartPeriodicSubmission(interval time.Duration)
  • func (ts *Submitter) Submit(waitOnQueueToDrain bool) error

Variables

var (
	NowProvider = time.Now().UnixMilli
)

Functions

func FieldTypeForValue

func FieldTypeForValue(value interface{}) int32

Types

type Aggregator

type Aggregator interface {
	Record(data interface{})
	GetData() *prefabProto.TelemetryEvent
	Clear()
	Lock()
	Unlock()
}

func NewContextAggregators

func NewContextAggregators(opts options.Options) []Aggregator

type ContextShapeAggregator

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

func NewContextShapeAggregator

func NewContextShapeAggregator() *ContextShapeAggregator

func (*ContextShapeAggregator) Clear

func (eca *ContextShapeAggregator) Clear()

func (*ContextShapeAggregator) GetData

func (eca *ContextShapeAggregator) GetData() *prefabProto.TelemetryEvent

func (*ContextShapeAggregator) Lock

func (eca *ContextShapeAggregator) Lock()

func (*ContextShapeAggregator) Record

func (eca *ContextShapeAggregator) Record(ctxSet interface{})

func (*ContextShapeAggregator) Unlock

func (eca *ContextShapeAggregator) Unlock()

type EvaluationSummaryAggregator

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

func NewEvaluationSummaryAggregator

func NewEvaluationSummaryAggregator() *EvaluationSummaryAggregator

func (*EvaluationSummaryAggregator) Clear

func (esa *EvaluationSummaryAggregator) Clear()

func (*EvaluationSummaryAggregator) GetData

func (esa *EvaluationSummaryAggregator) GetData() *prefabProto.TelemetryEvent

func (*EvaluationSummaryAggregator) Lock

func (esa *EvaluationSummaryAggregator) Lock()

func (*EvaluationSummaryAggregator) Record

func (esa *EvaluationSummaryAggregator) Record(data interface{})

func (*EvaluationSummaryAggregator) Unlock

func (esa *EvaluationSummaryAggregator) Unlock()

type ExampleContextAggregator

type ExampleContextAggregator struct {
	Data map[string]*prefabProto.ExampleContext
	// contains filtered or unexported fields
}

func NewExampleContextAggregator

func NewExampleContextAggregator() *ExampleContextAggregator

func (*ExampleContextAggregator) Clear

func (eca *ExampleContextAggregator) Clear()

func (*ExampleContextAggregator) GetData

func (eca *ExampleContextAggregator) GetData() *prefabProto.TelemetryEvent

func (*ExampleContextAggregator) Lock

func (eca *ExampleContextAggregator) Lock()

func (*ExampleContextAggregator) Record

func (eca *ExampleContextAggregator) Record(ctxSet interface{})

func (*ExampleContextAggregator) Unlock

func (eca *ExampleContextAggregator) Unlock()

type Payload

type Payload = prefabProto.TelemetryEvents

type QueueItem

type QueueItem interface{}

type Submitter

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

func NewTelemetrySubmitter

func NewTelemetrySubmitter(options options.Options) *Submitter

func (*Submitter) RecordContext

func (ts *Submitter) RecordContext(data *contexts.ContextSet)

func (*Submitter) RecordEvaluation

func (ts *Submitter) RecordEvaluation(data internal.ConfigMatch)

func (*Submitter) SetupQueueConsumer

func (ts *Submitter) SetupQueueConsumer()

func (*Submitter) StartPeriodicSubmission

func (ts *Submitter) StartPeriodicSubmission(interval time.Duration)

func (*Submitter) Submit

func (ts *Submitter) Submit(waitOnQueueToDrain bool) error