Skip to content

Commit 337c8b7

Browse files
Add import API for Dgraph v25 (#228)
1 parent 363877e commit 337c8b7

File tree

4 files changed

+488
-87
lines changed

4 files changed

+488
-87
lines changed

.trunk/trunk.yaml

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,13 @@
33
version: 0.1
44

55
cli:
6-
version: 1.22.10
6+
version: 1.22.12
77

88
# Trunk provides extensibility via plugins. (https://docs.trunk.io/plugins)
99
plugins:
1010
sources:
1111
- id: trunk
12-
ref: v1.6.7
12+
ref: v1.6.8
1313
uri: https://github.com/trunk-io/plugins
1414

1515
# Many linters and tools depend on runtimes - configure them here. (https://docs.trunk.io/runtimes)
@@ -27,18 +27,18 @@ lint:
2727
- protos/api/*.pb.go
2828
- protos/api.v25/*.pb.go
2929
enabled:
30-
- trivy@0.60.0
31-
- renovate@39.194.0
30+
- trivy@0.61.1
31+
- renovate@39.253.2
3232
33-
33+
3434
- git-diff-check
3535
36-
36+
3737
38-
- osv-scanner@1.9.2
38+
- osv-scanner@2.0.1
3939
40-
41-
- yamllint@1.36.0
40+
41+
- yamllint@1.37.0
4242
actions:
4343
enabled:
4444
- trunk-announce

protos/api.v25.proto

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,8 @@ service Dgraph {
2929
rpc DropNamespace(DropNamespaceRequest) returns (DropNamespaceResponse) {}
3030
rpc UpdateNamespace(UpdateNamespaceRequest) returns (UpdateNamespaceResponse) {}
3131
rpc ListNamespaces(ListNamespacesRequest) returns (ListNamespacesResponse) {}
32+
rpc InitiateSnapshotStream (InitiateSnapshotStreamRequest) returns (InitiateSnapshotStreamResponse) {}
33+
rpc StreamSnapshot(stream StreamSnapshotRequest) returns (StreamSnapshotResponse) {}
3234
}
3335

3436
message PingRequest {}
@@ -158,3 +160,24 @@ message Namespace {
158160
string name = 1;
159161
uint64 id = 2;
160162
}
163+
164+
message InitiateSnapshotStreamRequest {}
165+
166+
message InitiateSnapshotStreamResponse {
167+
repeated uint32 groups = 1;
168+
}
169+
170+
message StreamSnapshotRequest {
171+
uint32 group_id =1;
172+
KVS pairs = 2;
173+
}
174+
175+
message StreamSnapshotResponse {
176+
bool done = 1;
177+
}
178+
179+
message KVS {
180+
bytes data = 1;
181+
bool done = 2;
182+
}
183+

0 commit comments

Comments
 (0)