netstorage

Documentation

Index

• func Init(addrs []string, hashSeed uint64)
• func MustStop()
• 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) GetLocalAuthToken(at *auth.Token) *auth.Token
  • func (ctx *InsertCtx) GetStorageNodeIdx(at *auth.Token, labels []prompb.Label) int
  • func (ctx *InsertCtx) Reset()
  • func (ctx *InsertCtx) SortLabelsIfNeeded()
  • func (ctx *InsertCtx) WriteDataPoint(at *auth.Token, labels []prompb.Label, timestamp int64, value float64) error
  • func (ctx *InsertCtx) WriteDataPointExt(storageNodeIdx int, metricNameRaw []byte, timestamp int64, value float64) error

Functions

func Init

func Init(addrs []string, hashSeed uint64)

Init initializes vmstorage nodes' connections to the given addrs.

hashSeed is used for changing the distribution of input time series among addrs.

Call MustStop when the initialized vmstorage connections are no longer needed.

func MustStop

func MustStop()

MustStop stops netstorage.

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        sortedLabels
	MetricNameBuf []byte
	// contains filtered or unexported fields
}

InsertCtx is a generic context for inserting data.

InsertCtx.Reset must be called before the first usage.

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 ctx.Labels.

func (*InsertCtx) FlushBufs

func (ctx *InsertCtx) FlushBufs() error

FlushBufs flushes ctx bufs to remote storage nodes.

func (*InsertCtx) GetLocalAuthToken

func (ctx *InsertCtx) GetLocalAuthToken(at *auth.Token) *auth.Token

GetLocalAuthToken obtains auth.Token from context labels vm_account_id and vm_project_id if at is nil.

At is returned as is if it isn't nil.

The vm_account_id and vm_project_id labels are automatically removed from the ctx.

func (*InsertCtx) GetStorageNodeIdx

func (ctx *InsertCtx) GetStorageNodeIdx(at *auth.Token, labels []prompb.Label) int

GetStorageNodeIdx returns storage node index for the given at and labels.

The returned index must be passed to WriteDataPoint.

func (*InsertCtx) Reset

func (ctx *InsertCtx) Reset()

Reset resets ctx.

func (*InsertCtx) SortLabelsIfNeeded

func (ctx *InsertCtx) SortLabelsIfNeeded()

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

func (*InsertCtx) WriteDataPoint

func (ctx *InsertCtx) WriteDataPoint(at *auth.Token, labels []prompb.Label, timestamp int64, value float64) error

WriteDataPoint writes (timestamp, value) data point with the given at and labels to ctx buffer.

func (*InsertCtx) WriteDataPointExt

func (ctx *InsertCtx) WriteDataPointExt(storageNodeIdx int, metricNameRaw []byte, timestamp int64, value float64) error

WriteDataPointExt writes the given metricNameRaw with (timestmap, value) to ctx buffer with the given storageNodeIdx.