storage

Jun 25, 2020

Changes in this version

type ItemStorageBacking

+ HasIndex func(meta *indexing.IndexMetadata) bool

Jun 24, 2020

Changes in this version

+ type Builder struct

+ func NewBuilder() *Builder

+ func (b *Builder) BackedBy(backing ItemStorageBacking) *Builder

+ func (b *Builder) Build() ItemStorage

+ func (b *Builder) WithBacking(backingType string) *Builder

+ func (b *Builder) WithDefaultBacking() *Builder

+ func (b *Builder) WithEndpoint(endpoint string) *Builder

+ func (b *Builder) WithNamespace(ns string) *Builder

+ func (b *Builder) WithPK(keyFields *indexing.Key) *Builder

+ func (b *Builder) WithRecord(recordTypePtr interface{}) *Builder

type ItemStorage

+ ForEach func(callback func(record interface{}))

+ GetNewest func(count int) []search.ExternalResultItem

+ Size func() int64

type ItemStorageBacking

+ ForEach func(callback func(record interface{}))

type KeyedStorage

+ func (s *KeyedStorage) ForEach(callback func(record interface{}))

Jun 24, 2020

Changes in this version

type ItemStorage

+ AddUniqueIndex func(key *indexing.Key)

+ Close func()

+ Find func(query indexing.Query, output *search.ExternalResultItem) error

+ SetKey func(index *indexing.Key) error

type ItemStorageBacking

+ Close func()

+ CreateWithId func(parts *indexing.Key, item *search.ExternalResultItem, ...) error

+ GetNewest func(count int) []search.ExternalResultItem

+ Size func() int64

type KeyedStorage

+ func NewKeyedStorageWithBackingType(namespace string, config config.Config, key *indexing.Key, storageType string) *KeyedStorage

+ func (s *KeyedStorage) AddUniqueIndex(key *indexing.Key)

+ func (s *KeyedStorage) Close()

+ func (s *KeyedStorage) Find(query indexing.Query, output *search.ExternalResultItem) error

+ func (s *KeyedStorage) GetNewest(count int) []search.ExternalResultItem

+ func (s *KeyedStorage) SetKey(index *indexing.Key) error

+ func (s *KeyedStorage) Size() int64

Jun 20, 2020

Changes in this version

+ func DefaultBoltPath() string

+ func GetBoltDb(file string) (*bolt.DB, error)

+ func GetIndexNameFromQuery(query Query) string

+ func GetIndexValueFromItem(keyParts Key, item *search.ExternalResultItem) []byte

+ func GetIndexValueFromQuery(query Query) []byte

+ func GetOlderThanHours(h int) []search.ExternalResultItem

+ type BoltStorage struct

+ Database *bolt.DB

+ func NewBoltStorage(dbPath string) (*BoltStorage, error)

+ func (b *BoltStorage) Create(keyParts Key, item *search.ExternalResultItem) error

+ func (b *BoltStorage) Find(query Query, result *search.ExternalResultItem) error

+ func (b *BoltStorage) ForChat(callback func(chat *Chat)) error

+ func (b *BoltStorage) GetBucket(tx *bolt.Tx, children ...string) *bolt.Bucket

+ func (b *BoltStorage) GetChat(id int) (*Chat, error)

+ func (b *BoltStorage) GetSearchResults(categoryId int) ([]search.ExternalResultItem, error)

+ func (b *BoltStorage) StoreChat(chat *Chat) error

+ func (b *BoltStorage) StoreSearchResults(items []search.ExternalResultItem) error

+ func (b *BoltStorage) Truncate() error

+ func (b *BoltStorage) Update(query Query, item *search.ExternalResultItem) error

+ type Chat struct

+ ChatId int64

+ InitialText string

+ Username string

+ type ChatMessage struct

+ ChatId string

+ Text string

+ type Cursor interface

+ CanContinue func(val []byte) bool

+ First func() ([]byte, []byte)

+ Next func() ([]byte, []byte)

+ type CursorOptions struct

+ Limit int

+ Reverse bool

+ Skip int

+ func NewCursorOptions() *CursorOptions

+ func SingleItemCursor() *CursorOptions

+ type DBStorage struct

+ Path string

+ func DefaultStorageBacking() *DBStorage

+ func (d *DBStorage) Create(keyParts Key, tr *search.ExternalResultItem) error

+ func (d *DBStorage) Find(query Query, matchingItem *search.ExternalResultItem) error

+ func (d *DBStorage) FindById(id string) *search.ExternalResultItem

+ func (d *DBStorage) FindByNameAndIndex(title string, indexerSite string) *search.ExternalResultItem

+ func (d *DBStorage) GetCategories() []db.TorrentCategory

+ func (d *DBStorage) GetDb() *gorm.DB

+ func (d *DBStorage) GetLatest(cnt int) []search.ExternalResultItem

+ func (d *DBStorage) GetNewest(cnt int) []search.ExternalResultItem

