chqpb

package
v0.4.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 23, 2024 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	KafkaEnvelopePublishType_name = map[int32]string{
		0:  "PUBLISH_TYPE_SPAN_STATS",
		1:  "PUBLISH_TYPE_SKETCHES",
		2:  "PUBLISH_TYPE_METADATA",
		3:  "PUBLISH_TYPE_CHECK_RUN",
		4:  "PUBLISH_TYPE_INTAKE_DATADOG",
		5:  "PUBLISH_TYPE_INTAKE_CARDINAL",
		6:  "PUBLISH_TYPE_METRICS",
		7:  "PUBLISH_TYPE_LOGS",
		8:  "PUBLISH_TYPE_TRACES",
		9:  "PUBLISH_TYPE_METRICS_V2",
		10: "PUBLISH_TYPE_OTEL_LOGS",
		11: "PUBLISH_TYPE_SPAN_METADATA_STATS",
		12: "PUBLISH_TYPE_METRIC_METADATA_STATS",
		13: "PUBLISH_TYPE_LOG_METADATA_STATS",
		14: "PUBLISH_TYPE_METRICS_V2_JSON",
	}
	KafkaEnvelopePublishType_value = map[string]int32{
		"PUBLISH_TYPE_SPAN_STATS":            0,
		"PUBLISH_TYPE_SKETCHES":              1,
		"PUBLISH_TYPE_METADATA":              2,
		"PUBLISH_TYPE_CHECK_RUN":             3,
		"PUBLISH_TYPE_INTAKE_DATADOG":        4,
		"PUBLISH_TYPE_INTAKE_CARDINAL":       5,
		"PUBLISH_TYPE_METRICS":               6,
		"PUBLISH_TYPE_LOGS":                  7,
		"PUBLISH_TYPE_TRACES":                8,
		"PUBLISH_TYPE_METRICS_V2":            9,
		"PUBLISH_TYPE_OTEL_LOGS":             10,
		"PUBLISH_TYPE_SPAN_METADATA_STATS":   11,
		"PUBLISH_TYPE_METRIC_METADATA_STATS": 12,
		"PUBLISH_TYPE_LOG_METADATA_STATS":    13,
		"PUBLISH_TYPE_METRICS_V2_JSON":       14,
	}
)

Enum value maps for KafkaEnvelopePublishType.

View Source 
var (
	Phase_name = map[int32]string{
		0: "PASSTHROUGH",
		1: "AGGREGATED",
		2: "AGGREGATION_OUTPUT",
		3: "FILTERED",
		4: "DRY_RUN_FILTERED",
		5: "PRE",
		6: "POST",
	}
	Phase_value = map[string]int32{
		"PASSTHROUGH":        0,
		"AGGREGATED":         1,
		"AGGREGATION_OUTPUT": 2,
		"FILTERED":           3,
		"DRY_RUN_FILTERED":   4,
		"PRE":                5,
		"POST":               6,
	}
)

Enum value maps for Phase.

View Source 
var File_attribute_proto protoreflect.FileDescriptor
View Source 
var File_kafkaenvelope_proto protoreflect.FileDescriptor
View Source 
var File_log_ingest_stats_proto protoreflect.FileDescriptor
View Source 
var File_metric_ingest_stats_proto protoreflect.FileDescriptor
View Source 
var File_span_ingest_stats_proto protoreflect.FileDescriptor
View Source 
var File_stats_proto protoreflect.FileDescriptor

Functions

func AttributeToString 

func AttributeToString(attr *Attribute) string

Types

type Attribute 

type Attribute struct {
	Type        int32  `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	IsAttribute bool   `protobuf:"varint,2,opt,name=isAttribute,proto3" json:"isAttribute,omitempty"`
	ContextId   string `protobuf:"bytes,3,opt,name=contextId,proto3" json:"contextId,omitempty"`
	Value       string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Key         string `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*Attribute) Descriptor deprecated 

func (*Attribute) Descriptor() ([]byte, []int)

Deprecated: Use Attribute.ProtoReflect.Descriptor instead.

func (*Attribute) GetContextId 

func (x *Attribute) GetContextId() string

func (*Attribute) GetIsAttribute 

func (x *Attribute) GetIsAttribute() bool

func (*Attribute) GetKey 

func (x *Attribute) GetKey() string

func (*Attribute) GetType 

func (x *Attribute) GetType() int32

func (*Attribute) GetValue 

func (x *Attribute) GetValue() string

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) ProtoReflect 

func (x *Attribute) ProtoReflect() protoreflect.Message

func (*Attribute) Reset 

func (x *Attribute) Reset()

func (*Attribute) String 

func (x *Attribute) String() string

type Clock added in v0.4.3 

type Clock interface {
	Now() time.Time
	After(d time.Duration) <-chan time.Time
}

type Entry added in v0.4.3 

type Entry[T any] struct {
	// contains filtered or unexported fields
}

type EventStats added in v0.2.3 

