Functor Protocol.WorkerRequest

module WorkerRequest: functor (Job : MapReduce.Job) -> sig .. end

Messages from the controller to the worker

Parameters:

Job : MapReduce.Job

type t =

`\|`	`MapRequest of Job.input`	`(*`	run the map phase for an input	`*)`
`\|`	`ReduceRequest of Job.key * Job.inter list`	`(*`	process the values associated with the given key	`*)`

include Protocol.Marshalable

You can send and receive WorkerRequest(J).ts by calling WorkerRequest(J).send and receive respectively. These functions are inherited from Marshalable: