storage

type AFile struct {
	Prefix      string
	Hour        hour.Hour
	Hash        Hash
	Compression config.Compression
}

type AStore interface {
	WritableAStore

	ReadableAStore

	Delete(aFile AFile) error

	fmt.Stringer
}

type DFile struct {
	Prefix  string
	Postfix string
	Time    time.Time
	Hash    Hash
}

type DStore interface {
	ReadableDStore
	WritableDStore

	// Lists all hours for which there is at least 1 DFile whose time is within that hour
	ListNonEmptyHours() ([]hour.Hour, error)

	ListInHour(hour hour.Hour) ([]DFile, error)

	Delete(dFile DFile) error
}

type DStoreFactory interface {
	New() (DStore, func())
}

type Hash string

type ReadableAStore interface {
	// TODO: audit all usages of this to ensure the reader is closed
	// TODO: ensure all implementers return nil on error
	Get(aFile AFile) (io.ReadCloser, error)

	// Searches for  all hours for which there is at least 1 AFile whose time is within that hour
	Search(startOpt *hour.Hour, end hour.Hour) ([]SearchResult, error)
}

type ReadableDStore interface {
	// TODO: audit all usages of this to ensure the reader is closed
	// TODO: ensure all implementers return nil on error
	Get(dFile DFile) (io.ReadCloser, error)
}

type SearchResult struct {
	Hour   hour.Hour
	AFiles map[AFile]bool
}

type WritableAStore interface {
	Store(aFile AFile, content io.Reader) error
}

type WritableDStore interface {
	Store(dFile DFile, content io.Reader) error
}