orch

Documentation

Index

• type ColdStartOrchestrator
  • func NewColdStartOrchestrator(bgmClient *dao.BgmApiAccessor, konomiAccessor dao.KonomiAccessor) *ColdStartOrchestrator
  • func (orch *ColdStartOrchestrator) Run(numOfSubjectRetrievers, numOfUserIdRetrievers, numOfUserIdMergers, ... int)
• type UpdateOrchestrator
  • func NewUpdateOrchestrator(bgmClient *dao.BgmApiAccessor, konomiAccessor dao.KonomiAccessor) *UpdateOrchestrator
  • func (orch *UpdateOrchestrator) Run(numOfUserIdReaders, numOfCollectionUpdater, numOfDataCleaner int)

Types

type ColdStartOrchestrator

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

func NewColdStartOrchestrator

func NewColdStartOrchestrator(bgmClient *dao.BgmApiAccessor, konomiAccessor dao.KonomiAccessor) *ColdStartOrchestrator

func (*ColdStartOrchestrator) Run

func (orch *ColdStartOrchestrator) Run(numOfSubjectRetrievers, numOfUserIdRetrievers, numOfUserIdMergers, coldStartIntervalInDays int)

type UpdateOrchestrator

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

func NewUpdateOrchestrator

func NewUpdateOrchestrator(bgmClient *dao.BgmApiAccessor, konomiAccessor dao.KonomiAccessor) *UpdateOrchestrator

func (*UpdateOrchestrator) Run

func (orch *UpdateOrchestrator) Run(numOfUserIdReaders, numOfCollectionUpdater, numOfDataCleaner int)