list

Documentation

Index

• type Job
  • func NewRefreshListsJob(log zerolog.Logger, listSvc RefreshListSvc) Job
• type RefreshListSvc
• type RefreshListsJob
  • func (job *RefreshListsJob) Run()
  • func (job *RefreshListsJob) RunE(ctx context.Context) error
• type Service
  • func NewService(log logger.Logger, repo domain.ListRepo, ...) Service
• type Titles
  • func NewTitleSet() *Titles
  • func (ts *Titles) Add(title string, matchRelease bool)
  • func (ts *Titles) Titles() []string

Types

type Job

type Job interface {
	cron.Job
	RunE(ctx context.Context) error
}

func NewRefreshListsJob

func NewRefreshListsJob(log zerolog.Logger, listSvc RefreshListSvc) Job

type RefreshListSvc

type RefreshListSvc interface {
	RefreshAll(ctx context.Context) error
}

type RefreshListsJob

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

func (*RefreshListsJob) Run

func (job *RefreshListsJob) Run()

func (*RefreshListsJob) RunE

func (job *RefreshListsJob) RunE(ctx context.Context) error

type Service

type Service interface {
	List(ctx context.Context) ([]*domain.List, error)
	FindByID(ctx context.Context, id int64) (*domain.List, error)
	Store(ctx context.Context, list *domain.List) error
	Update(ctx context.Context, list *domain.List) error
	Delete(ctx context.Context, id int64) error
	RefreshAll(ctx context.Context) error
	RefreshList(ctx context.Context, listID int64) error
	RefreshArrLists(ctx context.Context) error
	RefreshOtherLists(ctx context.Context) error
	Start()
}

func NewService

func NewService(log logger.Logger, repo domain.ListRepo, downloadClientSvc download_client.Service, filterSvc filter.Service, schedulerSvc scheduler.Service) Service

type Titles

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

func NewTitleSet

func NewTitleSet() *Titles

func (*Titles) Add

func (ts *Titles) Add(title string, matchRelease bool)

func (*Titles) Titles

func (ts *Titles) Titles() []string