writer

Documentation

Index

• Variables
• func Init(opts []config.WriterOptions, globalOpt config.WriterGlobalOpt) error
• type SafeList
  • func NewSafeList() *SafeList
  • func (sl *SafeList) Len() int
  • func (sl *SafeList) PopBack(max int) []*prompb.TimeSeries
  • func (sl *SafeList) PushFront(v interface{}) *list.Element
  • func (sl *SafeList) PushFrontBatch(vs []interface{})
  • func (sl *SafeList) RemoveAll()
• type SafeListLimited
  • func NewSafeListLimited(maxSize int) *SafeListLimited
  • func (sll *SafeListLimited) Len() int
  • func (sll *SafeListLimited) PopBack(max int) []*prompb.TimeSeries
  • func (sll *SafeListLimited) PushFront(v interface{}) bool
  • func (sll *SafeListLimited) PushFrontBatch(vs []interface{}) bool
  • func (sll *SafeListLimited) RemoveAll()
• type WriterType
  • func (w WriterType) Post(req []byte, headers ...map[string]string) error
  • func (w WriterType) Write(cluster string, index int, items []*prompb.TimeSeries, ...)
• type WritersType
  • func NewWriters() WritersType
  • func (ws *WritersType) PushSample(ident string, v interface{}, clusters ...string)
  • func (ws *WritersType) Put(name string, writer WriterType)
  • func (ws *WritersType) StartConsumer(index int, ch *SafeListLimited, clusterName string)

Variables

var Writers = NewWriters()

Functions

func Init

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

Types

type SafeList

type SafeList struct {
	sync.RWMutex
	L *list.List
}

func NewSafeList

func NewSafeList() *SafeList

func (*SafeList) Len

func (sl *SafeList) Len() int

func (*SafeList) PopBack

func (sl *SafeList) PopBack(max int) []*prompb.TimeSeries

func (*SafeList) PushFront

func (sl *SafeList) PushFront(v interface{}) *list.Element

func (*SafeList) PushFrontBatch

func (sl *SafeList) PushFrontBatch(vs []interface{})

func (*SafeList) RemoveAll

func (sl *SafeList) RemoveAll()

type SafeListLimited

type SafeListLimited struct {
	SL *SafeList
	// contains filtered or unexported fields
}

SafeList with Limited Size

func NewSafeListLimited

func NewSafeListLimited(maxSize int) *SafeListLimited

func (*SafeListLimited) Len

func (sll *SafeListLimited) Len() int

func (*SafeListLimited) PopBack

func (sll *SafeListLimited) PopBack(max int) []*prompb.TimeSeries

func (*SafeListLimited) PushFront

func (sll *SafeListLimited) PushFront(v interface{}) bool

func (*SafeListLimited) PushFrontBatch

func (sll *SafeListLimited) PushFrontBatch(vs []interface{}) bool

func (*SafeListLimited) RemoveAll

func (sll *SafeListLimited) RemoveAll()

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(cluster string, 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{}, clusters ...string)

func (*WritersType) Put

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

func (*WritersType) StartConsumer

func (ws *WritersType) StartConsumer(index int, ch *SafeListLimited, clusterName string)