service

Documentation

Index

• type SubjectService
  • func NewSubjectService(bgmClient *dao.BgmApiAccessor) *SubjectService
  • func (svc *SubjectService) GetSubjectRetriever(numOfSubjectRetrievers int) func(put func(*job.ColdStartOrchJob)) error
• type UserCleaningService
  • func NewUserCleaningService(konomiAccessor dao.KonomiAccessor) *UserCleaningService
  • func (svc *UserCleaningService) GetUserCleaner() func(in *job.RegularUpdateOrchJob) (*job.RegularUpdateOrchJob, error)
• type UserIdReadingService
  • func NewUserIdReadingService(accessor dao.KonomiAccessor) *UserIdReadingService
  • func (svc *UserIdReadingService) GetUserIdReader(numOfUserIdReaders int) func(put func(*job.RegularUpdateOrchJob)) error
• type UserIdScrapingService
  • func NewUserIdScrapingService() *UserIdScrapingService
  • func (svc *UserIdScrapingService) GetUserIdMerger() (func(in *orchJob.ColdStartOrchJob) (*orchJob.ColdStartOrchJob, error), ...)
  • func (svc *UserIdScrapingService) GetUserIdRetriever(coldStartIntervalInDays int) func(in *orchJob.ColdStartOrchJob) (*orchJob.ColdStartOrchJob, error)
• type UserPersistingService
  • func NewUserPersistenceService(bgmClinet *dao.BgmApiAccessor, konomiAccessor dao.KonomiAccessor) *UserPersistingService
  • func (svc *UserPersistingService) Persist(uids []string)
• type UserUpdatingService
  • func NewUserUpdatingService(bgmClient *dao.BgmApiAccessor, konomiAccessor dao.KonomiAccessor) *UserUpdatingService
  • func (svc *UserUpdatingService) GetUserUpdater() func(in *job.RegularUpdateOrchJob) (*job.RegularUpdateOrchJob, error)

Types

type SubjectService

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

func NewSubjectService

func NewSubjectService(bgmClient *dao.BgmApiAccessor) *SubjectService

func (*SubjectService) GetSubjectRetriever

func (svc *SubjectService) GetSubjectRetriever(numOfSubjectRetrievers int) func(put func(*job.ColdStartOrchJob)) error

type UserCleaningService

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

func NewUserCleaningService

func NewUserCleaningService(konomiAccessor dao.KonomiAccessor) *UserCleaningService

func (*UserCleaningService) GetUserCleaner

func (svc *UserCleaningService) GetUserCleaner() func(in *job.RegularUpdateOrchJob) (*job.RegularUpdateOrchJob, error)

type UserIdReadingService

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

func NewUserIdReadingService

func NewUserIdReadingService(accessor dao.KonomiAccessor) *UserIdReadingService

func (*UserIdReadingService) GetUserIdReader

func (svc *UserIdReadingService) GetUserIdReader(numOfUserIdReaders int) func(put func(*job.RegularUpdateOrchJob)) error

type UserIdScrapingService

type UserIdScrapingService struct {
}

func NewUserIdScrapingService

func NewUserIdScrapingService() *UserIdScrapingService

func (*UserIdScrapingService) GetUserIdMerger

func (svc *UserIdScrapingService) GetUserIdMerger() (func(in *orchJob.ColdStartOrchJob) (*orchJob.ColdStartOrchJob, error), map[string]struct{})

func (*UserIdScrapingService) GetUserIdRetriever

func (svc *UserIdScrapingService) GetUserIdRetriever(coldStartIntervalInDays int) func(in *orchJob.ColdStartOrchJob) (*orchJob.ColdStartOrchJob, error)

type UserPersistingService

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

func NewUserPersistenceService

func NewUserPersistenceService(bgmClinet *dao.BgmApiAccessor, konomiAccessor dao.KonomiAccessor) *UserPersistingService

func (*UserPersistingService) Persist

func (svc *UserPersistingService) Persist(uids []string)

type UserUpdatingService

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

func NewUserUpdatingService

func NewUserUpdatingService(
	bgmClient *dao.BgmApiAccessor,
	konomiAccessor dao.KonomiAccessor,
) *UserUpdatingService

func (*UserUpdatingService) GetUserUpdater

func (svc *UserUpdatingService) GetUserUpdater() func(in *job.RegularUpdateOrchJob) (*job.RegularUpdateOrchJob, error)