writer

Documentation

Index

• func InitWriters() error
• func WriteSamples(samples []*types.Sample)
• func WriteTimeSeries(timeSeries []prompb.TimeSeries)
• type Snapshot
  • func QueueMetrics() *Snapshot
• type Writer
  • func (w Writer) Write(items []prompb.TimeSeries)
• type Writers
  • func (ws *Writers) LoopRead()

Functions

func InitWriters

func InitWriters() error

func WriteSamples

func WriteSamples(samples []*types.Sample)

WriteSamples convert samples to []prompb.TimeSeries and batch write to queue

func WriteTimeSeries

func WriteTimeSeries(timeSeries []prompb.TimeSeries)

WriteTimeSeries write prompb.TimeSeries to all writers

Types

type Snapshot

type Snapshot struct {
	FailCount  uint64
	FailTotal  uint64
	TotalCount uint64

	QueueSize uint64
}

Writers manage all writers and metric queue

func QueueMetrics

func QueueMetrics() *Snapshot

type Writer

type Writer struct {
	Opts   config.WriterOption
	Client api.Client
}

func (Writer) Write

func (w Writer) Write(items []prompb.TimeSeries)

type Writers

type Writers struct {
	sync.Mutex

	Snapshot
	// contains filtered or unexported fields
}

Writers manage all writers and metric queue

func (*Writers) LoopRead

func (ws *Writers) LoopRead()