writer

Documentation

Index

• Variables
• func Init(opts []Options, globalOpt GlobalOpt) error
• type GlobalOpt
• type Options
• type WriterType
  • func (w WriterType) Post(req []byte) error
  • func (w WriterType) Write(items []*prompb.TimeSeries)
• type WritersType
  • func NewWriters() WritersType
  • func (ws *WritersType) PushQueue(vs []interface{}) bool
  • func (ws *WritersType) Put(name string, writer WriterType)
  • func (ws *WritersType) Writes()

Variables

var Writers = NewWriters()

Functions

func Init

func Init(opts []Options, globalOpt GlobalOpt) error

Types

type GlobalOpt

type GlobalOpt struct {
	QueueMaxSize  int
	QueuePopSize  int
	SleepInterval int64
}

type Options

type Options struct {
	Name          string
	Url           string
	BasicAuthUser string
	BasicAuthPass string

	Timeout               int64
	DialTimeout           int64
	TLSHandshakeTimeout   int64
	ExpectContinueTimeout int64
	IdleConnTimeout       int64
	KeepAlive             int64

	MaxConnsPerHost     int
	MaxIdleConns        int
	MaxIdleConnsPerHost int
}

type WriterType

type WriterType struct {
	Opts   Options
	Client api.Client
}

func (WriterType) Post

func (w WriterType) Post(req []byte) error

func (WriterType) Write

func (w WriterType) Write(items []*prompb.TimeSeries)

type WritersType

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

func NewWriters

func NewWriters() WritersType

func (*WritersType) PushQueue

func (ws *WritersType) PushQueue(vs []interface{}) bool

func (*WritersType) Put

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

func (*WritersType) Writes

func (ws *WritersType) Writes()