type EventStats struct {
	ServiceName string       `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	Fingerprint int64        `protobuf:"varint,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	Phase       Phase        `protobuf:"varint,3,opt,name=phase,proto3,enum=chqpb.Phase" json:"phase,omitempty"`
	Count       int64        `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	Size        int64        `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	Exemplar    []byte       `protobuf:"bytes,6,opt,name=exemplar,proto3" json:"exemplar,omitempty"`
	ProcessorId string       `protobuf:"bytes,7,opt,name=processorId,proto3" json:"processorId,omitempty"`
	Attributes  []*Attribute `protobuf:"bytes,8,rep,name=attributes,proto3" json:"attributes,omitempty"`
	CollectorId string       `protobuf:"bytes,9,opt,name=collectorId,proto3" json:"collectorId,omitempty"`
	CustomerId  string       `protobuf:"bytes,10,opt,name=customerId,proto3" json:"customerId,omitempty"`
	TsHour      int64        `protobuf:"varint,11,opt,name=tsHour,proto3" json:"tsHour,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStats) Descriptor deprecated added in v0.2.3 

func (*EventStats) Descriptor() ([]byte, []int)

Deprecated: Use EventStats.ProtoReflect.Descriptor instead.

func (*EventStats) GetAttributes added in v0.2.3 

func (x *EventStats) GetAttributes() []*Attribute

func (*EventStats) GetCollectorId added in v0.2.4 

func (x *EventStats) GetCollectorId() string

func (*EventStats) GetCount added in v0.2.3 

func (x *EventStats) GetCount() int64

func (*EventStats) GetCustomerId added in v0.2.4 

func (x *EventStats) GetCustomerId() string

func (*EventStats) GetExemplar added in v0.2.3 

func (x *EventStats) GetExemplar() []byte

func (*EventStats) GetFingerprint added in v0.2.3 

func (x *EventStats) GetFingerprint() int64

func (*EventStats) GetPhase added in v0.2.3 

func (x *EventStats) GetPhase() Phase

func (*EventStats) GetProcessorId added in v0.2.3 

func (x *EventStats) GetProcessorId() string

func (*EventStats) GetServiceName added in v0.2.3 

func (x *EventStats) GetServiceName() string

func (*EventStats) GetSize added in v0.2.3 

func (x *EventStats) GetSize() int64

func (*EventStats) GetTsHour added in v0.2.4 

func (x *EventStats) GetTsHour() int64

func (*EventStats) Key added in v0.2.3 

func (e *EventStats) Key() string

func (*EventStats) ProtoMessage added in v0.2.3 

func (*EventStats) ProtoMessage()

func (*EventStats) ProtoReflect added in v0.2.3 

func (x *EventStats) ProtoReflect() protoreflect.Message

func (*EventStats) Reset added in v0.2.3 

func (x *EventStats) Reset()

func (*EventStats) String added in v0.2.3 

func (x *EventStats) String() string

type EventStatsCache added in v0.2.25 

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

func NewEventStatsCache added in v0.2.25 

func NewEventStatsCache(capacity int,
	numBins uint16,
	flushInterval time.Duration,
	flushCallback FlushCallback[*EventStats],
	initializeCallback InitializeCallback[*EventStats],
	clock Clock) *EventStatsCache

func (*EventStatsCache) Record added in v0.2.25 

func (e *EventStatsCache) Record(serviceName string,
	fingerprint int64,
	phase Phase,
	processorId string,
	collectorId string,
	customerId string,
	attributes []*Attribute,
	count int64,
	size int64) error

func (*EventStatsCache) RecordEventStats added in v0.4.3 

func (e *EventStatsCache) RecordEventStats(eventStats *EventStats) error

type EventStatsReport added in v0.2.3 

type EventStatsReport struct {
	SubmittedAt int64         `protobuf:"varint,1,opt,name=submittedAt,proto3" json:"submittedAt,omitempty"`
	Stats       []*EventStats `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStatsReport) Descriptor deprecated added in v0.2.3 

func (*EventStatsReport) Descriptor() ([]byte, []int)

Deprecated: Use EventStatsReport.ProtoReflect.Descriptor instead.

func (*EventStatsReport) GetStats added in v0.2.3 

func (x *EventStatsReport) GetStats() []*EventStats

func (*EventStatsReport) GetSubmittedAt added in v0.2.3 

func (x *EventStatsReport) GetSubmittedAt() int64

func (*EventStatsReport) ProtoMessage added in v0.2.3 

func (*EventStatsReport) ProtoMessage()

func (*EventStatsReport) ProtoReflect added in v0.2.3 

func (x *EventStatsReport) ProtoReflect() protoreflect.Message

func (*EventStatsReport) Reset added in v0.2.3 

func (x *EventStatsReport) Reset()

func (*EventStatsReport) String added in v0.2.3 

func (x *EventStatsReport) String() string

type FlushCallback added in v0.4.3 

type FlushCallback[T any] func(expiredItems []T)

type InitializeCallback added in v0.4.7 

type InitializeCallback[T any] func(tsHour int64, key string) (T, error)

type KafkaEnvelope 

type KafkaEnvelope struct {
	CustomerId  string `protobuf:"bytes,1,opt,name=customerId,proto3" json:"customerId,omitempty"`
	Key         string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	PublishType int32  `protobuf:"varint,3,opt,name=publishType,proto3" json:"publishType,omitempty"`
	Ts          int64  `protobuf:"varint,4,opt,name=ts,proto3" json:"ts,omitempty"`
	Payload     []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// Types that are assignable to Partition:
	//
	//	*KafkaEnvelope_PartitionValue
	Partition isKafkaEnvelope_Partition `protobuf_oneof:"partition"`
	// contains filtered or unexported fields
}

func (*KafkaEnvelope) Descriptor deprecated 

func (*KafkaEnvelope) Descriptor() ([]byte, []int)

Deprecated: Use KafkaEnvelope.ProtoReflect.Descriptor instead.

func (*KafkaEnvelope) GetCustomerId 

func (x *KafkaEnvelope) GetCustomerId() string

func (*KafkaEnvelope) GetKey 

func (x *KafkaEnvelope) GetKey() string

func (*KafkaEnvelope) GetPartition 

func (m *KafkaEnvelope) GetPartition() isKafkaEnvelope_Partition

func (*KafkaEnvelope) GetPartitionValue 

func (x *KafkaEnvelope) GetPartitionValue() int32

func (*KafkaEnvelope) GetPayload 

func (x *KafkaEnvelope) GetPayload() []byte

func (*KafkaEnvelope) GetPublishType 

func (x *KafkaEnvelope) GetPublishType() int32

func (*KafkaEnvelope) GetTs 

func (x *KafkaEnvelope) GetTs() int64

func (*KafkaEnvelope) ProtoMessage 

func (*KafkaEnvelope) ProtoMessage()

func (*KafkaEnvelope) ProtoReflect 

func (x *KafkaEnvelope) ProtoReflect() protoreflect.Message

func (*KafkaEnvelope) Reset 

func (x *KafkaEnvelope) Reset()

func (*KafkaEnvelope) String 

func (x *KafkaEnvelope) String() string

type KafkaEnvelopePublishType 

