archive

Documentation

Index

• func NewFileSQLite(filename string) (*sqlitex.Pool, error)
• type FeedStorage
• type HibikiFeed
  • func NewHibikiFeed(storage FeedStorage) *HibikiFeed
  • func (f *HibikiFeed) GetShowFeed(ctx context.Context) ([]ShowEntry, error)
  • func (f *HibikiFeed) Run(ctx context.Context) (err error)
• type OnsenFeed
  • func NewOnsenFeed(storage FeedStorage) *OnsenFeed
  • func (f *OnsenFeed) GetShowFeed(ctx context.Context) ([]ShowEntry, error)
  • func (f *OnsenFeed) Run(ctx context.Context) (err error)
• type OnsenProvider
  • func NewOnsenProvider(storage Storage) *OnsenProvider
  • func (p *OnsenProvider) GetFeed(_ model.Loader) ([]model.ShowAccess, error)
  • func (p *OnsenProvider) Label() string
• type ShowEntry
• type Storage
  • func NewStorage(pool *sqlitex.Pool) *Storage
  • func (s *Storage) AddShows(ctx context.Context, entries []ShowEntry) error
  • func (s *Storage) GetShows(ctx context.Context) ([]ShowEntry, error)
  • func (s *Storage) MigrateShowFeed(ctx context.Context) error

Functions

func NewFileSQLite

func NewFileSQLite(filename string) (*sqlitex.Pool, error)

Types

type FeedStorage

type FeedStorage interface {
	AddShows(ctx context.Context, entries []ShowEntry) error
}

type HibikiFeed

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

func NewHibikiFeed

func NewHibikiFeed(storage FeedStorage) *HibikiFeed

func (*HibikiFeed) GetShowFeed

func (f *HibikiFeed) GetShowFeed(ctx context.Context) ([]ShowEntry, error)

func (*HibikiFeed) Run

func (f *HibikiFeed) Run(ctx context.Context) (err error)

type OnsenFeed

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

func NewOnsenFeed

func NewOnsenFeed(storage FeedStorage) *OnsenFeed

func (*OnsenFeed) GetShowFeed

func (f *OnsenFeed) GetShowFeed(ctx context.Context) ([]ShowEntry, error)

func (*OnsenFeed) Run

func (f *OnsenFeed) Run(ctx context.Context) (err error)

type OnsenProvider

type OnsenProvider struct {
	Storage
}

func NewOnsenProvider

func NewOnsenProvider(storage Storage) *OnsenProvider

func (*OnsenProvider) GetFeed

func (p *OnsenProvider) GetFeed(_ model.Loader) ([]model.ShowAccess, error)

func (*OnsenProvider) Label

func (p *OnsenProvider) Label() string

type ShowEntry

type ShowEntry struct {
	Source string
	ShowID string
}

type Storage

type Storage struct {
	*sqlitex.Pool
}

func NewStorage

func NewStorage(pool *sqlitex.Pool) *Storage

func (*Storage) AddShows

func (s *Storage) AddShows(ctx context.Context, entries []ShowEntry) error

func (*Storage) GetShows

func (s *Storage) GetShows(ctx context.Context) ([]ShowEntry, error)

func (*Storage) MigrateShowFeed

func (s *Storage) MigrateShowFeed(ctx context.Context) error