Documentation
¶
Index ¶
- Variables
- type BoltStore
- func (store *BoltStore) BuildInitialIndex() error
- func (store *BoltStore) ClearCache() error
- func (store *BoltStore) ClearOutputs() error
- func (store *BoltStore) Close() error
- func (store *BoltStore) CountFeeds() (int, error)
- func (store *BoltStore) DeleteFeed(id string) (*model.FeedDef, error)
- func (store *BoltStore) DeleteOutput(ID string) (*model.OutputDef, error)
- func (store *BoltStore) EvictFromCache(before time.Time) error
- func (store *BoltStore) ExistsFeed(url string) bool
- func (store *BoltStore) ForEachFeed(cb func(*model.FeedDef) error) error
- func (store *BoltStore) ForEachOutput(cb func(*model.OutputDef) error) error
- func (store *BoltStore) GetFeed(id string) (*model.FeedDef, error)
- func (store *BoltStore) GetFromCache(key string) (*model.CacheItem, error)
- func (store *BoltStore) GetOutput(ID string) (*model.OutputDef, error)
- func (store *BoltStore) ListFeeds(page, size int) (*model.FeedDefPage, error)
- func (store *BoltStore) ListOutputs(page, limit int) (*model.OutputDefCollection, error)
- func (store *BoltStore) SaveFeed(feed *model.FeedDef) error
- func (store *BoltStore) SaveOutput(output model.OutputDef) (*model.OutputDef, error)
- func (store *BoltStore) SearchFeeds(query string, page, size int) (*model.FeedDefPage, error)
- func (store *BoltStore) StoreToCache(key string, item *model.CacheItem) error
Constants ¶
This section is empty.
Variables ¶
var CacheBucketName = []byte("CACHE")
CacheBucketName bucket name
var FeedBucketName = []byte("FEED")
FeedBucketName bucket name
var OutputBucketName = []byte("OUTPUT")
OutputBucketName bucket name
Functions ¶
This section is empty.
Types ¶
type BoltStore ¶
type BoltStore struct {
// contains filtered or unexported fields
}
BoltStore is a data store backed by BoltDB
func NewBoltStore ¶
NewBoltStore creates a data store backed by BoltDB
func (*BoltStore) BuildInitialIndex ¶
BuildInitialIndex create initial index (only if empty)
func (*BoltStore) ClearCache ¶
ClearCache removes all items from the cache.
func (*BoltStore) ClearOutputs ¶
ClearOutputs clear all outputs
func (*BoltStore) CountFeeds ¶
CountFeeds returns total numer of feeds.
func (*BoltStore) DeleteFeed ¶
DeleteFeed removes a feed.
func (*BoltStore) DeleteOutput ¶
DeleteOutput removes a output.
func (*BoltStore) EvictFromCache ¶
EvictFromCache manage the cache eviction.
func (*BoltStore) ExistsFeed ¶
ExistsFeed returns true if a feed exists for this url.
func (*BoltStore) ForEachFeed ¶
ForEachFeed iterates over all feeds
func (*BoltStore) ForEachOutput ¶
ForEachOutput iterates over all outputs
func (*BoltStore) GetFromCache ¶
GetFromCache returns a cached item.
func (*BoltStore) ListFeeds ¶
func (store *BoltStore) ListFeeds(page, size int) (*model.FeedDefPage, error)
ListFeeds returns a paginated list of feeds.
func (*BoltStore) ListOutputs ¶
func (store *BoltStore) ListOutputs(page, limit int) (*model.OutputDefCollection, error)
ListOutputs returns a paginated list of outputs.
func (*BoltStore) SaveOutput ¶
SaveOutput stores a output.
func (*BoltStore) SearchFeeds ¶
SearchFeeds search feeds using search index
Source Files