diff options
author | alexnick <alexnick@yandex-team.ru> | 2022-02-10 16:47:45 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:45 +0300 |
commit | 80ba7327fdd90a6281bcec18f03e84ff856c3559 (patch) | |
tree | 0151ace31c13e6d6ec74aac742084670ca5493a3 /ydb/public/api/protos/draft/datastreams.proto | |
parent | 6aced6c854653b75aab9808d5995be5fc4d9fa53 (diff) | |
download | ydb-80ba7327fdd90a6281bcec18f03e84ff856c3559.tar.gz |
Restoring authorship annotation for <alexnick@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'ydb/public/api/protos/draft/datastreams.proto')
-rw-r--r-- | ydb/public/api/protos/draft/datastreams.proto | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/ydb/public/api/protos/draft/datastreams.proto b/ydb/public/api/protos/draft/datastreams.proto index 5c1354288a..28021116b3 100644 --- a/ydb/public/api/protos/draft/datastreams.proto +++ b/ydb/public/api/protos/draft/datastreams.proto @@ -24,8 +24,8 @@ extend google.protobuf.FieldOptions { enum EncryptionType { ENCRYPTION_UNDEFINED = 0; - NONE = 1; - KMS = 2; + NONE = 1; + KMS = 2; } message EnhancedMetrics { @@ -122,7 +122,7 @@ message Shard { // Id of the shard's parent string parent_shard_id = 3 [(FieldTransformer) = TRANSFORM_EMPTY_TO_NOTHING]; // The range of possible sequence numbers for the shard - SequenceNumberRange sequence_number_range = 4; + SequenceNumberRange sequence_number_range = 4; // Unique id of the shard within stream string shard_id = 5; } @@ -149,15 +149,15 @@ message ConsumerDescription { enum ShardIteratorType { SHARD_ITERATOR_UNDEFINED = 0; // Start reading exactly from the position denoted by a sequence number - AT_SEQUENCE_NUMBER = 1; + AT_SEQUENCE_NUMBER = 1; // Start reading right after the specified position - AFTER_SEQUENCE_NUMBER = 2; + AFTER_SEQUENCE_NUMBER = 2; // Start reading from the position denoted by a specific timestamp - AT_TIMESTAMP = 3; + AT_TIMESTAMP = 3; // Start reading from the oldest record - TRIM_HORIZON = 4; + TRIM_HORIZON = 4; // Start reading latest records - LATEST = 5; + LATEST = 5; } // Parameters used to filter out the response of ListShards @@ -182,7 +182,7 @@ message ShardFilter { string shard_id = 1; // Can only be used if AT_TIMESTAMP or FROM_TIMESTAMP are specified. int64 timestamp = 2 [(FieldTransformer) = TRANSFORM_DOUBLE_S_TO_INT_MS]; - ShardFilterType type = 3; + ShardFilterType type = 3; } // Represents starting position in the stream from which to start reading @@ -295,8 +295,8 @@ message ListStreamsRequest { string exclusive_start_stream_name = 2; // Max number of entries to return int32 limit = 3; - // Will make recurse listing if set to true. Otherwise will return only streams from root directory. - bool recurse = 4; + // Will make recurse listing if set to true. Otherwise will return only streams from root directory. + bool recurse = 4; } message ListStreamsResponse { @@ -412,7 +412,7 @@ message DescribeStreamResponse { } message DescribeStreamResult { - StreamDescription stream_description = 1; + StreamDescription stream_description = 1; } message RegisterStreamConsumerRequest { @@ -478,7 +478,7 @@ message PutRecordsResultEntry { string error_message = 2 [(FieldTransformer) = TRANSFORM_EMPTY_TO_NOTHING]; string error_code = 3 [(FieldTransformer) = TRANSFORM_EMPTY_TO_NOTHING]; string sequence_number = 4; - string shard_id = 5; + string shard_id = 5; } message GetRecordsRequest { @@ -529,7 +529,7 @@ message PutRecordResult { // Unique id of the record within shard string sequence_number = 2; // Id of the shard were the data was inserted - string shard_id = 3; + string shard_id = 3; } message PutRecordsRequest { |