stormstore

Documentation

Index

• type FeedItemStore
  • func NewFeedItemStore(filename string) (*FeedItemStore, error)
  • func (f *FeedItemStore) Close()
  • func (f *FeedItemStore) Get(ctx context.Context, id uuid.UUID) (*models.FeedItem, error)
  • func (f *FeedItemStore) ListRecent(ctx context.Context, feedID uuid.UUID, filterExpression models.FeedItemFilter, ...) (feedItems []models.FeedItem, err error)
  • func (f *FeedItemStore) ListRecentsFromAllFeeds(ctx context.Context, filterExpression models.FeedItemFilter, page, count int) (feedItems []models.FeedItem, err error)
  • func (f *FeedItemStore) PutIfAbsent(ctx context.Context, item *models.FeedItem) error
  • func (f *FeedItemStore) Save(ctx context.Context, feedItem *models.FeedItem) error
• type FeedStore
  • func NewFeedStore(filename string) (*FeedStore, error)
  • func (js *FeedStore) Close()
  • func (js *FeedStore) Delete(ctx context.Context, id uuid.UUID) error
  • func (js *FeedStore) Get(ctx context.Context, id uuid.UUID) (feed models.Feed, err error)
  • func (js *FeedStore) List(ctx context.Context) (feeds []models.Feed, err error)
  • func (js *FeedStore) Save(ctx context.Context, feed *models.Feed) error
• type JobStore
  • func NewJobStore(filename string) (*JobStore, error)
  • func (js *JobStore) Close()
  • func (js *JobStore) Job(id uuid.UUID) (job models.Job, err error)
  • func (js *JobStore) List() (jobs []models.Job, err error)
  • func (js *JobStore) Save(job models.Job) error
• type VideoStore
  • func NewVideoStore(filename string) (*VideoStore, error)
  • func (vs *VideoStore) Close()
  • func (vs *VideoStore) DeleteWithExtID(extId string) error
  • func (vs *VideoStore) FindWithExtID(extId string) (*models.SavedVideo, error)
  • func (vs *VideoStore) FindWithID(id uuid.UUID) (*models.SavedVideo, error)
  • func (vs *VideoStore) ListRecent() (videos []models.SavedVideo, err error)
  • func (vs *VideoStore) Save(video models.SavedVideo) error

Types

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

func (f *FeedItemStore) Get(ctx context.Context, id uuid.UUID) (*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) error

func (*FeedItemStore) Save

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 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 string) error

func (*VideoStore) FindWithExtID

func (vs *VideoStore) FindWithExtID(extId string) (*models.SavedVideo, error)

func (*VideoStore) FindWithID

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