+ func (d *DBStorage) GetOlderThanHours(h int) []search.ExternalResultItem

+ func (d *DBStorage) GetTorrentCount() int64

+ func (d *DBStorage) GetTorrentsInCategories(ids []int) []search.ExternalResultItem

+ func (d *DBStorage) Truncate()

+ func (d *DBStorage) Update(query Query, item *search.ExternalResultItem) error

+ func (d *DBStorage) UpdateResult(id uint, torrent *search.ExternalResultItem)

+ type Index interface

+ Add func(value []byte, targetID []byte) error

+ All func(value []byte, opts *CursorOptions) [][]byte

+ AllRecords func(opts *CursorOptions) [][]byte

+ Get func(value []byte) []byte

+ Range func(min []byte, max []byte, opts *CursorOptions) [][]byte

+ Remove func(value []byte) error

+ RemoveById func(id []byte) error

+ type ItemStorage interface

+ Add func(item *search.ExternalResultItem) (bool, bool)

+ NewWithKey func(key Key) ItemStorage

+ type ItemStorageBacking interface

+ Create func(parts Key, item *search.ExternalResultItem) error

+ Find func(query Query, result *search.ExternalResultItem) error

+ Update func(query Query, item *search.ExternalResultItem) error

+ type Key []string

+ func NewKey(fieldNames ...string) Key

+ type KeyedStorage struct

+ func NewKeyedStorage(keyFields Key) *KeyedStorage

+ func NewKeyedStorageWithBacking(key Key, storage ItemStorageBacking) *KeyedStorage

+ func (s *KeyedStorage) Add(item *search.ExternalResultItem) (bool, bool)

+ func (s *KeyedStorage) NewWithKey(key Key) ItemStorage

+ type ListIndex struct

+ IDs *UniqueIndex

+ IndexBucket *bolt.Bucket

+ ParentBucket *bolt.Bucket

+ func NewListIndex(parent *bolt.Bucket, name []byte) (*ListIndex, error)

+ func (ix *ListIndex) Add(val []byte, id []byte) error

+ func (ix *ListIndex) All(indexValue []byte, opts *CursorOptions) [][]byte

+ func (ix *ListIndex) AllRecords(opts *CursorOptions) [][]byte

+ func (ix *ListIndex) Get(indexValue []byte) []byte

+ func (ix *ListIndex) Prefix(prefix []byte, opts *CursorOptions) [][]byte

+ func (ix *ListIndex) Range(min []byte, max []byte, opts *CursorOptions) [][]byte

+ func (ix *ListIndex) Remove(indexValue []byte) error

+ func (ix *ListIndex) RemoveById(id []byte) error

+ type PrefixCursor struct

+ C *bolt.Cursor

+ Prefix []byte

+ Reverse bool

+ func (c *PrefixCursor) CanContinue(value []byte) bool

+ func (c *PrefixCursor) First() ([]byte, []byte)

+ func (c *PrefixCursor) Next() ([]byte, []byte)

+ type Query interface

+ Get func(key interface{}) (value interface{}, found bool)

+ Keys func() []interface{}

+ Put func(k, v interface{})

+ Size func() int

+ Values func() []interface{}

+ func GetKeyQueryFromItem(keyParts Key, item *search.ExternalResultItem) Query

+ func NewQuery() Query

+ type RangeCursor struct

+ C *bolt.Cursor

+ Comparator func(a []byte, b []byte) int

+ Max []byte

+ Min []byte

+ Reverse bool

+ func (r *RangeCursor) CanContinue(value []byte) bool

+ func (r *RangeCursor) First() ([]byte, []byte)

+ func (r *RangeCursor) Next() ([]byte, []byte)

+ type ReversibleCursor struct

+ C *bolt.Cursor

+ Reverse bool

+ func (c *ReversibleCursor) CanContinue(val []byte) bool

+ func (c *ReversibleCursor) First() ([]byte, []byte)

+ func (c *ReversibleCursor) Next() ([]byte, []byte)

+ type UniqueIndex struct

+ IndexBucket *bolt.Bucket

+ ParentBucket *bolt.Bucket

+ func NewUniqueIndex(parentBucket *bolt.Bucket, name []byte) (*UniqueIndex, error)

+ func (ix *UniqueIndex) Add(indexValue []byte, id []byte) error

+ func (ix *UniqueIndex) All(indexValue []byte, _ *CursorOptions) [][]byte

+ func (ix *UniqueIndex) AllRecords(ops *CursorOptions) [][]byte

+ func (ix *UniqueIndex) AllWithPrefix(prefix []byte, ops *CursorOptions) [][]byte

+ func (ix *UniqueIndex) Get(indexValue []byte) []byte

+ func (ix *UniqueIndex) Range(min []byte, max []byte, ops *CursorOptions) [][]byte

+ func (ix *UniqueIndex) Remove(indexValue []byte) error

+ func (ix *UniqueIndex) RemoveById(id []byte) error