job

Jul 4, 2024

Changes in this version

+ type Job interface

+ Execute func(ctx context.Context, fulfilled []T, abandoned []T) error

+ type Scheduler struct

+ func NewScheduler[T comparable]() *Scheduler[T]

+ func (s *Scheduler[T]) Abandon(ctx context.Context, dependency T) error

+ func (s *Scheduler[T]) Fulfill(ctx context.Context, dependency T) error

+ func (s *Scheduler[T]) Schedule(ctx context.Context, userJob Job[T], dependencies ...T) error

+ func (s *Scheduler[_]) NumDependencies() int