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

Method StreamExtSnapshot

protos/pb/pb_grpc.pb.go:925–925  ·  view source on GitHub ↗
(ctx context.Context, opts ...grpc.CallOption)

Source from the content-addressed store, hash-verified

923 TaskStatus(ctx context.Context, in *TaskStatusRequest, opts ...grpc.CallOption) (*TaskStatusResponse, error)
924 UpdateExtSnapshotStreamingState(ctx context.Context, in *api.UpdateExtSnapshotStreamingStateRequest, opts ...grpc.CallOption) (*Status, error)
925 StreamExtSnapshot(ctx context.Context, opts ...grpc.CallOption) (Worker_StreamExtSnapshotClient, error)
926}
927
928type workerClient struct {

Callers 5

InStreamFunction · 0.95
streamInGroupFunction · 0.95
_Worker_StreamExtSnapshot_HandlerFunction · 0.65
attemptDoneOnlyStreamFunction · 0.65
streamSnapshotForGroupFunction · 0.65

Implementers 3

workerClientprotos/pb/pb_grpc.pb.go
UnimplementedWorkerServerprotos/pb/pb_grpc.pb.go
grpcWorkerworker/worker.go

Calls

no outgoing calls

Tested by 1

attemptDoneOnlyStreamFunction · 0.52