Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
404
type
Zero_OracleClient
interface
{
405
Recv() (*OracleDelta, error)
406
grpc.ClientStream
407
}
408
Callers
15
listenToHeartbeat
Method · 0.65
RaftMessage
Method · 0.65
attemptDoneOnlyStream
Function · 0.65
streamSnapshotForGroup
Function · 0.65
streamBadger
Function · 0.65
handlePublisher
Method · 0.65
runForwardSubscriber
Method · 0.65
InStream
Function · 0.65
pipeTwoStream
Function · 0.65
StreamExtSnapshot
Method · 0.65
populateSnapshot
Method · 0.65
doStreamSnapshot
Function · 0.65
Implementers
10
raftHeartbeatClient
protos/pb/pb_grpc.pb.go
raftRaftMessageServer
protos/pb/pb_grpc.pb.go
zeroStreamMembershipClient
protos/pb/pb_grpc.pb.go
zeroOracleClient
protos/pb/pb_grpc.pb.go
workerStreamSnapshotClient
protos/pb/pb_grpc.pb.go
workerSubscribeClient
protos/pb/pb_grpc.pb.go
workerStreamExtSnapshotClient
protos/pb/pb_grpc.pb.go
workerStreamSnapshotServer
protos/pb/pb_grpc.pb.go
workerReceivePredicateServer
protos/pb/pb_grpc.pb.go
workerStreamExtSnapshotServer
protos/pb/pb_grpc.pb.go
Calls
no outgoing calls
Tested by
1
attemptDoneOnlyStream
Function · 0.52