file

type File struct {
	// contains filtered or unexported fields
}

type Filter func(record.Record) bool

type Query interface {
	HasNext() bool
	Next() record.Record
}

type QueryBuilder interface {
	// Today sets the search range to span from Local Midnight for 24 hours
	Today() QueryBuilder
	// TodayUTC sets the search range to span from Midnight UTC for 24 hours
	TodayUTC() QueryBuilder
	// Yesterday sets the search range to span yesterday in local time
	Yesterday() QueryBuilder
	// YesterdayUTC sets the search range to span yesterday in UTC
	YesterdayUTC() QueryBuilder
	// DayFrom sets the search range to span for 24 hours from the specified time
	DayFrom(from time.Time) QueryBuilder
	// DayTo sets the search range to span for 24 hours up until the specified time
	DayTo(to time.Time) QueryBuilder
	// Between sets the time range of the query
	Between(from, to time.Time) QueryBuilder
	// Filter sets the filter to use. If one already exists then this will be or'ed with it.
	Filter(Filter) QueryBuilder
	// Build the final Query
	Build() Query
}

type Store interface {
	// Append a record to a metric
	Append(metric string, rec record.Record) error
	AppendBulk(metric string, rec record.Record) error
	Sync(metric string) error
	// GetRecord returns the numbered record for a metric on a specific date
	GetRecord(metric string, date time.Time, num int) (record.Record, error)
	// NumRecords returns the number of metrics for a metric on a specific date
	NumRecords(metric string, date time.Time) (int, error)
	// Query returns a builder to build a query against a metric
	Query(metric string) QueryBuilder
}