store

Documentation

Overview

Package cache implements a cache for time series data.

Index

• type TimePoint
• type TimeStore
  • func NewCMAStore() TimeStore
  • func NewGCStore(store TimeStore, bufferDuration time.Duration) TimeStore
  • func NewTimeStore() TimeStore

Types

type TimePoint

type TimePoint struct {
	Timestamp time.Time
	Value     interface{}
}

TimePoint is a single point of a timeseries, representing a time-value pair.

type TimeStore

type TimeStore interface {
	// Put stores a TimePoint to the TimeStore. Returns error upon failure.
	// Ignores zero timestamps.
	Put(tp TimePoint) error
	// Get returns a slice of elements that were previously stored with timestamps
	// between 'start' and 'end'. 'start' is expected to be before 'end'.
	// If 'start' is zero, it returns all the elements up until 'end'.
	// If 'end' is zero, it returns all the elements from 'start'.
	// If both 'start' and 'end' are zero, it returns all the elements in the store.
	// Note: Returns data in reverse chronological order -
	// Latest element will be the first element in the slice.
	Get(start, end time.Time) []TimePoint
	// Delete removes all elements that were previously stored with timestamps
	// between 'start' and 'end'.
	Delete(start, end time.Time) error
}

TimeStore represents a timeseries storage. Implementations are expected to be thread safe.

func NewCMAStore

func NewCMAStore() TimeStore

func NewGCStore

func NewGCStore(store TimeStore, bufferDuration time.Duration) TimeStore

func NewTimeStore

func NewTimeStore() TimeStore