storage

type ErrorInvalidSearch struct{}

type ErrorNotFound struct {
	Key string
}

type ExpiryHandler func(key string, elt api.Element)

type InvalidSearch interface {
	InvalidSearch()
}

type KeyNotFound interface {
	NotFound()
}

type Manager interface {
	io.Closer
	Searcher
	Writer
}

type Options struct {
	// MaxAge time series elements older than this will be discarded.
	MaxAge time.Duration
	// WorkerCount is the number of goroutines that process incoming messages.
	WorkerCount int
	// ChannelBufferSize is the number of jobs that can be buffered in the jobs channel to improve throughput and async processing.
	ChannelBufferSize int
	// OnExpire is an optional method that is called when a time series element expires. This could be used to
	// aggregate expiring elements into courser granularity or to write to persistent storage.
	OnExpire ExpiryHandler
	// MessageCounter keeps tally of the number of messages that have arrived.
	MessageCounter metrics.Counter
}

type Searcher interface {
	Search(key string, first, last uint64) ([]api.Element, error)
}

type Writer interface {
	Write(key string, ts time.Time, data []byte)
}