writer

Documentation

Index

• Variables
• func Init(opts []config.WriterOptions, globalOpt config.WriterGlobalOpt) error
• type WriterType
  • func (w WriterType) Post(req []byte, headers ...map[string]string) error
  • func (w WriterType) Write(index int, items []*prompb.TimeSeries, headers ...map[string]string)
• type WritersType
  • func NewWriters() WritersType
  • func (ws *WritersType) PushSample(ident string, v interface{})
  • func (ws *WritersType) Put(name string, writer WriterType)
  • func (ws *WritersType) StartConsumer(index int, ch chan *prompb.TimeSeries)

Variables

var Writers = NewWriters()

Functions

func Init

func Init(opts []config.WriterOptions, globalOpt config.WriterGlobalOpt) error

Types

type WriterType

type WriterType struct {
	Opts   config.WriterOptions
	Client api.Client
}

func (WriterType) Post

func (w WriterType) Post(req []byte, headers ...map[string]string) error

func (WriterType) Write

func (w WriterType) Write(index int, items []*prompb.TimeSeries, headers ...map[string]string)

type WritersType

type WritersType struct {
	// contains filtered or unexported fields
}

func NewWriters

func NewWriters() WritersType

func (*WritersType) PushSample

func (ws *WritersType) PushSample(ident string, v interface{})

PushSample Push one sample to chan, hash by ident @Author: quzhihao

func (*WritersType) Put

func (ws *WritersType) Put(name string, writer WriterType)

func (*WritersType) StartConsumer

func (ws *WritersType) StartConsumer(index int, ch chan *prompb.TimeSeries)

StartConsumer every ident channel has a consumer, start it @Author: quzhihao