common

Documentation

Index

• func ReadLinesBlock(r io.Reader, dstBuf, tailBuf []byte) ([]byte, []byte, error)
• type InsertCtx
  • func (ctx *InsertCtx) AddLabel(name, value string)
  • func (ctx *InsertCtx) FlushBufs() error
  • func (ctx *InsertCtx) Reset(rowsLen int)
  • func (ctx *InsertCtx) WriteDataPoint(prefix []byte, labels []prompb.Label, timestamp int64, value float64)
  • func (ctx *InsertCtx) WriteDataPointExt(metricNameRaw []byte, labels []prompb.Label, timestamp int64, value float64) []byte

Functions

func ReadLinesBlock

func ReadLinesBlock(r io.Reader, dstBuf, tailBuf []byte) ([]byte, []byte, error)

ReadLinesBlock reads a block of lines delimited by '\n' from tailBuf and r into dstBuf.

Trailing chars after the last newline are put into tailBuf.

Returns (dstBuf, tailBuf).

Types

type InsertCtx

type InsertCtx struct {
	Labels []prompb.Label
	// contains filtered or unexported fields
}

InsertCtx contains common bits for data points insertion.

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) 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)

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

func (*InsertCtx) WriteDataPointExt

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

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

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