type KafkaEnvelopePublishType int32
const (
	KafkaEnvelopePublishType_PUBLISH_TYPE_SPAN_STATS            KafkaEnvelopePublishType = 0
	KafkaEnvelopePublishType_PUBLISH_TYPE_SKETCHES              KafkaEnvelopePublishType = 1
	KafkaEnvelopePublishType_PUBLISH_TYPE_METADATA              KafkaEnvelopePublishType = 2
	KafkaEnvelopePublishType_PUBLISH_TYPE_CHECK_RUN             KafkaEnvelopePublishType = 3
	KafkaEnvelopePublishType_PUBLISH_TYPE_INTAKE_DATADOG        KafkaEnvelopePublishType = 4
	KafkaEnvelopePublishType_PUBLISH_TYPE_INTAKE_CARDINAL       KafkaEnvelopePublishType = 5
	KafkaEnvelopePublishType_PUBLISH_TYPE_METRICS               KafkaEnvelopePublishType = 6
	KafkaEnvelopePublishType_PUBLISH_TYPE_LOGS                  KafkaEnvelopePublishType = 7
	KafkaEnvelopePublishType_PUBLISH_TYPE_TRACES                KafkaEnvelopePublishType = 8
	KafkaEnvelopePublishType_PUBLISH_TYPE_METRICS_V2            KafkaEnvelopePublishType = 9
	KafkaEnvelopePublishType_PUBLISH_TYPE_OTEL_LOGS             KafkaEnvelopePublishType = 10
	KafkaEnvelopePublishType_PUBLISH_TYPE_SPAN_METADATA_STATS   KafkaEnvelopePublishType = 11
	KafkaEnvelopePublishType_PUBLISH_TYPE_METRIC_METADATA_STATS KafkaEnvelopePublishType = 12
	KafkaEnvelopePublishType_PUBLISH_TYPE_LOG_METADATA_STATS    KafkaEnvelopePublishType = 13
	KafkaEnvelopePublishType_PUBLISH_TYPE_METRICS_V2_JSON       KafkaEnvelopePublishType = 14
)

func (KafkaEnvelopePublishType) Descriptor 

func (KafkaEnvelopePublishType) Descriptor() protoreflect.EnumDescriptor

func (KafkaEnvelopePublishType) Enum 

func (x KafkaEnvelopePublishType) Enum() *KafkaEnvelopePublishType

func (KafkaEnvelopePublishType) EnumDescriptor deprecated 

func (KafkaEnvelopePublishType) EnumDescriptor() ([]byte, []int)

Deprecated: Use KafkaEnvelopePublishType.Descriptor instead.

func (KafkaEnvelopePublishType) Number 

func (x KafkaEnvelopePublishType) Number() protoreflect.EnumNumber

func (KafkaEnvelopePublishType) String 

func (x KafkaEnvelopePublishType) String() string

func (KafkaEnvelopePublishType) Type 

func (KafkaEnvelopePublishType) Type() protoreflect.EnumType

type KafkaEnvelope_PartitionValue 

type KafkaEnvelope_PartitionValue struct {
	PartitionValue int32 `protobuf:"varint,6,opt,name=partitionValue,proto3,oneof"`
}

type LogIngestStat 

type LogIngestStat struct {
	Exemplar    []byte             `protobuf:"bytes,1,opt,name=exemplar,proto3" json:"exemplar,omitempty"`
	EventsCount int64              `protobuf:"varint,2,opt,name=eventsCount,proto3" json:"eventsCount,omitempty"`
	SizeBytes   int64              `protobuf:"varint,3,opt,name=sizeBytes,proto3" json:"sizeBytes,omitempty"`
	Key         *LogIngestStat_Key `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*LogIngestStat) Descriptor deprecated 

func (*LogIngestStat) Descriptor() ([]byte, []int)

Deprecated: Use LogIngestStat.ProtoReflect.Descriptor instead.

func (*LogIngestStat) GetEventsCount 

func (x *LogIngestStat) GetEventsCount() int64

func (*LogIngestStat) GetExemplar 

func (x *LogIngestStat) GetExemplar() []byte

func (*LogIngestStat) GetKey 

func (x *LogIngestStat) GetKey() *LogIngestStat_Key

func (*LogIngestStat) GetSizeBytes 

func (x *LogIngestStat) GetSizeBytes() int64

func (*LogIngestStat) ProtoMessage 

func (*LogIngestStat) ProtoMessage()

func (*LogIngestStat) ProtoReflect 

func (x *LogIngestStat) ProtoReflect() protoreflect.Message

func (*LogIngestStat) Reset 

func (x *LogIngestStat) Reset()

func (*LogIngestStat) String 

func (x *LogIngestStat) String() string

type LogIngestStat_Key 

type LogIngestStat_Key struct {
	Service     string       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Fingerprint int64        `protobuf:"varint,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	TsHour      int64        `protobuf:"varint,3,opt,name=tsHour,proto3" json:"tsHour,omitempty"`
	Attributes  []*Attribute `protobuf:"bytes,4,rep,name=attributes,proto3" json:"attributes,omitempty"`
	CustomerId  string       `protobuf:"bytes,5,opt,name=customerId,proto3" json:"customerId,omitempty"`
	PhaseType   string       `protobuf:"bytes,6,opt,name=phaseType,proto3" json:"phaseType,omitempty"`
	ProcessorId string       `protobuf:"bytes,7,opt,name=processorId,proto3" json:"processorId,omitempty"`
	CollectorId string       `protobuf:"bytes,8,opt,name=collectorId,proto3" json:"collectorId,omitempty"`
	// contains filtered or unexported fields
}

func (*LogIngestStat_Key) Descriptor deprecated 

func (*LogIngestStat_Key) Descriptor() ([]byte, []int)

Deprecated: Use LogIngestStat_Key.ProtoReflect.Descriptor instead.

func (*LogIngestStat_Key) GetAttributes 

func (x *LogIngestStat_Key) GetAttributes() []*Attribute

func (*LogIngestStat_Key) GetCollectorId 

func (x *LogIngestStat_Key) GetCollectorId() string

