rpc

type AbortReduceTaskArgs struct{}

type AbortReduceTaskReply struct{}

type DefaultRpcGateway struct {
}

type GetHeartBeatArgs struct{}

type GetHeartBeatReply struct {
	MapTask    *MapTaskState
	ReduceTask *ReduceTaskState
}

type IntermediateFile struct {
	Location    string
	Partition   uint16
	SizeInBytes uint64
}

type MapTaskState struct {
	Id                uint16
	Status            TaskStatus
	IntermediateFiles []IntermediateFile
}

type ReduceTaskState struct {
	Id                 uint16
	Status             TaskStatus
	PartitionNumber    uint16
	OutputFileLocation string
}

type RpcGateway interface {
	Call(address string, methodName string, args any, reply any) error
}

type StartMapTaskArgs struct {
	Id                     uint16
	InputFileSplitLocation string
}

type StartMapTaskReply struct{}

type StartReduceTaskArgs struct {
	Id                uint16
	IntermediateFiles []IntermediateFile
}

type StartReduceTaskReply struct{}

type TaskStatus uint8