cache

type CS struct {
	Chunks          []*Chunk
	CurrentChunkPos int

	sync.RWMutex
	// contains filtered or unexported fields
}

type CacheSection struct {
	KeepMinutes      int `yaml:"keepMinutes"`
	SpanInSeconds    int `yaml:"spanInSeconds"`
	NumOfChunks      int `yaml:"numOfChunks"`
	DoCleanInMinutes int `yaml:"doCleanInMinutes"`
	FlushDiskStepMs  int `yaml:"flushDiskStepMs"`
}

type Chunk struct {
	tsz.Series
	FirstTs   uint32
	LastTs    uint32
	NumPoints uint32
	Closed    bool
}

type ChunksSlot struct {
	sync.RWMutex
	Data []map[string][]*Chunk
	Size int
}

type Iter struct {
	*tsz.Iter
}

type Point struct {
	Key       string  `msg:"key"`
	Timestamp int64   `msg:"timestamp"`
	Value     float64 `msg:"value"`
}