func (*LogIngestStat_Key) GetCustomerId 

func (x *LogIngestStat_Key) GetCustomerId() string

func (*LogIngestStat_Key) GetFingerprint 

func (x *LogIngestStat_Key) GetFingerprint() int64

func (*LogIngestStat_Key) GetPhaseType 

func (x *LogIngestStat_Key) GetPhaseType() string

func (*LogIngestStat_Key) GetProcessorId 

func (x *LogIngestStat_Key) GetProcessorId() string

func (*LogIngestStat_Key) GetService 

func (x *LogIngestStat_Key) GetService() string

func (*LogIngestStat_Key) GetTsHour 

func (x *LogIngestStat_Key) GetTsHour() int64

func (*LogIngestStat_Key) Hash 

func (key *LogIngestStat_Key) Hash() uint64

func (*LogIngestStat_Key) ProtoMessage 

func (*LogIngestStat_Key) ProtoMessage()

func (*LogIngestStat_Key) ProtoReflect 

func (x *LogIngestStat_Key) ProtoReflect() protoreflect.Message

func (*LogIngestStat_Key) Reset 

func (x *LogIngestStat_Key) Reset()

func (*LogIngestStat_Key) String 

func (x *LogIngestStat_Key) String() string

type LogIngestStatsList 

type LogIngestStatsList struct {
	Stats []*LogIngestStat        `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	Key   *LogIngestStatsList_Key `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*LogIngestStatsList) Descriptor deprecated 

func (*LogIngestStatsList) Descriptor() ([]byte, []int)

Deprecated: Use LogIngestStatsList.ProtoReflect.Descriptor instead.

func (*LogIngestStatsList) GetKey 

func (x *LogIngestStatsList) GetKey() *LogIngestStatsList_Key

func (*LogIngestStatsList) GetStats 

func (x *LogIngestStatsList) GetStats() []*LogIngestStat

func (*LogIngestStatsList) ProtoMessage 

func (*LogIngestStatsList) ProtoMessage()

func (*LogIngestStatsList) ProtoReflect 

func (x *LogIngestStatsList) ProtoReflect() protoreflect.Message

func (*LogIngestStatsList) Reset 

func (x *LogIngestStatsList) Reset()

func (*LogIngestStatsList) String 

func (x *LogIngestStatsList) String() string

type LogIngestStatsList_Key 

type LogIngestStatsList_Key struct {
	CustomerId  string `protobuf:"bytes,1,opt,name=customerId,proto3" json:"customerId,omitempty"`
	PhaseType   string `protobuf:"bytes,2,opt,name=phaseType,proto3" json:"phaseType,omitempty"`
	ProcessorId string `protobuf:"bytes,3,opt,name=processorId,proto3" json:"processorId,omitempty"`
	CollectorId string `protobuf:"bytes,4,opt,name=collectorId,proto3" json:"collectorId,omitempty"`
	TsHour      int64  `protobuf:"varint,5,opt,name=tsHour,proto3" json:"tsHour,omitempty"`
	// contains filtered or unexported fields
}

func (*LogIngestStatsList_Key) Descriptor deprecated 

func (*LogIngestStatsList_Key) Descriptor() ([]byte, []int)

Deprecated: Use LogIngestStatsList_Key.ProtoReflect.Descriptor instead.

func (*LogIngestStatsList_Key) GetCollectorId 

func (x *LogIngestStatsList_Key) GetCollectorId() string

func (*LogIngestStatsList_Key) GetCustomerId 

func (x *LogIngestStatsList_Key) GetCustomerId() string

func (*LogIngestStatsList_Key) GetPhaseType 

func (x *LogIngestStatsList_Key) GetPhaseType() string

func (*LogIngestStatsList_Key) GetProcessorId 

func (x *LogIngestStatsList_Key) GetProcessorId() string

func (*LogIngestStatsList_Key) GetTsHour 

func (x *LogIngestStatsList_Key) GetTsHour() int64

func (*LogIngestStatsList_Key) ProtoMessage 

func (*LogIngestStatsList_Key) ProtoMessage()

func (*LogIngestStatsList_Key) ProtoReflect 

func (x *LogIngestStatsList_Key) ProtoReflect() protoreflect.Message

func (*LogIngestStatsList_Key) Reset 

func (x *LogIngestStatsList_Key) Reset()

func (*LogIngestStatsList_Key) String 

func (x *LogIngestStatsList_Key) String() string

type MetricExemplar 

