mr

type ByKey ¶

type ByKey []KeyValue

for sorting by key.

func (a ByKey) Len() int

func (a ByKey) Less(i, j int) bool

func (a ByKey) Swap(i, j int)

type ExampleArgs ¶

type ExampleArgs struct {
	X int
}

example to show how to declare the arguments and reply for an RPC.

type ExampleReply ¶

type ExampleReply struct {
	Y int
}

type KeyValue ¶

type KeyValue struct {
	Key   string
	Value string
}

Map functions return a slice of KeyValue.

type Master ¶

type Master struct {
	// contains filtered or unexported fields
}

func MakeMaster(files []string, nReduce int) *Master

func (m *Master) Done() bool

func (m *Master) Example(args *ExampleArgs, reply *ExampleReply) error

func (m *Master) ReportTask(args *ReportTaskArgs, reply *ReportTaskReply) error

func (m *Master) RequestTask(args *RequestTaskArgs, reply *RequestTaskReply) error

type ReportTaskArgs ¶

type ReportTaskArgs struct {
	Task Task
}

args and reply for CallReportTask RPC

type ReportTaskReply ¶

type ReportTaskReply struct {
}

type RequestTaskArgs ¶

type RequestTaskArgs struct {
}

args and reply for CallRequestTask

type RequestTaskReply ¶

type RequestTaskReply struct {
	Task            Task
	WorkerNextState int
}

func CallRequestTask() (RequestTaskReply, error)

type Task ¶

type Task struct {
	Id           int
	TaskType     int
	State        int
	Filename     string
	TimeStamp    time.Time
	NumsOfMap    int
	NumsOfReduce int
}

master maintain the full consistent info of Task, worker only need part of it to work