Skip to content

Commit 2831fdb

Browse files
modify import apis for HA+Sharded cluster (#260)
1 parent 9f3d5dc commit 2831fdb

File tree

5 files changed

+274
-237
lines changed

5 files changed

+274
-237
lines changed

protos/api.v2.proto

Lines changed: 15 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,9 @@ service Dgraph {
2929
rpc DropNamespace(DropNamespaceRequest) returns (DropNamespaceResponse) {}
3030
rpc UpdateNamespace(UpdateNamespaceRequest) returns (UpdateNamespaceResponse) {}
3131
rpc ListNamespaces(ListNamespacesRequest) returns (ListNamespacesResponse) {}
32-
rpc InitiatePDirStream (InitiatePDirStreamRequest) returns (InitiatePDirStreamResponse) {}
33-
rpc StreamPDir(stream StreamPDirRequest) returns (StreamPDirResponse) {}
32+
33+
rpc UpdateExtSnapshotStreamingState(UpdateExtSnapshotStreamingStateRequest) returns (UpdateExtSnapshotStreamingStateResponse) {}
34+
rpc StreamExtSnapshot(stream StreamExtSnapshotRequest) returns (StreamExtSnapshotResponse) {}
3435
}
3536

3637
message PingRequest {}
@@ -161,23 +162,25 @@ message Namespace {
161162
uint64 id = 2;
162163
}
163164

164-
message InitiatePDirStreamRequest {}
165-
166-
message InitiatePDirStreamResponse {
167-
repeated uint32 groups = 1;
165+
message UpdateExtSnapshotStreamingStateRequest {
166+
bool start = 1;
167+
bool finish = 2;
168+
bool drop_data = 3;
168169
}
169170

170-
message StreamPDirRequest {
171-
uint32 group_id =1;
172-
StreamPacket stream_packet = 2;
171+
message UpdateExtSnapshotStreamingStateResponse {
172+
repeated uint32 groups = 1;
173173
}
174174

175-
message StreamPDirResponse {
176-
bool done = 1;
175+
message StreamExtSnapshotRequest {
176+
uint32 group_id = 1;
177+
bool forward = 2;
178+
StreamPacket pkt = 3;
177179
}
178180

181+
message StreamExtSnapshotResponse {}
182+
179183
message StreamPacket {
180184
bytes data = 1;
181185
bool done = 2;
182186
}
183-

0 commit comments

Comments
 (0)