Skip to content

Commit 096fa43

Browse files
committed
feat: remove host_id and task_id in RegisterPersistentCachePeerRequest
Signed-off-by: Gaius <gaius.qi@gmail.com>
1 parent 352bcc2 commit 096fa43

File tree

8 files changed

+341
-399
lines changed

8 files changed

+341
-399
lines changed

Cargo.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[package]
22
name = "dragonfly-api"
3-
version = "2.1.6"
3+
version = "2.1.7"
44
authors = ["Gaius <gaius.qi@gmail.com>"]
55
edition = "2021"
66
license = "Apache-2.0"

pkg/apis/scheduler/v2/scheduler.pb.go

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

pkg/apis/scheduler/v2/scheduler.pb.validate.go

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

pkg/apis/scheduler/v2/scheduler.proto

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -226,20 +226,16 @@ message DeleteHostRequest{
226226

227227
// RegisterPersistentCachePeerRequest represents persistent cache peer registered request of AnnouncePersistentCachePeerRequest.
228228
message RegisterPersistentCachePeerRequest {
229-
// Host id.
230-
string host_id = 1 [(validate.rules).string.min_len = 1];
231-
// Task id.
232-
string task_id = 2 [(validate.rules).string.min_len = 1];
233229
// Tag is used to distinguish different persistent cache tasks.
234-
optional string tag = 3;
230+
optional string tag = 1;
235231
// Application of task.
236-
optional string application = 4;
232+
optional string application = 2;
237233
// Task piece length.
238-
uint64 piece_length = 5 [(validate.rules).uint64.gte = 1];
234+
uint64 piece_length = 3 [(validate.rules).uint64.gte = 1];
239235
// File path to be exported.
240-
optional string output_path = 6 [(validate.rules).string = {min_len: 1, ignore_empty: true}];
236+
optional string output_path = 4 [(validate.rules).string = {min_len: 1, ignore_empty: true}];
241237
// Download timeout.
242-
optional google.protobuf.Duration timeout = 7;
238+
optional google.protobuf.Duration timeout = 5;
243239
}
244240

245241
// DownloadPersistentCachePeerStartedRequest represents persistent cache peer download started request of AnnouncePersistentCachePeerRequest.

proto/scheduler.proto

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -217,20 +217,16 @@ message DeleteHostRequest{
217217

218218
// RegisterPersistentCachePeerRequest represents persistent cache peer registered request of AnnouncePersistentCachePeerRequest.
219219
message RegisterPersistentCachePeerRequest {
220-
// Host id.
221-
string host_id = 1;
222-
// Task id.
223-
string task_id = 2;
224220
// Tag is used to distinguish different persistent cache tasks.
225-
optional string tag = 3;
221+
optional string tag = 1;
226222
// Application of task.
227-
optional string application = 4;
223+
optional string application = 2;
228224
// Task piece length.
229-
uint64 piece_length = 5;
225+
uint64 piece_length = 3;
230226
// File path to be exported.
231-
optional string output_path = 6;
227+
optional string output_path = 4;
232228
// Download timeout.
233-
optional google.protobuf.Duration timeout = 7;
229+
optional google.protobuf.Duration timeout = 5;
234230
}
235231

236232
// DownloadPersistentCachePeerStartedRequest represents persistent cache peer download started request of AnnouncePersistentCachePeerRequest.

src/descriptor.bin

-192 Bytes
Binary file not shown.

src/scheduler.v2.rs

Lines changed: 5 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -334,26 +334,20 @@ pub struct DeleteHostRequest {
334334
#[allow(clippy::derive_partial_eq_without_eq)]
335335
#[derive(Clone, PartialEq, ::prost::Message)]
336336
pub struct RegisterPersistentCachePeerRequest {
337-
/// Host id.
338-
#[prost(string, tag = "1")]
339-
pub host_id: ::prost::alloc::string::String,
340-
/// Task id.
341-
#[prost(string, tag = "2")]
342-
pub task_id: ::prost::alloc::string::String,
343337
/// Tag is used to distinguish different persistent cache tasks.
344-
#[prost(string, optional, tag = "3")]
338+
#[prost(string, optional, tag = "1")]
345339
pub tag: ::core::option::Option<::prost::alloc::string::String>,
346340
/// Application of task.
347-
#[prost(string, optional, tag = "4")]
341+
#[prost(string, optional, tag = "2")]
348342
pub application: ::core::option::Option<::prost::alloc::string::String>,
349343
/// Task piece length.
350-
#[prost(uint64, tag = "5")]
344+
#[prost(uint64, tag = "3")]
351345
pub piece_length: u64,
352346
/// File path to be exported.
353-
#[prost(string, optional, tag = "6")]
347+
#[prost(string, optional, tag = "4")]
354348
pub output_path: ::core::option::Option<::prost::alloc::string::String>,
355349
/// Download timeout.
356-
#[prost(message, optional, tag = "7")]
350+
#[prost(message, optional, tag = "5")]
357351
pub timeout: ::core::option::Option<::prost_wkt_types::Duration>,
358352
}
359353
/// DownloadPersistentCachePeerStartedRequest represents persistent cache peer download started request of AnnouncePersistentCachePeerRequest.

0 commit comments

Comments
 (0)