jobs

Documentation

Index

• Variables
• type Cron
  • func NewCron(executeAllPendingDownloadTaskJob ExecuteAllPendingDownloadTaskJob, ...) (Cron, error)
• type ExecuteAllPendingDownloadTaskJob
  • func NewExecuteAllPendingDownloadTaskJob(downloadTaskLogic logic.DownloadTaskLogic, cronConfig configs.Cron) ExecuteAllPendingDownloadTaskJob
• type Job
• type UpdateFailedDownloadTaskStatusToPendingJob
  • func NewUpdateFailedDownloadTaskStatusToPendingJob(downloadTaskLogic logic.DownloadTaskLogic, cronConfig configs.Cron) UpdateFailedDownloadTaskStatusToPendingJob

Variables

var WireSet = wire.NewSet(
	NewExecuteAllPendingDownloadTaskJob,
	NewUpdateFailedDownloadTaskStatusToPendingJob,
	NewCron,
)

Types

type Cron

type Cron interface {
	Start(context.Context) error
}

func NewCron

func NewCron(
	executeAllPendingDownloadTaskJob ExecuteAllPendingDownloadTaskJob,
	updateFailedDownloadTaskStatusToPending UpdateFailedDownloadTaskStatusToPendingJob,
	logger *zap.Logger,
) (Cron, error)

type ExecuteAllPendingDownloadTaskJob

type ExecuteAllPendingDownloadTaskJob interface {
	Run(ctx context.Context) error
	GetSchedule() string
}

func NewExecuteAllPendingDownloadTaskJob

func NewExecuteAllPendingDownloadTaskJob(
	downloadTaskLogic logic.DownloadTaskLogic,
	cronConfig configs.Cron,
) ExecuteAllPendingDownloadTaskJob

type Job

type Job interface {
	Run(context.Context) error
	GetSchedule() string
}

type UpdateFailedDownloadTaskStatusToPendingJob

type UpdateFailedDownloadTaskStatusToPendingJob interface {
	Run(ctx context.Context) error
	GetSchedule() string
}

func NewUpdateFailedDownloadTaskStatusToPendingJob

func NewUpdateFailedDownloadTaskStatusToPendingJob(
	downloadTaskLogic logic.DownloadTaskLogic,
	cronConfig configs.Cron,
) UpdateFailedDownloadTaskStatusToPendingJob