common

Documentation

Index

• func CheckStreamAggrConfig() error
• func InitStreamAggr()
• func MustStopStreamAggr()
• func PutInsertCtx(ctx *InsertCtx)
• func StartIngestionRateLimiter(maxIngestionRate int)
• func StopIngestionRateLimiter()
• type InsertCtx
  • func GetInsertCtx() *InsertCtx
  • func (ctx *InsertCtx) AddLabel(name, value string)
  • func (ctx *InsertCtx) AddLabelBytes(name, value []byte)
  • func (ctx *InsertCtx) ApplyRelabeling()
  • func (ctx *InsertCtx) FlushBufs() error
  • func (ctx *InsertCtx) Reset(rowsLen int)
  • func (ctx *InsertCtx) SortLabelsIfNeeded()
  • func (ctx *InsertCtx) TryPrepareLabels(hasRelabeling bool) bool
  • func (ctx *InsertCtx) WriteDataPoint(prefix []byte, labels []prompbmarshal.Label, timestamp int64, value float64) error
  • func (ctx *InsertCtx) WriteDataPointExt(metricNameRaw []byte, labels []prompbmarshal.Label, timestamp int64, ...) ([]byte, error)

Functions

func CheckStreamAggrConfig

func CheckStreamAggrConfig() error

CheckStreamAggrConfig checks config pointed by -stramaggr.config

func InitStreamAggr

func InitStreamAggr()

InitStreamAggr must be called after flag.Parse and before using the common package.

MustStopStreamAggr must be called when stream aggr is no longer needed.

func MustStopStreamAggr

func MustStopStreamAggr()

MustStopStreamAggr stops stream aggregators.

func PutInsertCtx

func PutInsertCtx(ctx *InsertCtx)

PutInsertCtx returns ctx to the pool.

ctx cannot be used after the call.

func StartIngestionRateLimiter

func StartIngestionRateLimiter(maxIngestionRate int)

StartIngestionRateLimiter starts ingestion rate limiter.

Ingestion rate limiter must be started before Init() call.

StopIngestionRateLimiter must be called before Stop() call in order to unblock all the callers to ingestion rate limiter. Otherwise deadlock may occur at Stop() call.

func StopIngestionRateLimiter

func StopIngestionRateLimiter()

StopIngestionRateLimiter stops ingestion rate limiter.

Types

type InsertCtx

type InsertCtx struct {
	Labels sortedLabels
	// contains filtered or unexported fields
}

InsertCtx contains common bits for data points insertion.

func GetInsertCtx

func GetInsertCtx() *InsertCtx

GetInsertCtx returns InsertCtx from the pool.

Call PutInsertCtx for returning it to the pool.

func (*InsertCtx) AddLabel

func (ctx *InsertCtx) AddLabel(name, value string)

AddLabel adds (name, value) label to ctx.Labels.

name and value must exist until ctx.Labels is used.

func (*InsertCtx) AddLabelBytes

func (ctx *InsertCtx) AddLabelBytes(name, value []byte)

AddLabelBytes adds (name, value) label to ctx.Labels.

name and value must exist until ctx.Labels is used.

func (*InsertCtx) ApplyRelabeling

func (ctx *InsertCtx) ApplyRelabeling()

ApplyRelabeling applies relabeling to ic.Labels.

func (*InsertCtx) FlushBufs

func (ctx *InsertCtx) FlushBufs() error

FlushBufs flushes buffered rows to the underlying storage.

func (*InsertCtx) Reset

func (ctx *InsertCtx) Reset(rowsLen int)

Reset resets ctx for future fill with rowsLen rows.

func (*InsertCtx) SortLabelsIfNeeded

func (ctx *InsertCtx) SortLabelsIfNeeded()

SortLabelsIfNeeded sorts labels if -sortLabels command-line flag is set

func (*InsertCtx) TryPrepareLabels

func (ctx *InsertCtx) TryPrepareLabels(hasRelabeling bool) bool

TryPrepareLabels prepares context labels to the ingestion

It returns false if timeseries should be skipped

func (*InsertCtx) WriteDataPoint

func (ctx *InsertCtx) WriteDataPoint(prefix []byte, labels []prompbmarshal.Label, timestamp int64, value float64) error

WriteDataPoint writes (timestamp, value) with the given prefix and labels into ctx buffer.

caller should invoke TryPrepareLabels before using this function if needed

func (*InsertCtx) WriteDataPointExt

func (ctx *InsertCtx) WriteDataPointExt(metricNameRaw []byte, labels []prompbmarshal.Label, timestamp int64, value float64) ([]byte, error)

WriteDataPointExt writes (timestamp, value) with the given metricNameRaw and labels into ctx buffer.

caller must invoke TryPrepareLabels before using this function

It returns metricNameRaw for the given labels if len(metricNameRaw) == 0.