chunks

type CacheStats struct {
	Hits   atomic.Int64
	Misses atomic.Int64
	// contains filtered or unexported fields
}

type Chunk struct {
	Header Header
	Data   ChunkData
}

type ChunkData struct {
	Id              ChunkId
	Timestamp       time.Time
	Keys            []string
	IndexedKeyFrame IndexedKeyFrame
	Diffs           []DiffEvent
	// contains filtered or unexported fields
}

type ChunkId string

type Diff []byte

type DiffEvent struct {
	Timestamp time.Time
	KeyIndex  int32
	Diff      Diff
}

type Event struct {
	Timestamp time.Time
	Key       string
	Data      []byte
	Delete    bool
}

type Header struct {
	LastUpdate time.Time
	Id         ChunkId
	Prev       ChunkId
	Next       ChunkId
	Min        time.Time
	Max        time.Time
}

type Index interface {
	UpdateIndex(header Header) error

	GetStateAt(timestamp time.Time) (map[string][]byte, error)
	GetMinTime() time.Time
	GetMaxTime() time.Time
	GetHeaders() []Header
	// contains filtered or unexported methods
}

type IndexedKVPair struct {
	KeyIndex int32
	Data     []byte
}

type IndexedKeyFrame []IndexedKVPair

type KVPair struct {
	Key  string
	Data []byte
}

type KeyFrame []KVPair