appender

Documentation

Index

• Constants
• type Cache
  • func NewCache(max int) *Cache
  • func (c *Cache) Add(key uint64, value *MetricState)
  • func (c *Cache) Get(key uint64) (value *MetricState, ok bool)
  • func (c *Cache) ResetMetric(key uint64)
• type ElasticQueue
  • func NewElasticQueue() *ElasticQueue
  • func (eq *ElasticQueue) IsEmpty() bool
  • func (eq *ElasticQueue) Length() int
  • func (eq *ElasticQueue) Pop() *MetricState
  • func (eq *ElasticQueue) PopN(length int) []*MetricState
  • func (eq *ElasticQueue) Push(val *MetricState) int
  • func (eq *ElasticQueue) Rotate(val *MetricState) (*MetricState, int)
• type MetricState
• type MetricsCache
  • func NewMetricsCache(container v3io.Container, logger logger.Logger, cfg *config.V3ioConfig, ...) *MetricsCache
  • func (mc *MetricsCache) Add(lset utils.LabelsIfc, t int64, v interface{}) (uint64, error)
  • func (mc *MetricsCache) AddFast(ref uint64, t int64, v interface{}) error
  • func (mc *MetricsCache) Close()
  • func (mc *MetricsCache) Start() error
  • func (mc *MetricsCache) WaitForCompletion(timeout time.Duration) (int, error)

Constants

const ListSize = 256

Types

type Cache

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

Cache is an LRU cache. It is not safe for concurrent access.

func NewCache

func NewCache(max int) *Cache

func (*Cache) Add

func (c *Cache) Add(key uint64, value *MetricState)

Add adds a value to the cache.

func (*Cache) Get

func (c *Cache) Get(key uint64) (value *MetricState, ok bool)

Get looks up a key's value from the cache.

func (*Cache) ResetMetric

func (c *Cache) ResetMetric(key uint64)

type ElasticQueue

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

func NewElasticQueue

func NewElasticQueue() *ElasticQueue

Elastic Queue, a fifo queue with dynamic resize

func (*ElasticQueue) IsEmpty

func (eq *ElasticQueue) IsEmpty() bool

Is the queue empty

func (*ElasticQueue) Length

func (eq *ElasticQueue) Length() int

Number of elements in the queue

func (*ElasticQueue) Pop

func (eq *ElasticQueue) Pop() *MetricState

func (*ElasticQueue) PopN

func (eq *ElasticQueue) PopN(length int) []*MetricState

func (*ElasticQueue) Push

func (eq *ElasticQueue) Push(val *MetricState) int

func (*ElasticQueue) Rotate

func (eq *ElasticQueue) Rotate(val *MetricState) (*MetricState, int)

Atomic rotate, push a value to the tail and pop one from the head

type MetricState

type MetricState struct {
	sync.RWMutex

	Lset utils.LabelsIfc
	// contains filtered or unexported fields
}

to add, rollups policy (cnt, sum, min/max, sum^2) + interval , or policy in per name label

type MetricsCache

type MetricsCache struct {
	NameLabelMap map[string]bool // temp store all lable names
	// contains filtered or unexported fields
}

store the state and metadata for all the metrics

func NewMetricsCache

func NewMetricsCache(container v3io.Container, logger logger.Logger, cfg *config.V3ioConfig,
	partMngr *partmgr.PartitionManager) *MetricsCache

func (*MetricsCache) Add

func (mc *MetricsCache) Add(lset utils.LabelsIfc, t int64, v interface{}) (uint64, error)

First time add time & value to metric (by label set)

func (*MetricsCache) AddFast

func (mc *MetricsCache) AddFast(ref uint64, t int64, v interface{}) error

fast Add to metric (by refID)

func (*MetricsCache) Close

func (mc *MetricsCache) Close()

func (*MetricsCache) Start

func (mc *MetricsCache) Start() error

func (*MetricsCache) WaitForCompletion

func (mc *MetricsCache) WaitForCompletion(timeout time.Duration) (int, error)