dispatcher

Documentation

Index

• Variables
• func Done(d chan bool) bool
• func SetLogger(l *zap.SugaredLogger)
• func WaitUntilTrue(ctx context.Context, between time.Duration, f func() bool) error
• type Dispatcher
  • func Start(workers int, wl Workload) Dispatcher
  • func (d *Dispatcher) Dispatch(payload interface{}) chan bool
  • func (d Dispatcher) DoAndStop()
  • func (d Dispatcher) Stop()
• type Task
• type Worker
  • func NewWorker(id int, workerPool chan chan Task, wl Workload, gwait *sync.WaitGroup) Worker
  • func (w *Worker) Start()
  • func (w *Worker) Stop()
• type Workload

Variables

var ErrInvalidPayload = errors.New("invalid payload")

Functions

func Done

func Done(d chan bool) bool

func SetLogger

func SetLogger(l *zap.SugaredLogger)

func WaitUntilTrue

func WaitUntilTrue(ctx context.Context, between time.Duration, f func() bool) error

Types

type Dispatcher

type Dispatcher struct {
	// contains filtered or unexported fields
}

func Start

func Start(workers int, wl Workload) Dispatcher

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(payload interface{}) chan bool

func (Dispatcher) DoAndStop

func (d Dispatcher) DoAndStop()

func (Dispatcher) Stop

func (d Dispatcher) Stop()

type Task

type Task struct {
	Payload    interface{}
	Dispatcher *Dispatcher
	// contains filtered or unexported fields
}

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(id int, workerPool chan chan Task, wl Workload, gwait *sync.WaitGroup) Worker

func (*Worker) Start

func (w *Worker) Start()

Start starts reading from tasks channel

func (*Worker) Stop

func (w *Worker) Stop()

Stop stops the wl invocation cycle (it will finish the current wl).

type Workload

type Workload interface {
	Do(Task) error
}