store

type CacheRepository interface {
	GetFromCache(key string) (*model.CacheItem, error)
	StoreToCache(key string, item *model.CacheItem) error
	ClearCache() error
	EvictFromCache(before time.Time) error
}

type DB interface {
	FeedRepository
	OutputRepository
	CacheRepository
	SearchRepository
	Close() error
}

type FeedRepository interface {
	ListFeeds(page, size int) (*model.FeedDefPage, error)
	CountFeeds() (int, error)
	ExistsFeed(url string) bool
	GetFeed(id string) (*model.FeedDef, error)
	DeleteFeed(id string) (*model.FeedDef, error)
	SaveFeed(feed *model.FeedDef) error
	ForEachFeed(cb func(*model.FeedDef) error) error
}

type OutputRepository interface {
	ListOutputs(page, limit int) (*model.OutputDefCollection, error)
	GetOutput(ID string) (*model.OutputDef, error)
	DeleteOutput(ID string) (*model.OutputDef, error)
	SaveOutput(output model.OutputDef) (*model.OutputDef, error)
	ForEachOutput(cb func(*model.OutputDef) error) error
	ClearOutputs() error
}

type SearchRepository interface {
	BuildInitialIndex() error
	SearchFeeds(query string, page, size int) (*model.FeedDefPage, error)
}