mr

type Args ¶

type Args struct {
	Task Task
}

Args RPC 参数

type ByKey ¶

type ByKey []KeyValue

func (a ByKey) Len() int

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

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

type Coordinator ¶

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

Coordinator 管理和调度任务，包括划分任务，管理任务状态 同时 Coordinator 需要知道 Worker 的状态 队列机制使用 channel 实现 任务包括 2 阶段，Map 和 Reduce，先 Map 后 Reduce

func MakeCoordinator(files []string, nReduce int) *Coordinator

func (m *Coordinator) Done() bool

func (m *Coordinator) FinishTaskHandler(args Args, reply *FinishTaskReply) error

func (m *Coordinator) GetTaskHandler(args Args, reply *GetTaskReply) error

type Err ¶

type Err string

type FinishTaskReply ¶

type FinishTaskReply struct {
	Reply
}

type GetArgs ¶

type GetArgs struct {
	Key string
}

type GetReply ¶

type GetReply struct {
	Err   Err
	Value string
}

type GetTaskReply ¶

type GetTaskReply struct {
	Reply    Reply
	Task     Task
	FileName string
	NReduce  int
	MMap     int
}

type KV ¶

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

func (kv *KV) Get(args *GetArgs, reply *GetReply) error

func (kv *KV) Put(args *PutArgs, reply *PutReply) error

type KeyValue ¶

type KeyValue struct {
	Key   string
	Value string
}

KeyValue Map functions return a slice of KeyValue.

type PutArgs ¶

type PutArgs struct {
	Key   string
	Value string
}

type PutReply ¶

type PutReply struct {
	Err Err
}

type Reply ¶

type Reply struct {
	State int
}

Reply RPC 返回值

type Task ¶

type Task struct {
	TaskType string
	// Id 用于对应文件名
	Id int
}

Task 任务信息