Ydb stable 22-4-2122.4.21

x-stable-origin-commit: e89099581237299a132feafb5b58af59ebd0468a

1 files changed, 45 insertions, 0 deletions

diff --git a/ydb/public/api/protos/draft/datastreams.proto b/ydb/public/api/protos/draft/datastreams.proto
index 01a0e5ec704..a995fb24a26 100644
--- a/ydb/public/api/protos/draft/datastreams.proto
+++ b/ydb/public/api/protos/draft/datastreams.proto
@@ -16,6 +16,7 @@ enum EFieldTransformationType {
     TRANSFORM_EMPTY_TO_NOTHING = 3;
 }
 
+
 extend google.protobuf.FieldOptions {
     EFieldTransformationType FieldTransformer = 58123;
 }
@@ -28,6 +29,13 @@ enum EncryptionType {
     KMS = 2;
 }
 
+enum StreamMode {
+    STREAM_MODE_UNDEFINED = 0;
+    PROVISIONED = 1;
+    ON_DEMAND = 2;
+}
+
+
 message EnhancedMetrics {
     // List of shard-level metrics
     repeated string shard_level_metrics = 1;
@@ -103,8 +111,15 @@ message StreamDescription {
     StreamStatus stream_status = 9;
     // Name of the stream
     string stream_name = 10;
+    // YDS-specific Write quota in KB/S
     int32 write_quota_kb_per_sec = 11;
+    // YDS-specific Owner of the stream
     string owner = 12;
+    // YDS-specific Storage limit in MB of the stream
+    int64 storage_limit_mb = 13;
+
+    // stream metering mode
+    StreamModeDetails stream_mode_details = 14;
 }
 
 // Represents range of possible sequence numbers for the shard
@@ -253,6 +268,11 @@ message Tag {
     string value = 2;
 }
 
+// Represents stream mode details
+message StreamModeDetails {
+    StreamMode stream_mode = 1;
+}
+
 message CreateStreamRequest {
     Ydb.Operations.OperationParams operation_params = 1;
     // Name of the stream
@@ -267,6 +287,8 @@ message CreateStreamRequest {
         // Retention storage in megabytes
         int32 retention_storage_megabytes = 6;
     }
+    // stream metering mode
+    StreamModeDetails stream_mode_details = 7;
 }
 
 message CreateStreamResponse {
@@ -371,6 +393,9 @@ message UpdateStreamRequest {
         // Retention storage in megabytes
         int32 retention_storage_megabytes = 6;
     }
+    // stream metering mode
+    StreamModeDetails stream_mode_details = 7;
+
 }
 
 message UpdateStreamResponse {
@@ -864,3 +889,23 @@ message UpdateShardCountResult {
     // Updated number of shards
     int32 target_shard_count = 3;
 }
+
+
+message UpdateStreamModeRequest {
+    Ydb.Operations.OperationParams operation_params = 1;
+    // Stream name or arn
+    string stream_arn = 2;
+    // stream metering mode
+    StreamModeDetails stream_mode_details = 3;
+
+
+}
+
+message UpdateStreamModeResponse {
+    // Result of request will be inside operation.
+    Ydb.Operations.Operation operation = 1;
+}
+
+message UpdateStreamModeResult {
+}
+