stormstore

package
v0.0.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DBManager added in v0.0.9 

type DBManager struct {
	// contains filtered or unexported fields
}

func NewDBManager added in v0.0.9 

func NewDBManager(baseDir string) *DBManager

func (*DBManager) Close added in v0.0.9 

func (dm *DBManager) Close()

func (*DBManager) Open added in v0.0.9 

func (dm *DBManager) Open(filename string) (*storm.DB, error)

type FavouriteStore added in v0.0.8 

type FavouriteStore struct {
	// contains filtered or unexported fields
}

func NewFavouriteStore added in v0.0.8 

func NewFavouriteStore(filename string) (*FavouriteStore, error)

func (*FavouriteStore) Close added in v0.0.8 

func (f *FavouriteStore) Close()

func (*FavouriteStore) Delete added in v0.0.8 

func (f *FavouriteStore) Delete(ctx context.Context, id uuid.UUID) error

func (*FavouriteStore) List added in v0.0.8 

func (f *FavouriteStore) List(ctx context.Context, filterExpr models.FeedItemFilter, page int) (favorites []models.Favourite, err error)

func (*FavouriteStore) LookupByVideoRef added in v0.0.8 

func (fs *FavouriteStore) LookupByVideoRef(ctx context.Context, videoRef models.VideoRef) (*models.Favourite, error)

func (*FavouriteStore) Save added in v0.0.8 

func (f *FavouriteStore) Save(ctx context.Context, favourite *models.Favourite) error

type FeedItemStore 

type FeedItemStore struct {
	// contains filtered or unexported fields
}

func NewFeedItemStore 

func NewFeedItemStore(filename string) (*FeedItemStore, error)

func (*FeedItemStore) Close 

func (f *FeedItemStore) Close()

func (*FeedItemStore) Get added in v0.0.6 

func (f *FeedItemStore) Get(ctx context.Context, id uuid.UUID) (*models.FeedItem, error)

func (*FeedItemStore) GetByVideoRef added in v0.0.10 

func (f *FeedItemStore) GetByVideoRef(ctx context.Context, videoRef models.VideoRef) (*models.FeedItem, error)

func (*FeedItemStore) ListRecent 

func (f *FeedItemStore) ListRecent(ctx context.Context, feedID uuid.UUID, filterExpression models.FeedItemFilter, page int) (feedItems []models.FeedItem, err error)

func (*FeedItemStore) ListRecentsFromAllFeeds 

func (f *FeedItemStore) ListRecentsFromAllFeeds(ctx context.Context, filterExpression models.FeedItemFilter, page, count int) (feedItems []models.FeedItem, err error)

func (*FeedItemStore) PutIfAbsent 

func (f *FeedItemStore) PutIfAbsent(ctx context.Context, item *models.FeedItem) (wasInserted bool, err error)

func (*FeedItemStore) Save added in v0.0.6 

func (f *FeedItemStore) Save(ctx context.Context, feedItem *models.FeedItem) error

type FeedStore 

type FeedStore struct {
	// contains filtered or unexported fields
}

func NewFeedStore 

func NewFeedStore(filename string) (*FeedStore, error)

func (*FeedStore) Close 

func (js *FeedStore) Close()

func (*FeedStore) Delete 

func (js *FeedStore) Delete(ctx context.Context, id uuid.UUID) error

func (*FeedStore) Get 

func (js *FeedStore) Get(ctx context.Context, id uuid.UUID) (feed models.Feed, err error)

func (*FeedStore) List 

func (js *FeedStore) List(ctx context.Context) (feeds []models.Feed, err error)

func (*FeedStore) Save 

func (js *FeedStore) Save(ctx context.Context, feed *models.Feed) error

type JobStore 

type JobStore struct {
	// contains filtered or unexported fields
}

func NewJobStore 

func NewJobStore(filename string) (*JobStore, error)

func (*JobStore) Close 

func (js *JobStore) Close()

func (*JobStore) Job 

func (js *JobStore) Job(id uuid.UUID) (job models.Job, err error)

func (*JobStore) List 

func (js *JobStore) List() (jobs []models.Job, err error)

func (*JobStore) Save 

func (js *JobStore) Save(job models.Job) error

type RulesStore added in v0.0.9 

type RulesStore struct {
	// contains filtered or unexported fields
}

func NewRulesStore added in v0.0.9 

func NewRulesStore(dm *DBManager) (*RulesStore, error)

func (*RulesStore) Delete added in v0.0.9 

func (rs *RulesStore) Delete(ctx context.Context, ruleID uuid.UUID) error

func (*RulesStore) Get added in v0.0.9 

func (rs *RulesStore) Get(ctx context.Context, ruleID uuid.UUID) (*models.Rule, error)

func (*RulesStore) List added in v0.0.9 

func (rs *RulesStore) List(ctx context.Context) (rules []*models.Rule, err error)

func (*RulesStore) Save added in v0.0.9 

func (rs *RulesStore) Save(ctx context.Context, rule *models.Rule) error

type VideoStore 

type VideoStore struct {
	// contains filtered or unexported fields
}

func NewVideoStore 

func NewVideoStore(filename string) (*VideoStore, error)

func (*VideoStore) Close 

func (vs *VideoStore) Close()

func (*VideoStore) DeleteWithExtID 

func (vs *VideoStore) DeleteWithExtID(extId models.VideoRef) error

func (*VideoStore) FindWithExtID 

func (vs *VideoStore) FindWithExtID(videoRef models.VideoRef) (*models.SavedVideo, error)

func (*VideoStore) FindWithID added in v0.0.5 

func (vs *VideoStore) FindWithID(id uuid.UUID) (*models.SavedVideo, error)

func (*VideoStore) ListRecent 

func (vs *VideoStore) ListRecent() (videos []models.SavedVideo, err error)

func (*VideoStore) Save 

func (vs *VideoStore) Save(video models.SavedVideo) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.