feat: add method SyncHost to service DfdaemonUpload (#431)

Signed-off-by: baowj <[email protected]>
dragonflyoss · Dec 31, 2024 · 190d05d · 190d05d
1 parent af929d0
commit 190d05d
Show file tree

Hide file tree

Showing 9 changed files with 540 additions and 147 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "dragonfly-api"
-version = "2.1.0"
+version = "2.1.1"
 authors = ["Gaius <[email protected]>"]
 edition = "2021"
 license = "Apache-2.0"

diff --git a/pkg/apis/dfdaemon/v2/dfdaemon.pb.go b/pkg/apis/dfdaemon/v2/dfdaemon.pb.go
diff --git a/pkg/apis/dfdaemon/v2/dfdaemon.pb.validate.go b/pkg/apis/dfdaemon/v2/dfdaemon.pb.validate.go
diff --git a/pkg/apis/dfdaemon/v2/dfdaemon.proto b/pkg/apis/dfdaemon/v2/dfdaemon.proto
@@ -194,6 +194,14 @@ message DeletePersistentCacheTaskRequest {
   string task_id = 1 [(validate.rules).string.min_len = 1];
 }
 
+// SyncHostRequest represents request of SyncHost.
+message SyncHostRequest {
+  // Host id.
+  string host_id = 1 [(validate.rules).string.min_len = 1];
+  // Peer id.
+  string peer_id = 2 [(validate.rules).string.min_len = 1];
+}
+
 // DfdaemonUpload represents dfdaemon upload service.
 service DfdaemonUpload {
   // DownloadTask downloads task from p2p network.
@@ -219,6 +227,9 @@ service DfdaemonUpload {
 
   // DeletePersistentCacheTask deletes persistent cache task from p2p network.
   rpc DeletePersistentCacheTask(DeletePersistentCacheTaskRequest) returns(google.protobuf.Empty);
+
+  // SyncHost sync host info from parents.
+  rpc SyncHost(SyncHostRequest) returns (stream common.v2.Host);
 }
 
 // DfdaemonDownload represents dfdaemon download service.

diff --git a/pkg/apis/dfdaemon/v2/dfdaemon_grpc.pb.go b/pkg/apis/dfdaemon/v2/dfdaemon_grpc.pb.go
diff --git a/proto/dfdaemon.proto b/proto/dfdaemon.proto
@@ -181,6 +181,14 @@ message DeletePersistentCacheTaskRequest {
   string task_id = 1;
 }
 
+// SyncHostRequest represents request of SyncHost.
+message SyncHostRequest {
+  // Host id.
+  string host_id = 1;
+  // Peer id.
+  string peer_id = 2;
+}
+
 // DfdaemonUpload represents upload service of dfdaemon.
 service DfdaemonUpload{
   // DownloadTask downloads task from p2p network.
@@ -206,6 +214,9 @@ service DfdaemonUpload{
 
   // DeletePersistentCacheTask deletes persistent cache task from p2p network.
   rpc DeletePersistentCacheTask(DeletePersistentCacheTaskRequest) returns(google.protobuf.Empty);
+
+  // SyncHost sync host info from parents.
+  rpc SyncHost(SyncHostRequest) returns (stream common.v2.Host);
 }
 
 // DfdaemonDownload represents download service of dfdaemon.

diff --git a/src/descriptor.bin b/src/descriptor.bin