Functor Protocol.WorkerResponse

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

Messages from the worker to the controller

Parameters:

Job : MapReduce.Job

type t =

`\|`	`JobFailed of string`	`(*`	The application threw the given exception with stacktrace	`*)`
`\|`	`MapResult of (Job.key * Job.inter) list`	`(*`	successful map output	`*)`
`\|`	`ReduceResult of Job.output`	`(*`	successful reduce output	`*)`

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: