MCPcopy
hub / github.com/dgraph-io/dgraph / Recv

Method Recv

protos/pb/pb_grpc.pb.go:405–405  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

403
404type Zero_OracleClient interface {
405 Recv() (*OracleDelta, error)
406 grpc.ClientStream
407}
408

Callers 15

listenToHeartbeatMethod · 0.65
RaftMessageMethod · 0.65
attemptDoneOnlyStreamFunction · 0.65
streamSnapshotForGroupFunction · 0.65
streamBadgerFunction · 0.65
handlePublisherMethod · 0.65
runForwardSubscriberMethod · 0.65
InStreamFunction · 0.65
pipeTwoStreamFunction · 0.65
StreamExtSnapshotMethod · 0.65
populateSnapshotMethod · 0.65
doStreamSnapshotFunction · 0.65

Implementers 10

raftHeartbeatClientprotos/pb/pb_grpc.pb.go
raftRaftMessageServerprotos/pb/pb_grpc.pb.go
zeroStreamMembershipClientprotos/pb/pb_grpc.pb.go
zeroOracleClientprotos/pb/pb_grpc.pb.go
workerStreamSnapshotClientprotos/pb/pb_grpc.pb.go
workerSubscribeClientprotos/pb/pb_grpc.pb.go
workerStreamExtSnapshotClientprotos/pb/pb_grpc.pb.go
workerStreamSnapshotServerprotos/pb/pb_grpc.pb.go
workerReceivePredicateServerprotos/pb/pb_grpc.pb.go
workerStreamExtSnapshotServerprotos/pb/pb_grpc.pb.go

Calls

no outgoing calls

Tested by 1

attemptDoneOnlyStreamFunction · 0.52