retrieval

Documentation

Index

• func LabelsToResource(labels labels.Labels) *resource_pb.Resource
• func ReadProgressFile(dir string) (offset int, err error)
• func SaveProgressFile(dir string, offset int) error
• type Appender
• type MetadataGetter
• type PrometheusReader
  • func NewPrometheusReader(logger log.Logger, walDirectory string, tailer tail.WalTailer, ...) *PrometheusReader
  • func (r *PrometheusReader) CurrentSegment() int
  • func (r *PrometheusReader) Next()
  • func (r *PrometheusReader) Run(ctx context.Context, startOffset int) error
• type SizedMetric
  • func NewSizedMetric(metric *metric_pb.Metric, count, size int) SizedMetric
  • func (s SizedMetric) Count() int
  • func (s SizedMetric) Metric() *metric_pb.Metric
  • func (s SizedMetric) Size() int

Functions

func LabelsToResource

func LabelsToResource(labels labels.Labels) *resource_pb.Resource

func ReadProgressFile

func ReadProgressFile(dir string) (offset int, err error)

ReadProgressFile reads the progress file in the given directory and returns the saved offset.

func SaveProgressFile

func SaveProgressFile(dir string, offset int) error

SaveProgressFile saves a progress file with the given offset in directory.

Types

type Appender

type Appender interface {
	Append(s SizedMetric)
}

Appender appends a time series with exactly one data point.

type MetadataGetter

type MetadataGetter interface {
	Get(ctx context.Context, job, instance, metric string) (*config.MetadataEntry, error)
}

type PrometheusReader

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

func NewPrometheusReader

func NewPrometheusReader(
	logger log.Logger,
	walDirectory string,
	tailer tail.WalTailer,
	filters [][]*labels.Matcher,
	metricRenames map[string]string,
	metadataGetter MetadataGetter,
	appender Appender,
	metricsPrefix string,
	maxPointAge time.Duration,
	scrapeConfig []*promconfig.ScrapeConfig,
	failingReporter common.FailingReporter,
	leaderCandidate leader.Candidate,
) *PrometheusReader

NewPrometheusReader is the PrometheusReader constructor

func (*PrometheusReader) CurrentSegment

func (r *PrometheusReader) CurrentSegment() int

func (*PrometheusReader) Next

func (r *PrometheusReader) Next()

func (*PrometheusReader) Run

func (r *PrometheusReader) Run(ctx context.Context, startOffset int) error

Run starts the main read loop, that reads the prometheus' WAL log to find and parse Series and Samples.

Series read are used to update an internal time series cache, containing metadata, labels and reset times.

Samples read are transformed by the retrieval.sampleBuilder into OTLP metrics and forwarded to the PrometheusReader.appender, generally a otlp.QueueManager.

type SizedMetric

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

SizedMetric encapsulates a small number of points w/ precomputed approximate size.

func NewSizedMetric

func NewSizedMetric(metric *metric_pb.Metric, count, size int) SizedMetric

func (SizedMetric) Count

func (s SizedMetric) Count() int

func (SizedMetric) Metric

func (s SizedMetric) Metric() *metric_pb.Metric

func (SizedMetric) Size

func (s SizedMetric) Size() int