worker

type BaseWorker struct {
	Queue       workqueue.TypedRateLimitingInterface[Operand]
	WorkerName  string
	WorkerError WorkerError

	Env string
	// contains filtered or unexported fields
}

type Operand interface{}

type PeriodicReconcilable interface {
	Interval() time.Duration
}

type Result struct {
	Requeue bool

	// RequeueAfter if greater than 0, tells the worker manager to requeue the operand after the Duration.
	// Implies that Requeue is true, there is no need to set Requeue to true at the same time as RequeueAfter.
	RequeueAfter time.Duration
}

type Worker interface {
	Execute(ctx context.Context, operand Operand) (Result, *errors.ServiceError)
	EnqueueNow(operand Operand)
	EnqueueAfter(Operand Operand, after time.Duration)
	WorkQueue() workqueue.TypedRateLimitingInterface[Operand]
	// Function that returns the list of operands to be passed to the workers execute method.
	GetInput(context.Context) ([]Operand, *errors.ServiceError)
	Logger() logger.Logger
	Name() string
}

type WorkerError interface {
	NewError(format string, args ...any) *errors.ServiceError
}