task

Jun 25, 2024

Changes in this version

+ type EqualSpec interface

+ Equal func(S) bool

+ type EqualityFunc func(x, y T) bool

+ type ID = string

+ type Runner struct

+ func NewEqualRunner[S EqualSpec[T, S], T any]() *Runner[T, S]

+ func NewRunner[T any, S Spec[T]](equalityFunc EqualityFunc[S]) *Runner[T, S]

+ func (runner *Runner[T, S]) Reconcile(ctx context.Context, logger *zap.Logger, shouldRun map[ID]S, in T)

+ func (runner *Runner[T, S]) StartTask(ctx context.Context, logger *zap.Logger, id string, spec S, task T)

+ func (runner *Runner[T, S]) Stop()

+ func (runner *Runner[T, S]) StopTask(logger *zap.Logger, id string)

+ type Spec interface

+ ID func() ID

+ RunTask func(ctx context.Context, logger *zap.Logger, in T) error

+ type Task struct

+ func New[T any, S Spec[T]](logger *zap.Logger, spec S, in T) *Task[T, S]

+ func (task *Task[T, S]) Spec() S

+ func (task *Task[T, S]) Start(ctx context.Context)

+ func (task *Task[T, S]) Stop()