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

Method WorkerRegister

rpc/master_grpc.pb.go:21–21  ·  view source on GitHub ↗
(ctx context.Context, in *WorkerInfo, opts ...grpc.CallOption)

Source from the content-addressed store, hash-verified

19// 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.
20type MasterClient interface {
21 WorkerRegister(ctx context.Context, in *WorkerInfo, opts ...grpc.CallOption) (*RegisterResult, error)
22 // IMD = InterMeDiate
23 UpdateIMDInfo(ctx context.Context, in *IMDInfo, opts ...grpc.CallOption) (*UpdateResult, error)
24}

Callers 2

WorkerRegisterFunction · 0.95

Implementers 3

masterClientrpc/master_grpc.pb.go
UnimplementedMasterServerrpc/master_grpc.pb.go
Mastermaster/master.go

Calls

no outgoing calls

Tested by

no test coverage detected