worker

Documentation

Index

• type Dispatcher
  • func NewDispatcher(size int) Dispatcher
• type Request
• type Worker

Types

type Dispatcher

type Dispatcher interface {
	// called by client
	Send(in interface{}) (interface{}, error)
	// called by worker to get more work
	Dispatch() Request
	// associate worker with dispatcher and start working
	AddWorker(worker Worker)
	Close()
}

Dispatcher ...

func NewDispatcher

func NewDispatcher(size int) Dispatcher

NewDispatcher ...

type Request

type Request struct {
	In     interface{}
	Result (chan interface{})
	Err    (chan error)
}

Request ...

type Worker

type Worker interface {
	SetDispatcher(d Dispatcher)
	Loop()
}

Worker ...