common

Documentation

Index

• func PutInsertCtx(ctx *InsertCtx)
• 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) WriteDataPoint(prefix []byte, labels []prompb.Label, timestamp int64, value float64) error
  • func (ctx *InsertCtx) WriteDataPointExt(metricNameRaw []byte, labels []prompb.Label, timestamp int64, value float64) ([]byte, error)

Functions

func PutInsertCtx

func PutInsertCtx(ctx *InsertCtx)

PutInsertCtx returns ctx to the pool.

ctx cannot be used after the call.

Types

type InsertCtx

type InsertCtx struct {
	Labels []prompb.Label
	// 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) WriteDataPoint

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

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

func (*InsertCtx) WriteDataPointExt

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

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

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