feat: add candidate_parent_ids to reschedule message (#245)

Signed-off-by: Gaius <[email protected]>
dragonflyoss · Jan 9, 2024 · e082eef · e082eef
1 parent e759b2e
commit e082eef
Show file tree

Hide file tree

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

diff --git a/pkg/apis/scheduler/v2/scheduler.pb.go b/pkg/apis/scheduler/v2/scheduler.pb.go
diff --git a/pkg/apis/scheduler/v2/scheduler.proto b/pkg/apis/scheduler/v2/scheduler.proto
@@ -44,8 +44,11 @@ message DownloadPeerBackToSourceStartedRequest {
 
 // RescheduleRequest represents reschedule request of AnnouncePeerRequest.
 message RescheduleRequest {
+  // Candidate parent ids.
+  repeated string candidate_parent_ids = 1;
+
   // The description of the reschedule reason.
-  optional string description = 1 [(validate.rules).string.min_len = 1];
+  optional string description = 2 [(validate.rules).string.min_len = 1];
 }
 
 // DownloadPeerFinishedRequest represents peer download finished request of AnnouncePeerRequest.

diff --git a/proto/scheduler.proto b/proto/scheduler.proto
@@ -41,8 +41,11 @@ message DownloadPeerBackToSourceStartedRequest {
 
 // RescheduleRequest represents reschedule request of AnnouncePeerRequest.
 message RescheduleRequest {
+  // Candidate parent ids.
+  repeated string candidate_parent_ids = 1;
+
   // The description of the reschedule reason.
-  optional string description = 1;
+  optional string description = 2;
 }
 
 // DownloadPeerFinishedRequest represents peer download finished request of AnnouncePeerRequest.

diff --git a/src/descriptor.bin b/src/descriptor.bin
diff --git a/src/scheduler.v2.rs b/src/scheduler.v2.rs
@@ -26,8 +26,11 @@ pub struct DownloadPeerBackToSourceStartedRequest {
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct RescheduleRequest {
+    /// Candidate parent ids.
+    #[prost(string, repeated, tag = "1")]
+    pub candidate_parent_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
     /// The description of the reschedule reason.
-    #[prost(string, optional, tag = "1")]
+    #[prost(string, optional, tag = "2")]
     pub description: ::core::option::Option<::prost::alloc::string::String>,
 }
 /// DownloadPeerFinishedRequest represents peer download finished request of AnnouncePeerRequest.