director

package

v0.3.0 Latest Latest Go to latest Published: Sep 17, 2015 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func NewContext(parent context.Context, w worker.Worker) context.Context

NewContext returns a Context whose Value method returns the director.

type Director struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Director manages workloads and delegates to workers.

func New() *Director

func (d *Director) Do(c context.Context, work *worker.Work)

Do processes the work request async.

func (d *Director) GetAssignemnts() []*worker.Assignment

GetAssignments returns a list of assignments. The assignment type is a structure that stores the work being performed and the assigned worker.

func (d *Director) GetPending() []*worker.Work

GetPending returns a list of all work that is pending assignment to a worker.

func (d *Director) GetStarted() []*worker.Work

GetStarted returns a list of all jobs that are assigned and being worked on.