Method Map

rpc/worker_grpc.pb.go:21–21

(ctx context.Context, in *MapInfo, opts ...grpc.CallOption)

// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type WorkerClient interface {
	Map(ctx context.Context, in *MapInfo, opts ...grpc.CallOption) (*Result, error)
	Reduce(ctx context.Context, in *ReduceInfo, opts ...grpc.CallOption) (*Result, error)
	// IMD = InterMeDiate
	GetIMDData(ctx context.Context, in *IMDLoc, opts ...grpc.CallOption) (*JSONKVs, error)