internal

Documentation

Index

• func CreateResource(job, instance string, serviceDiscoveryLabels labels.Labels) pcommon.Resource
• func NewAppendable(sink consumer.Metrics, set receiver.CreateSettings, gcInterval time.Duration, ...) (storage.Appendable, error)
• func NewZapToGokitLogAdapter(logger *zap.Logger) gokitLog.Logger
• type JobsMap
  • func NewJobsMap(gcInterval time.Duration) *JobsMap
• type MetricsAdjuster
  • func NewInitialPointAdjuster(logger *zap.Logger, gcInterval time.Duration, useCreatedMetric bool) MetricsAdjuster
  • func NewStartTimeMetricAdjuster(logger *zap.Logger, startTimeMetricRegex *regexp.Regexp) MetricsAdjuster

Functions

func CreateResource

func CreateResource(job, instance string, serviceDiscoveryLabels labels.Labels) pcommon.Resource

CreateResource creates the resource data added to OTLP payloads.

func NewAppendable

func NewAppendable(
	sink consumer.Metrics,
	set receiver.CreateSettings,
	gcInterval time.Duration,
	useStartTimeMetric bool,
	startTimeMetricRegex *regexp.Regexp,
	useCreatedMetric bool,
	enableNativeHistograms bool,
	externalLabels labels.Labels,
	trimSuffixes bool) (storage.Appendable, error)

NewAppendable returns a storage.Appendable instance that emits metrics to the sink.

func NewZapToGokitLogAdapter

func NewZapToGokitLogAdapter(logger *zap.Logger) gokitLog.Logger

NewZapToGokitLogAdapter create an adapter for zap.Logger to gokitLog.Logger

Types

type JobsMap

type JobsMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

JobsMap maps from a job instance to a map of timeseries instances for the job.

func NewJobsMap

func NewJobsMap(gcInterval time.Duration) *JobsMap

NewJobsMap creates a new (empty) JobsMap.

type MetricsAdjuster

type MetricsAdjuster interface {
	AdjustMetrics(metrics pmetric.Metrics) error
}

func NewInitialPointAdjuster

func NewInitialPointAdjuster(logger *zap.Logger, gcInterval time.Duration, useCreatedMetric bool) MetricsAdjuster

NewInitialPointAdjuster returns a new MetricsAdjuster that adjust metrics' start times based on the initial received points.

func NewStartTimeMetricAdjuster

func NewStartTimeMetricAdjuster(logger *zap.Logger, startTimeMetricRegex *regexp.Regexp) MetricsAdjuster

NewStartTimeMetricAdjuster returns a new MetricsAdjuster that adjust metrics' start times based on a start time metric.