type MetricExemplar struct {
	MetricName  string `protobuf:"bytes,1,opt,name=metricName,proto3" json:"metricName,omitempty"`
	ServiceName string `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	MetricType  string `protobuf:"bytes,3,opt,name=metricType,proto3" json:"metricType,omitempty"`
	Exemplar    []byte `protobuf:"bytes,4,opt,name=exemplar,proto3" json:"exemplar,omitempty"`
	ProcessorId string `protobuf:"bytes,5,opt,name=processorId,proto3" json:"processorId,omitempty"`
	CustomerId  string `protobuf:"bytes,6,opt,name=customerId,proto3" json:"customerId,omitempty"`
	CollectorId string `protobuf:"bytes,7,opt,name=collectorId,proto3" json:"collectorId,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricExemplar) Descriptor deprecated 

func (*MetricExemplar) Descriptor() ([]byte, []int)

Deprecated: Use MetricExemplar.ProtoReflect.Descriptor instead.

func (*MetricExemplar) GetCollectorId added in v0.2.23 

func (x *MetricExemplar) GetCollectorId() string

func (*MetricExemplar) GetCustomerId added in v0.2.23 

func (x *MetricExemplar) GetCustomerId() string

func (*MetricExemplar) GetExemplar 

func (x *MetricExemplar) GetExemplar() []byte

func (*MetricExemplar) GetMetricName 

func (x *MetricExemplar) GetMetricName() string

func (*MetricExemplar) GetMetricType 

func (x *MetricExemplar) GetMetricType() string

func (*MetricExemplar) GetProcessorId added in v0.2.10 

func (x *MetricExemplar) GetProcessorId() string

func (*MetricExemplar) GetServiceName 

func (x *MetricExemplar) GetServiceName() string

func (*MetricExemplar) ProtoMessage 

func (*MetricExemplar) ProtoMessage()

func (*MetricExemplar) ProtoReflect 

func (x *MetricExemplar) ProtoReflect() protoreflect.Message

func (*MetricExemplar) Reset 

func (x *MetricExemplar) Reset()

func (*MetricExemplar) String 

func (x *MetricExemplar) String() string

type MetricIngestStat 

type MetricIngestStat struct {
	HllSketch []byte                `protobuf:"bytes,1,opt,name=hllSketch,proto3" json:"hllSketch,omitempty"`
	Key       *MetricIngestStat_Key `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricIngestStat) Descriptor deprecated 

func (*MetricIngestStat) Descriptor() ([]byte, []int)

Deprecated: Use MetricIngestStat.ProtoReflect.Descriptor instead.

func (*MetricIngestStat) GetHllSketch 

func (x *MetricIngestStat) GetHllSketch() []byte

func (*MetricIngestStat) GetKey 

func (x *MetricIngestStat) GetKey() *MetricIngestStat_Key

func (*MetricIngestStat) ProtoMessage 

func (*MetricIngestStat) ProtoMessage()

func (*MetricIngestStat) ProtoReflect 

func (x *MetricIngestStat) ProtoReflect() protoreflect.Message

func (*MetricIngestStat) Reset 

func (x *MetricIngestStat) Reset()

func (*MetricIngestStat) String 

func (x *MetricIngestStat) String() string

type MetricIngestStat_Key 

type MetricIngestStat_Key struct {
	Service     string       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	MetricName  string       `protobuf:"bytes,2,opt,name=metricName,proto3" json:"metricName,omitempty"`
	TagName     string       `protobuf:"bytes,3,opt,name=tagName,proto3" json:"tagName,omitempty"`
	TsHour      int64        `protobuf:"varint,4,opt,name=tsHour,proto3" json:"tsHour,omitempty"`
	CustomerId  string       `protobuf:"bytes,5,opt,name=customerId,proto3" json:"customerId,omitempty"`
	PhaseType   string       `protobuf:"bytes,6,opt,name=phaseType,proto3" json:"phaseType,omitempty"`
	ProcessorId string       `protobuf:"bytes,7,opt,name=processorId,proto3" json:"processorId,omitempty"`
	CollectorId string       `protobuf:"bytes,8,opt,name=collectorId,proto3" json:"collectorId,omitempty"`
	Attributes  []*Attribute `protobuf:"bytes,9,rep,name=attributes,proto3" json:"attributes,omitempty"`
	TagScope    string       `protobuf:"bytes,10,opt,name=tagScope,proto3" json:"tagScope,omitempty"`
	MetricType  string       `protobuf:"bytes,11,opt,name=metricType,proto3" json:"metricType,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricIngestStat_Key) Descriptor deprecated 

func (*MetricIngestStat_Key) Descriptor() ([]byte, []int)

Deprecated: Use MetricIngestStat_Key.ProtoReflect.Descriptor instead.

func (*MetricIngestStat_Key) GetAttributes 

func (x *MetricIngestStat_Key) GetAttributes() []*Attribute

func (*MetricIngestStat_Key) GetCollectorId 

func (x *MetricIngestStat_Key) GetCollectorId() string

func (*MetricIngestStat_Key) GetCustomerId 

func (x *MetricIngestStat_Key) GetCustomerId() string

func (*MetricIngestStat_Key) GetMetricName 

func (x *MetricIngestStat_Key) GetMetricName() string

func (*MetricIngestStat_Key) GetMetricType 

func (x *MetricIngestStat_Key) GetMetricType() string

func (*MetricIngestStat_Key) GetPhaseType 

func (x *MetricIngestStat_Key) GetPhaseType() string

func (*MetricIngestStat_Key) GetProcessorId 

func (x *MetricIngestStat_Key) GetProcessorId() string

func (*MetricIngestStat_Key) GetService 

func (x *MetricIngestStat_Key) GetService() string

func (*MetricIngestStat_Key) GetTagName 

func (x *MetricIngestStat_Key) GetTagName() string

func (*MetricIngestStat_Key) GetTagScope 

func (x *MetricIngestStat_Key) GetTagScope() string

func (*MetricIngestStat_Key) GetTsHour 

func (x *MetricIngestStat_Key) GetTsHour() int64

func (*MetricIngestStat_Key) Hash 

func (key *MetricIngestStat_Key) Hash() uint64

func (*MetricIngestStat_Key) ProtoMessage 

func (*MetricIngestStat_Key) ProtoMessage()

func (*MetricIngestStat_Key) ProtoReflect 

func (x *MetricIngestStat_Key) ProtoReflect() protoreflect.Message

func (*MetricIngestStat_Key) Reset 

func (x *MetricIngestStat_Key) Reset()

func (*MetricIngestStat_Key) String 

func (x *MetricIngestStat_Key) String() string

type MetricIngestStatsList 

type MetricIngestStatsList struct {
	Stats     []*MetricIngestStat                     `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	Key       *MetricIngestStatsList_Key              `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Exemplars []*MetricIngestStatsList_MetricExemplar `protobuf:"bytes,3,rep,name=exemplars,proto3" json:"exemplars,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricIngestStatsList) Descriptor deprecated 

func (*MetricIngestStatsList) Descriptor() ([]byte, []int)

Deprecated: Use MetricIngestStatsList.ProtoReflect.Descriptor instead.

func (*MetricIngestStatsList) GetExemplars 

func (x *MetricIngestStatsList) GetExemplars() []*MetricIngestStatsList_MetricExemplar

func (*MetricIngestStatsList) GetKey 

func (x *MetricIngestStatsList) GetKey() *MetricIngestStatsList_Key

func (*MetricIngestStatsList) GetStats 

func (x *MetricIngestStatsList) GetStats() []*MetricIngestStat

func (*MetricIngestStatsList) ProtoMessage 

func (*MetricIngestStatsList) ProtoMessage()

func (*MetricIngestStatsList) ProtoReflect 

func (x *MetricIngestStatsList) ProtoReflect() protoreflect.Message

func (*MetricIngestStatsList) Reset 

func (x *MetricIngestStatsList) Reset()

func (*MetricIngestStatsList) String 

func (x *MetricIngestStatsList) String() string

type MetricIngestStatsList_Key 

type MetricIngestStatsList_Key struct {
	CustomerId  string `protobuf:"bytes,1,opt,name=customerId,proto3" json:"customerId,omitempty"`
	PhaseType   string `protobuf:"bytes,2,opt,name=phaseType,proto3" json:"phaseType,omitempty"`
	TsHour      int64  `protobuf:"varint,3,opt,name=tsHour,proto3" json:"tsHour,omitempty"`
	VendorId    string `protobuf:"bytes,4,opt,name=vendorId,proto3" json:"vendorId,omitempty"`
	CollectorId string `protobuf:"bytes,5,opt,name=collectorId,proto3" json:"collectorId,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricIngestStatsList_Key) Descriptor deprecated 

func (*MetricIngestStatsList_Key) Descriptor() ([]byte, []int)

Deprecated: Use MetricIngestStatsList_Key.ProtoReflect.Descriptor instead.

func (*MetricIngestStatsList_Key) GetCollectorId 

func (x *MetricIngestStatsList_Key) GetCollectorId() string

func (*MetricIngestStatsList_Key) GetCustomerId 

func (x *MetricIngestStatsList_Key) GetCustomerId() string

func (*MetricIngestStatsList_Key) GetPhaseType 

func (x *MetricIngestStatsList_Key) GetPhaseType() string

func (*MetricIngestStatsList_Key) GetTsHour 

func (x *MetricIngestStatsList_Key) GetTsHour() int64

func (*MetricIngestStatsList_Key) GetVendorId 

func (x *MetricIngestStatsList_Key) GetVendorId() string

func (*MetricIngestStatsList_Key) ProtoMessage 

func (*MetricIngestStatsList_Key) ProtoMessage()

func (*MetricIngestStatsList_Key) ProtoReflect 

func (x *MetricIngestStatsList_Key) ProtoReflect() protoreflect.Message

func (*MetricIngestStatsList_Key) Reset 

func (x *MetricIngestStatsList_Key) Reset()

func (*MetricIngestStatsList_Key) String 

func (x *MetricIngestStatsList_Key) String() string

type MetricIngestStatsList_MetricExemplar 

type MetricIngestStatsList_MetricExemplar struct {
	MetricName  string `protobuf:"bytes,1,opt,name=metricName,proto3" json:"metricName,omitempty"`
	ServiceName string `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	MetricType  string `protobuf:"bytes,3,opt,name=metricType,proto3" json:"metricType,omitempty"`
	Exemplar    []byte `protobuf:"bytes,4,opt,name=exemplar,proto3" json:"exemplar,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricIngestStatsList_MetricExemplar) Descriptor deprecated 

func (*MetricIngestStatsList_MetricExemplar) Descriptor() ([]byte, []int)

Deprecated: Use MetricIngestStatsList_MetricExemplar.ProtoReflect.Descriptor instead.

func (*MetricIngestStatsList_MetricExemplar) GetExemplar 

func (x *MetricIngestStatsList_MetricExemplar) GetExemplar() []byte

func (*MetricIngestStatsList_MetricExemplar) GetMetricName 

func (x *MetricIngestStatsList_MetricExemplar) GetMetricName() string

func (*MetricIngestStatsList_MetricExemplar) GetMetricType 

func (x *MetricIngestStatsList_MetricExemplar) GetMetricType() string

func (*MetricIngestStatsList_MetricExemplar) GetServiceName 

func (x *MetricIngestStatsList_MetricExemplar) GetServiceName() string

func (*MetricIngestStatsList_MetricExemplar) ProtoMessage 

func (*MetricIngestStatsList_MetricExemplar) ProtoMessage()

func (*MetricIngestStatsList_MetricExemplar) ProtoReflect 

func (x *MetricIngestStatsList_MetricExemplar) ProtoReflect() protoreflect.Message

func (*MetricIngestStatsList_MetricExemplar) Reset 

func (x *MetricIngestStatsList_MetricExemplar) Reset()

func (*MetricIngestStatsList_MetricExemplar) String 

func (x *MetricIngestStatsList_MetricExemplar) String() string

type MetricStats 

type MetricStats struct {
	MetricName          string       `protobuf:"bytes,1,opt,name=metricName,proto3" json:"metricName,omitempty"`
	ServiceName         string       `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	TagName             string       `protobuf:"bytes,3,opt,name=tagName,proto3" json:"tagName,omitempty"`
	Phase               Phase        `protobuf:"varint,4,opt,name=phase,proto3,enum=chqpb.Phase" json:"phase,omitempty"`
	CardinalityEstimate float64      `protobuf:"fixed64,5,opt,name=cardinalityEstimate,proto3" json:"cardinalityEstimate,omitempty"`
	Hll                 []byte       `protobuf:"bytes,6,opt,name=hll,proto3" json:"hll,omitempty"`
	Count               int64        `protobuf:"varint,7,opt,name=count,proto3" json:"count,omitempty"`
	ProcessorId         string       `protobuf:"bytes,8,opt,name=processorId,proto3" json:"processorId,omitempty"`
	Attributes          []*Attribute `protobuf:"bytes,9,rep,name=attributes,proto3" json:"attributes,omitempty"`
	TagScope            string       `protobuf:"bytes,10,opt,name=tagScope,proto3" json:"tagScope,omitempty"`
	MetricType          string       `protobuf:"bytes,11,opt,name=metricType,proto3" json:"metricType,omitempty"`
	CollectorId         string       `protobuf:"bytes,12,opt,name=collectorId,proto3" json:"collectorId,omitempty"`
	CustomerId          string       `protobuf:"bytes,13,opt,name=customerId,proto3" json:"customerId,omitempty"`
	TsHour              int64        `protobuf:"varint,14,opt,name=tsHour,proto3" json:"tsHour,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricStats) Descriptor deprecated 

func (*MetricStats) Descriptor() ([]byte, []int)

Deprecated: Use MetricStats.ProtoReflect.Descriptor instead.

func (*MetricStats) GetAttributes 

func (x *MetricStats) GetAttributes() []*Attribute

func (*MetricStats) GetCardinalityEstimate 

func (x *MetricStats) GetCardinalityEstimate() float64

func (*MetricStats) GetCollectorId added in v0.2.7 

func (x *MetricStats) GetCollectorId() string

func (*MetricStats) GetCount 

func (x *MetricStats) GetCount() int64

func (*MetricStats) GetCustomerId added in v0.2.7 

func (x *MetricStats) GetCustomerId() string

func (*MetricStats) GetHll 

func (x *MetricStats) GetHll() []byte

func (*MetricStats) GetMetricName 

func (x *MetricStats) GetMetricName() string

func (*MetricStats) GetMetricType 

func (x *MetricStats) GetMetricType() string

func (*MetricStats) GetPhase 

func (x *MetricStats) GetPhase() Phase

func (*MetricStats) GetProcessorId 

func (x *MetricStats) GetProcessorId() string

func (*MetricStats) GetServiceName 

func (x *MetricStats) GetServiceName() string

func (*MetricStats) GetTagName 

func (x *MetricStats) GetTagName() string

func (*MetricStats) GetTagScope 

func (x *MetricStats) GetTagScope() string

func (*MetricStats) GetTsHour added in v0.2.11 

func (x *MetricStats) GetTsHour() int64

func (*MetricStats) Key added in v0.2.17 

func (m *MetricStats) Key() string

func (*MetricStats) ProtoMessage 

func (*MetricStats) ProtoMessage()

func (*MetricStats) ProtoReflect 

func (x *MetricStats) ProtoReflect() protoreflect.Message

func (*MetricStats) Reset 

func (x *MetricStats) Reset()

func (*MetricStats) String 

func (x *MetricStats) String() string

type MetricStatsCache added in v0.2.14 

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

func NewMetricStatsCache added in v0.2.14 

func NewMetricStatsCache(capacity int,
	numBins uint16,
	flushInterval time.Duration,
	flushCallback FlushCallback[*MetricStatsWrapper],
	initializeCallback InitializeCallback[*MetricStatsWrapper],
	clock Clock) *MetricStatsCache

func (*MetricStatsCache) Record added in v0.2.14 

func (e *MetricStatsCache) Record(phase Phase, metricName, metricType, tagScope, tagName, serviceName, processorId, collectorId, customerId, tagValue string, attributes []*Attribute) error

func (*MetricStatsCache) RecordMetricStats added in v0.4.3 

func (e *MetricStatsCache) RecordMetricStats(metricStats *MetricStats) error

type MetricStatsReport 

type MetricStatsReport struct {
	SubmittedAt int64             `protobuf:"varint,1,opt,name=submittedAt,proto3" json:"submittedAt,omitempty"`
	Stats       []*MetricStats    `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
	Exemplars   []*MetricExemplar `protobuf:"bytes,3,rep,name=exemplars,proto3" json:"exemplars,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricStatsReport) Descriptor deprecated 

func (*MetricStatsReport) Descriptor() ([]byte, []int)

Deprecated: Use MetricStatsReport.ProtoReflect.Descriptor instead.

func (*MetricStatsReport) GetExemplars 

func (x *MetricStatsReport) GetExemplars() []*MetricExemplar

func (*MetricStatsReport) GetStats 

func (x *MetricStatsReport) GetStats() []*MetricStats

func (*MetricStatsReport) GetSubmittedAt 

func (x *MetricStatsReport) GetSubmittedAt() int64

func (*MetricStatsReport) ProtoMessage 

func (*MetricStatsReport) ProtoMessage()

func (*MetricStatsReport) ProtoReflect 

func (x *MetricStatsReport) ProtoReflect() protoreflect.Message

func (*MetricStatsReport) Reset 

func (x *MetricStatsReport) Reset()

func (*MetricStatsReport) String 

func (x *MetricStatsReport) String() string

type MetricStatsWrapper added in v0.2.7 

type MetricStatsWrapper struct {
	Stats *MetricStats
	Hll   hll.Union

	Dirty bool
	// contains filtered or unexported fields
}

func (*MetricStatsWrapper) GetEstimate added in v0.2.14 

func (m *MetricStatsWrapper) GetEstimate() (float64, error)

func (*MetricStatsWrapper) MergeWith added in v0.2.16 

func (m *MetricStatsWrapper) MergeWith(sketchBytes []byte) error

type MockClock added in v0.4.3 

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

func NewMockClock added in v0.4.3 

func NewMockClock(start time.Time) *MockClock

func (*MockClock) Advance added in v0.4.3 

func (m *MockClock) Advance(d time.Duration)

func (*MockClock) After added in v0.4.3 

func (m *MockClock) After(d time.Duration) <-chan time.Time

func (*MockClock) Now added in v0.4.3 

func (m *MockClock) Now() time.Time

type Phase 

type Phase int32
const (
	Phase_PASSTHROUGH        Phase = 0
	Phase_AGGREGATED         Phase = 1
	Phase_AGGREGATION_OUTPUT Phase = 2
	Phase_FILTERED           Phase = 3
	Phase_DRY_RUN_FILTERED   Phase = 4
	Phase_PRE                Phase = 5
	Phase_POST               Phase = 6
)

func (Phase) Descriptor 

func (Phase) Descriptor() protoreflect.EnumDescriptor

func (Phase) Enum 

func (x Phase) Enum() *Phase

func (Phase) EnumDescriptor deprecated 

func (Phase) EnumDescriptor() ([]byte, []int)

Deprecated: Use Phase.Descriptor instead.

func (Phase) Number 

func (x Phase) Number() protoreflect.EnumNumber

func (Phase) String 

func (x Phase) String() string

func (Phase) Type 

func (Phase) Type() protoreflect.EnumType

type RealClock added in v0.4.3 

type RealClock struct{}

func (RealClock) After added in v0.4.3 

func (RealClock) After(d time.Duration) <-chan time.Time

func (RealClock) Now added in v0.4.3 

func (RealClock) Now() time.Time

type SpanIngestStat 

type SpanIngestStat struct {
	Exemplar    []byte              `protobuf:"bytes,1,opt,name=exemplar,proto3" json:"exemplar,omitempty"`
	EventsCount int64               `protobuf:"varint,2,opt,name=eventsCount,proto3" json:"eventsCount,omitempty"`
	SizeBytes   int64               `protobuf:"varint,3,opt,name=sizeBytes,proto3" json:"sizeBytes,omitempty"`
	Key         *SpanIngestStat_Key `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanIngestStat) Descriptor deprecated 

func (*SpanIngestStat) Descriptor() ([]byte, []int)

Deprecated: Use SpanIngestStat.ProtoReflect.Descriptor instead.

func (*SpanIngestStat) GetEventsCount 

func (x *SpanIngestStat) GetEventsCount() int64

func (*SpanIngestStat) GetExemplar 

func (x *SpanIngestStat) GetExemplar() []byte

func (*SpanIngestStat) GetKey 

func (x *SpanIngestStat) GetKey() *SpanIngestStat_Key

func (*SpanIngestStat) GetSizeBytes 

func (x *SpanIngestStat) GetSizeBytes() int64

func (*SpanIngestStat) ProtoMessage 

func (*SpanIngestStat) ProtoMessage()

func (*SpanIngestStat) ProtoReflect 

func (x *SpanIngestStat) ProtoReflect() protoreflect.Message

func (*SpanIngestStat) Reset 

func (x *SpanIngestStat) Reset()

func (*SpanIngestStat) String 

func (x *SpanIngestStat) String() string

type SpanIngestStat_Key 

type SpanIngestStat_Key struct {
	Service     string       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Fingerprint int64        `protobuf:"varint,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	TsHour      int64        `protobuf:"varint,3,opt,name=tsHour,proto3" json:"tsHour,omitempty"`
	Attributes  []*Attribute `protobuf:"bytes,4,rep,name=attributes,proto3" json:"attributes,omitempty"`
	CustomerId  string       `protobuf:"bytes,5,opt,name=customerId,proto3" json:"customerId,omitempty"`
	PhaseType   string       `protobuf:"bytes,6,opt,name=phaseType,proto3" json:"phaseType,omitempty"`
	ProcessorId string       `protobuf:"bytes,7,opt,name=processorId,proto3" json:"processorId,omitempty"`
	CollectorId string       `protobuf:"bytes,8,opt,name=collectorId,proto3" json:"collectorId,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanIngestStat_Key) Descriptor deprecated 

func (*SpanIngestStat_Key) Descriptor() ([]byte, []int)

Deprecated: Use SpanIngestStat_Key.ProtoReflect.Descriptor instead.

func (*SpanIngestStat_Key) GetAttributes 

func (x *SpanIngestStat_Key) GetAttributes() []*Attribute

func (*SpanIngestStat_Key) GetCollectorId 

func (x *SpanIngestStat_Key) GetCollectorId() string

func (*SpanIngestStat_Key) GetCustomerId 

func (x *SpanIngestStat_Key) GetCustomerId() string

func (*SpanIngestStat_Key) GetFingerprint 

func (x *SpanIngestStat_Key) GetFingerprint() int64

func (*SpanIngestStat_Key) GetPhaseType 

func (x *SpanIngestStat_Key) GetPhaseType() string

func (*SpanIngestStat_Key) GetProcessorId 

func (x *SpanIngestStat_Key) GetProcessorId() string

func (*SpanIngestStat_Key) GetService 

func (x *SpanIngestStat_Key) GetService() string

func (*SpanIngestStat_Key) GetTsHour 

func (x *SpanIngestStat_Key) GetTsHour() int64

func (*SpanIngestStat_Key) Hash 

func (key *SpanIngestStat_Key) Hash() uint64

func (*SpanIngestStat_Key) ProtoMessage 

func (*SpanIngestStat_Key) ProtoMessage()

func (*SpanIngestStat_Key) ProtoReflect 

func (x *SpanIngestStat_Key) ProtoReflect() protoreflect.Message

func (*SpanIngestStat_Key) Reset 

func (x *SpanIngestStat_Key) Reset()

func (*SpanIngestStat_Key) String 

func (x *SpanIngestStat_Key) String() string

type SpanIngestStatsList 

type SpanIngestStatsList struct {
	Stats []*SpanIngestStat `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*SpanIngestStatsList) Descriptor deprecated 

func (*SpanIngestStatsList) Descriptor() ([]byte, []int)

Deprecated: Use SpanIngestStatsList.ProtoReflect.Descriptor instead.

func (*SpanIngestStatsList) GetStats 

func (x *SpanIngestStatsList) GetStats() []*SpanIngestStat

func (*SpanIngestStatsList) ProtoMessage 

func (*SpanIngestStatsList) ProtoMessage()

func (*SpanIngestStatsList) ProtoReflect 

func (x *SpanIngestStatsList) ProtoReflect() protoreflect.Message

func (*SpanIngestStatsList) Reset 

func (x *SpanIngestStatsList) Reset()

func (*SpanIngestStatsList) String 

func (x *SpanIngestStatsList) String() string

type StatsCache added in v0.4.3 

type StatsCache[T any] struct {
	// contains filtered or unexported fields
}

func NewStatsCache added in v0.4.3 

func NewStatsCache[T any](capacity int,
	numBins uint16,
	expiry time.Duration,
	flushCallback FlushCallback[T],
	initializeCallback InitializeCallback[T],
	clock Clock) *StatsCache[T]

func (*StatsCache[T]) Close added in v0.4.3 

func (b *StatsCache[T]) Close()

Close stops the cleanup goroutine

func (*StatsCache[T]) Compute added in v0.4.3 

func (b *StatsCache[T]) Compute(tsHour int64, key string, entryUpdater func(existing T) error) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.