worker

type KV struct {
	Key   string `json:"k"`
	Value string `json:"v"`
}

type MapFormat (func(string, string, MrContext))

type MrContext struct {
	Chan chan KV
}

type ReduceFormat (func(string, []string, MrContext))

type RpcClient interface {
	//Connect()
	WorkerRegister(w *rpc.WorkerInfo) (int, error)
	UpdateIMDInfo(u *rpc.IMDInfo) bool
	GetIMDData(ip string, filename string) []KV
}

type Worker struct {
	UUID string
	ID   int

	Mapf    MapFormat
	Reducef ReduceFormat
	Chan    MrContext
	EndChan chan bool

	State  rpc.WorkerState_State
	Client RpcClient

	rpc.UnimplementedWorkerServer
	// contains filtered or unexported fields
}