feat: add delegation_token for ObjectStorage (#413)

Signed-off-by: BruceAko <[email protected]>

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "dragonfly-api"
-version = "2.0.169"
+version = "2.0.170"
 authors = ["Gaius <[email protected]>"]
 edition = "2021"
 license = "Apache-2.0"

pkg/apis/common/v2/common.proto

@@ -431,6 +431,8 @@ message Download {
   bool prefetch = 16;
   // Object Storage related information.
   optional ObjectStorage object_storage = 17;
+  // HDFS related information.
+  optional HDFS hdfs = 18;
 }
 
 // Object Storage related information.
@@ -451,6 +453,12 @@ message ObjectStorage {
   optional string predefined_acl = 7 [(validate.rules).string = {min_len: 1, ignore_empty: true}];
 }
 
+// HDFS related information.
+message HDFS {
+  // Delegation token for Web HDFS operator.
+  optional string delegation_token = 1 [(validate.rules).string = {min_len: 1, ignore_empty: true}];
+}
+
 // Range represents download range.
 message Range {
   // Start of range.

proto/common.proto

@@ -427,6 +427,8 @@ message Download {
   bool prefetch = 16;
   // Object Storage related information.
   optional ObjectStorage object_storage = 17;
+  // HDFS related information.
+  optional HDFS hdfs = 18;
 }
 
 // Object Storage related information.
@@ -447,6 +449,12 @@ message ObjectStorage {
   optional string predefined_acl = 7;
 }
 
+// HDFS related information.
+message HDFS {
+  // Delegation token for Web HDFS operator.
+  optional string delegation_token = 1;
+}
+
 // Range represents download range.
 message Range {
   // Start of range.

src/common.v2.rs

@@ -479,6 +479,9 @@ pub struct Download {
     /// Object Storage related information.
     #[prost(message, optional, tag = "17")]
     pub object_storage: ::core::option::Option<ObjectStorage>,
+    /// HDFS related information.
+    #[prost(message, optional, tag = "18")]
+    pub hdfs: ::core::option::Option<Hdfs>,
 }
 /// Object Storage related information.
 #[derive(serde::Serialize, serde::Deserialize)]
@@ -507,6 +510,15 @@ pub struct ObjectStorage {
     #[prost(string, optional, tag = "7")]
     pub predefined_acl: ::core::option::Option<::prost::alloc::string::String>,
 }
+/// HDFS related information.
+#[derive(serde::Serialize, serde::Deserialize)]
+#[allow(clippy::derive_partial_eq_without_eq)]
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct Hdfs {
+    /// Delegation token for Web HDFS operator.
+    #[prost(string, optional, tag = "1")]
+    pub delegation_token: ::core::option::Option<::prost::alloc::string::String>,
+}
 /// Range represents download range.
 #[derive(serde::Serialize, serde::Deserialize)]
 #[allow(clippy::derive_partial_eq_without_eq)]