Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CallExample ¶
func CallExample()
example function to show how to make an RPC call to the coordinator.
the RPC argument and reply types are defined in rpc.go.
Types ¶
type Coordinator ¶
type Coordinator struct { }
func MakeCoordinator ¶
func MakeCoordinator(files []string, nReduce int) *Coordinator
create a Coordinator. main/mrcoordinator.go calls this function. nReduce is the number of reduce tasks to use.
func (*Coordinator) Done ¶
func (c *Coordinator) Done() bool
main/mrcoordinator.go calls Done() periodically to find out if the entire job has finished.
func (*Coordinator) Example ¶
func (c *Coordinator) Example(args *ExampleArgs, reply *ExampleReply) error
an example RPC handler.
the RPC argument and reply types are defined in rpc.go.
type ExampleArgs ¶
type ExampleArgs struct {
X int
}
type ExampleReply ¶
type ExampleReply struct {
Y int
}
Click to show internal directories.
Click to hide internal directories.