batch_job

type BaseConfig struct {
	Enabled    bool   `json:"enabled"`
	Interval   string `json:"interval"` // e.g. "10s", "1m", "1h"
	MaxRetries int64  `json:"maxRetries"`
}

type BatchJob struct {
	BaseConfig
	// contains filtered or unexported fields
}

type BatchJobConfigOption func(*BatchJob)

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

type BatchJobsOption func(*BatchJobs)

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

type BatcherOption func(*Batcher)

type Runnable interface {
	RegisterRecurringBatchJobs(ctx context.Context) error
}