Copyright © 2007-2013 Zuse Institute Berlin
Version: $Id$
Authors: Jan Fajerski (fajerski@informatik.hu-berlin.de).
message() = {mr_master, init, Client :: comm:mypid(), mr_state:jobid(), JobSpec :: mr_state:job_description()} | {mr_master, mr_state:jobid(), snapshot, snapshot_leader:result_message(), mr_state:job_description(), comm:mypid()} | {mr_master, mr_state:jobid(), phase_completed, Round :: non_neg_integer(), Range :: intervals:interval()} | {mr_master, mr_state:jobid(), job_completed, intervals:interval()} | {mr_master, mr_state:jobid(), job_error, intervals:interval()}
dispatch_snapshot/1 | |
init_job/4 | |
on/2 |
init_job(State :: dht_node_state:state(), JobId :: nonempty_string(), Job :: mr_state:job_description(), Client :: comm:mypid()) -> dht_node_state:state()
dispatch_snapshot(JobId :: mr_state:jobid()) -> ok
on(Msg :: message(), State :: dht_node_state:state()) -> dht_node_state:state()
Generated by EDoc, Feb 29 2016, 16:16:26.