util

Documentation

Index

• func ParseHostPort(hp string) (host string, port int, err error)
• func SparseFromBytes(b []byte) (*intsets.Sparse, error)
• func SparseToBytes(s *intsets.Sparse) ([]byte, error)
• func ToWriteRequest(items []BatchItem) (sampleCount int, data []byte, err error)
• type BatchItem
• type Batcher
  • func NewBatcher(maxCount int, maxWait time.Duration, outChan chan []BatchItem) *Batcher
  • func (b *Batcher) Enqueue(metric model.Metric, samples []model.Sample)
  • func (b *Batcher) Start()
  • func (b *Batcher) Stop()

Functions

func ParseHostPort

func ParseHostPort(hp string) (host string, port int, err error)

func SparseFromBytes

func SparseFromBytes(b []byte) (*intsets.Sparse, error)

SparseFromBytes deserializes the given byte array into a Sparse object.

func SparseToBytes

func SparseToBytes(s *intsets.Sparse) ([]byte, error)

SparseToBytes serializes a Sparse object to a byte array.

func ToWriteRequest

func ToWriteRequest(items []BatchItem) (sampleCount int, data []byte, err error)

Types

type BatchItem

type BatchItem struct {
	Metric  model.Metric
	Samples []model.Sample
}

type Batcher

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

func NewBatcher

func NewBatcher(maxCount int, maxWait time.Duration, outChan chan []BatchItem) *Batcher

func (*Batcher) Enqueue

func (b *Batcher) Enqueue(metric model.Metric, samples []model.Sample)

func (*Batcher) Start

func (b *Batcher) Start()

func (*Batcher) Stop

func (b *Batcher) Stop()