batch_job

Dec 19, 2023

Changes in this version

+ type BaseConfig struct

+ Enabled bool

+ Interval string

+ MaxRetries int64

+ func (c *BaseConfig) ProcessingInterval() taskprocessor.ProcessingInterval

+ func (c *BaseConfig) Validate() error

+ type BatchJob struct

+ func NewBatchJob(options ...BatchJobConfigOption) *BatchJob

+ func (c *BatchJob) String() string

+ func (c *BatchJob) Validate() error

+ type BatchJobConfigOption func(*BatchJob)

+ func WithBaseConfig(cfg BaseConfig) BatchJobConfigOption

+ func WithTask(task *asynq.Task) BatchJobConfigOption

+ func WithTaskId(taskId *string) BatchJobConfigOption

+ type BatchJobs struct

+ func NewBatchJobs(options ...BatchJobsOption) *BatchJobs

+ func (b *BatchJobs) AddJob(job *BatchJob)

+ type BatchJobsOption func(*BatchJobs)

+ func WithBatchJob(batchJob *BatchJob) BatchJobsOption

+ func WithBatchJobs(batchJobs *BatchJobs) BatchJobsOption

+ type Batcher struct

+ func NewBatcher(options ...BatcherOption) *Batcher

+ func (b *Batcher) RegisterRecurringBatchJobs(ctx context.Context) error

+ type BatcherOption func(*Batcher)

+ func WithBatchJobsRef(batchJobs *BatchJobs) BatcherOption

+ func WithTaskProcessor(processor *taskprocessor.TaskProcessor) BatcherOption

+ type Runnable interface

+ RegisterRecurringBatchJobs func(ctx context.Context) error