sequential

Documentation

Index

• type Scheduler
  • 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()

Types

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

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

func (*Scheduler) AddWork

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

func (*Scheduler) Shutdown

func (p *Scheduler) Shutdown()