tasks

type Broker struct {
	CleanupMachinery func()
	CleanupSpan      func()
	BatchID          string
	Server           *machinery.Server
	Ctx              context.Context
}

type Config interface {
	TasksDefaultQueue() string
	TasksResultsExpireIn() int
	TasksBroker() string
	TasksResultBackend() string
	TasksRedis() RedisConfig
	TasksPeriodicTaskSignatures() map[string]PeriodicTaskSignature
	TasksPeriodicTaskSignature(taskName string) PeriodicTaskSignature
}

type PeriodicTaskSignature interface {
	PeriodicTaskSignatureArgs() []tasks.Arg
	PeriodicTaskSignatureCron() string
	PeriodicTaskSignatureRetryCount() int
}

type RedisConfig interface {
	RedisMaxIdle() int
	RedisIdleTimeout() int
	RedisReadTimeout() int
	RedisWriteTimeout() int
	RedisConnectTimeout() int
	RedisNormalTasksPollPeriod() int
	RedisDelayedTasksPollPeriod() int
}