sequential

type Scheduler ¶

type Scheduler struct {
	Do func(context.Context, *events.XRPCStreamEvent) error
	// contains filtered or unexported fields
}

Scheduler is a sequential scheduler that will run work on a single worker

func NewScheduler(ident string, do func(context.Context, *events.XRPCStreamEvent) error) *Scheduler

func (s *Scheduler) AddWork(ctx context.Context, repo string, val *events.XRPCStreamEvent) error

func (p *Scheduler) Shutdown()