MCPcopy Create free account
hub / github.com/BWbwchen/MapReduce / GetIMDData

Method GetIMDData

rpc/worker_grpc.pb.go:24–24  ·  view source on GitHub ↗

IMD = InterMeDiate

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

Source from the content-addressed store, hash-verified

22 Reduce(ctx context.Context, in *ReduceInfo, opts ...grpc.CallOption) (*Result, error)
23 // IMD = InterMeDiate
24 GetIMDData(ctx context.Context, in *IMDLoc, opts ...grpc.CallOption) (*JSONKVs, error)
25 // rpc HealthCheck (IMDInfo) returns (UpdateResult);
26 End(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
27 Health(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*WorkerState, error)

Callers 2

GetIMDDataFunction · 0.95

Implementers 3

Workerworker/worker.go
workerClientrpc/worker_grpc.pb.go
UnimplementedWorkerServerrpc/worker_grpc.pb.go

Calls

no outgoing calls

Tested by

no test coverage detected