master

type FileInfo struct {
	FileName string
	From     int
	To       int
}

type IMDInfo struct {
	IP       string
	FileName string
}

type MapTaskInfo struct {
	Files     []FileInfo
	TaskState int
	UUID      string
}

type Master struct {
	Workers     []WorkerInfo
	MapTasks    []MapTaskInfo
	ReduceTasks []ReduceTaskInfo

	rpc.UnimplementedMasterServer
	// contains filtered or unexported fields
}

type ReduceTaskInfo struct {
	IMDs      []IMDInfo
	TaskState int
	UUID      string
}

type RpcClient interface {
	Connect(workerIP string) (*grpc.ClientConn, rpc.WorkerClient)
	Map(workerIP string, m *rpc.MapInfo) bool
	Reduce(workerIP string, m *rpc.ReduceInfo) bool
	End(workerIP string) bool
	Health(workerIP string) int
}

type WorkerInfo struct {
	UUID        string
	IP          string
	WorkerState int
	// contains filtered or unexported fields
}