rpc

package

v0.0.0-...-e147593 Latest Latest Go to latest Published: May 31, 2023 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type AbortReduceTaskArgs struct{}

type AbortReduceTaskReply struct{}

type DefaultRpcGateway struct {
}

func (rpcGateway DefaultRpcGateway) Call(
	address string,
	methodName string,
	args any,
	reply any,
) error

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

const (
	Idle       TaskStatus = 0
	InProgress TaskStatus = 1
	Completed  TaskStatus = 2
)