Module Protocol

module Protocol: sig .. end

The messages sent between the worker and the controller.

Sending and receiving messages

module type Marshalable = sig .. end

Send or receive marshaled messages through Reader or Writer

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

Messages from the controller to the worker

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

Messages from the worker to the controller