database

type Database struct {
	Version      uint32
	Segments     []Segment
	Current      uint32
	TopicLookup  []string
	SchemaLookup []schema.Object
	TopicCount   int
	STime        time.Time // Last serialize time
	Name         string    // <-- We do not save to disk, starting here
	Path         string
	// contains filtered or unexported fields
}

type Datum struct {
	Delta   time.Duration
	TopicID int
	Data    []byte
}

type Entries []Entry

type Entry struct {
	Time   time.Time `json:"time"`
	Topic  string    `json:"topic"`
	Schema string    `json:"schema"`
	Data   []byte    `json:"data"`
}

type Filter func(Entries) Entries

type Filters []Filter

type Query struct {
	Quantifier     string
	Topics         []string
	Range          *TimeRange // nil means entire history (no time range)
	RangeSemantics string     // none, before, since, between
}

type Result struct {
	Data Entries
}

type Segment struct {
	HeadTime time.Time
	Series   [SegmentSize]Datum
	Size     int
}

type Stats struct {
	Segments      int
	TopicCount    int
	SerializeTime time.Time
}

type TimeRange struct {
	Start time.Time
	End   time.Time
}

type WriteAheadLog struct {
	LogPath string
}