Skip to content

Commit 3290110

Browse files
add bidirectional streaming support for external snapshot streaming (#266)
1 parent 4a519e5 commit 3290110

File tree

3 files changed

+98
-88
lines changed

3 files changed

+98
-88
lines changed

protos/api.v2.proto

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ service Dgraph {
3131
rpc ListNamespaces(ListNamespacesRequest) returns (ListNamespacesResponse) {}
3232

3333
rpc UpdateExtSnapshotStreamingState(UpdateExtSnapshotStreamingStateRequest) returns (UpdateExtSnapshotStreamingStateResponse) {}
34-
rpc StreamExtSnapshot(stream StreamExtSnapshotRequest) returns (StreamExtSnapshotResponse) {}
34+
rpc StreamExtSnapshot(stream StreamExtSnapshotRequest) returns (stream StreamExtSnapshotResponse) {}
3535
}
3636

3737
message PingRequest {}
@@ -178,7 +178,9 @@ message StreamExtSnapshotRequest {
178178
StreamPacket pkt = 3;
179179
}
180180

181-
message StreamExtSnapshotResponse {}
181+
message StreamExtSnapshotResponse {
182+
bool finish = 1;
183+
}
182184

183185
message StreamPacket {
184186
bytes data = 1;

protos/api.v2/api.v2.pb.go

Lines changed: 89 additions & 79 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

protos/api.v2/api.v2_grpc.pb.go

Lines changed: 5 additions & 7 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)