boltTime

type BoltTime struct {
	DB *bolt.DB
	// contains filtered or unexported fields
}

type Entry struct {
	Time  time.Time
	Value []byte
}

type TimeBucket interface {
	Put(bucket string, entry Entry) error

	Get(t time.Time) []Entry
	GetSince(t time.Time) []Entry
	GetBefore(t time.Time) []Entry
	GetNewestN(n int) []Entry
	GetOldestN(n int) []Entry

	Delete(t time.Time) error
	DeleteSince(t time.Time) error
	DeleteBefore(t time.Time) error
	DeleteNewestN(n int) error
	DeleteOldestN(n int) error
}

type TimeStore interface {
	Put(bucket string, entry Entry) error
	GetSince(bucket string, t time.Time) ([]Entry, error)
	DeleteBefore(bucket string, t time.Time) error
	GetLatestN(bucket string, n int) ([]Entry, error)
}