@@ -33,36 +33,36 @@ namespace NYdb::inline V3::NDataStreams::V1 {
33
33
ESM_ON_DEMAND = 2 ,
34
34
};
35
35
36
- using TCreateStreamResult = TProtoResultWrapper<Ydb ::DataStreams::V1::CreateStreamResult>;
37
- using TDeleteStreamResult = TProtoResultWrapper<Ydb ::DataStreams::V1::DeleteStreamResult>;
38
- using TDescribeStreamResult = TProtoResultWrapper<Ydb ::DataStreams::V1::DescribeStreamResult>;
39
- using TPutRecordResult = TProtoResultWrapper<Ydb ::DataStreams::V1::PutRecordResult>;
40
- using TRegisterStreamConsumerResult = TProtoResultWrapper<Ydb ::DataStreams::V1::RegisterStreamConsumerResult>;
41
- using TDeregisterStreamConsumerResult = TProtoResultWrapper<Ydb ::DataStreams::V1::DeregisterStreamConsumerResult>;
42
- using TDescribeStreamConsumerResult = TProtoResultWrapper<Ydb ::DataStreams::V1::DescribeStreamConsumerResult>;
43
- using TListStreamsResult = TProtoResultWrapper<Ydb ::DataStreams::V1::ListStreamsResult>;
44
- using TListShardsResult = TProtoResultWrapper<Ydb ::DataStreams::V1::ListShardsResult>;
45
- using TPutRecordsResult = TProtoResultWrapper<Ydb ::DataStreams::V1::PutRecordsResult>;
46
- using TGetRecordsResult = TProtoResultWrapper<Ydb ::DataStreams::V1::GetRecordsResult>;
47
- using TGetShardIteratorResult = TProtoResultWrapper<Ydb ::DataStreams::V1::GetShardIteratorResult>;
48
- // using TSubscribeToShardResult = TProtoResultWrapper<Ydb ::DataStreams::V1::SubscribeToShardResult>;
49
- using TDescribeLimitsResult = TProtoResultWrapper<Ydb ::DataStreams::V1::DescribeLimitsResult>;
50
- using TDescribeStreamSummaryResult = TProtoResultWrapper<Ydb ::DataStreams::V1::DescribeStreamSummaryResult>;
51
- using TDecreaseStreamRetentionPeriodResult = TProtoResultWrapper<Ydb ::DataStreams::V1::DecreaseStreamRetentionPeriodResult>;
52
- using TIncreaseStreamRetentionPeriodResult = TProtoResultWrapper<Ydb ::DataStreams::V1::IncreaseStreamRetentionPeriodResult>;
53
- using TUpdateShardCountResult = TProtoResultWrapper<Ydb ::DataStreams::V1::UpdateShardCountResult>;
54
- using TUpdateStreamModeResult = TProtoResultWrapper<Ydb ::DataStreams::V1::UpdateStreamModeResult>;
55
- using TListStreamConsumersResult = TProtoResultWrapper<Ydb ::DataStreams::V1::ListStreamConsumersResult>;
56
- using TAddTagsToStreamResult = TProtoResultWrapper<Ydb ::DataStreams::V1::AddTagsToStreamResult>;
57
- using TDisableEnhancedMonitoringResult = TProtoResultWrapper<Ydb ::DataStreams::V1::DisableEnhancedMonitoringResult>;
58
- using TEnableEnhancedMonitoringResult = TProtoResultWrapper<Ydb ::DataStreams::V1::EnableEnhancedMonitoringResult>;
59
- using TListTagsForStreamResult = TProtoResultWrapper<Ydb ::DataStreams::V1::ListTagsForStreamResult>;
60
- using TMergeShardsResult = TProtoResultWrapper<Ydb ::DataStreams::V1::MergeShardsResult>;
61
- using TRemoveTagsFromStreamResult = TProtoResultWrapper<Ydb ::DataStreams::V1::RemoveTagsFromStreamResult>;
62
- using TSplitShardResult = TProtoResultWrapper<Ydb ::DataStreams::V1::SplitShardResult>;
63
- using TStartStreamEncryptionResult = TProtoResultWrapper<Ydb ::DataStreams::V1::StartStreamEncryptionResult>;
64
- using TStopStreamEncryptionResult = TProtoResultWrapper<Ydb ::DataStreams::V1::StopStreamEncryptionResult>;
65
- using TUpdateStreamResult = TProtoResultWrapper<Ydb ::DataStreams::V1::UpdateStreamResult>;
36
+ using TCreateStreamResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::CreateStreamResult>;
37
+ using TDeleteStreamResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::DeleteStreamResult>;
38
+ using TDescribeStreamResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::DescribeStreamResult>;
39
+ using TPutRecordResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::PutRecordResult>;
40
+ using TRegisterStreamConsumerResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::RegisterStreamConsumerResult>;
41
+ using TDeregisterStreamConsumerResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::DeregisterStreamConsumerResult>;
42
+ using TDescribeStreamConsumerResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::DescribeStreamConsumerResult>;
43
+ using TListStreamsResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::ListStreamsResult>;
44
+ using TListShardsResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::ListShardsResult>;
45
+ using TPutRecordsResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::PutRecordsResult>;
46
+ using TGetRecordsResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::GetRecordsResult>;
47
+ using TGetShardIteratorResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::GetShardIteratorResult>;
48
+ // using TSubscribeToShardResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::SubscribeToShardResult>;
49
+ using TDescribeLimitsResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::DescribeLimitsResult>;
50
+ using TDescribeStreamSummaryResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::DescribeStreamSummaryResult>;
51
+ using TDecreaseStreamRetentionPeriodResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::DecreaseStreamRetentionPeriodResult>;
52
+ using TIncreaseStreamRetentionPeriodResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::IncreaseStreamRetentionPeriodResult>;
53
+ using TUpdateShardCountResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::UpdateShardCountResult>;
54
+ using TUpdateStreamModeResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::UpdateStreamModeResult>;
55
+ using TListStreamConsumersResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::ListStreamConsumersResult>;
56
+ using TAddTagsToStreamResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::AddTagsToStreamResult>;
57
+ using TDisableEnhancedMonitoringResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::DisableEnhancedMonitoringResult>;
58
+ using TEnableEnhancedMonitoringResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::EnableEnhancedMonitoringResult>;
59
+ using TListTagsForStreamResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::ListTagsForStreamResult>;
60
+ using TMergeShardsResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::MergeShardsResult>;
61
+ using TRemoveTagsFromStreamResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::RemoveTagsFromStreamResult>;
62
+ using TSplitShardResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::SplitShardResult>;
63
+ using TStartStreamEncryptionResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::StartStreamEncryptionResult>;
64
+ using TStopStreamEncryptionResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::StopStreamEncryptionResult>;
65
+ using TUpdateStreamResult = TProtoResultWrapper<NYdbProtos ::DataStreams::V1::UpdateStreamResult>;
66
66
67
67
using TAsyncCreateStreamResult = NThreading::TFuture<TCreateStreamResult>;
68
68
using TAsyncDeleteStreamResult = NThreading::TFuture<TDeleteStreamResult>;
@@ -128,7 +128,7 @@ namespace NYdb::inline V3::NDataStreams::V1 {
128
128
, DownUtilizationPercent_(0 )
129
129
, UpUtilizationPercent_(0 ) {
130
130
}
131
- TAutoPartitioningSettings (const Ydb ::DataStreams::V1::AutoPartitioningSettings& settings);
131
+ TAutoPartitioningSettings (const NYdbProtos ::DataStreams::V1::AutoPartitioningSettings& settings);
132
132
TAutoPartitioningSettings (EAutoPartitioningStrategy strategy, TDuration stabilizationWindow, uint64_t downUtilizationPercent, uint64_t upUtilizationPercent)
133
133
: Strategy_(strategy)
134
134
, StabilizationWindow_(stabilizationWindow)
@@ -153,7 +153,7 @@ namespace NYdb::inline V3::NDataStreams::V1 {
153
153
friend struct TPartitioningSettingsBuilder <TUpdateStreamSettings>;
154
154
public:
155
155
TPartitioningSettings () : MinActivePartitions_(0 ), MaxActivePartitions_(0 ), AutoPartitioningSettings_(){}
156
- TPartitioningSettings (const Ydb ::DataStreams::V1::PartitioningSettings& settings);
156
+ TPartitioningSettings (const NYdbProtos ::DataStreams::V1::PartitioningSettings& settings);
157
157
TPartitioningSettings (uint64_t minActivePartitions, uint64_t maxActivePartitions, TAutoPartitioningSettings autoscalingSettings = {})
158
158
: MinActivePartitions_(minActivePartitions)
159
159
, MaxActivePartitions_(maxActivePartitions)
@@ -334,10 +334,10 @@ namespace NYdb::inline V3::NDataStreams::V1 {
334
334
TAsyncDescribeStreamResult DescribeStream (const std::string& path, TDescribeStreamSettings settings = TDescribeStreamSettings());
335
335
TAsyncPutRecordResult PutRecord (const std::string& path, const TDataRecord& record, TPutRecordSettings settings = TPutRecordSettings());
336
336
TAsyncListStreamsResult ListStreams (TListStreamsSettings settings = TListStreamsSettings());
337
- TAsyncListShardsResult ListShards (const std::string& path, const Ydb ::DataStreams::V1::ShardFilter& shardFilter, TListShardsSettings settings = TListShardsSettings());
337
+ TAsyncListShardsResult ListShards (const std::string& path, const NYdbProtos ::DataStreams::V1::ShardFilter& shardFilter, TListShardsSettings settings = TListShardsSettings());
338
338
TAsyncPutRecordsResult PutRecords (const std::string& path, const std::vector<TDataRecord>& records, TPutRecordsSettings settings = TPutRecordsSettings());
339
339
TAsyncGetRecordsResult GetRecords (const std::string& shardIterator, TGetRecordsSettings settings = TGetRecordsSettings());
340
- TAsyncGetShardIteratorResult GetShardIterator (const std::string& path, const std::string& shardId, Ydb ::DataStreams::V1::ShardIteratorType shardIteratorTypeStr,
340
+ TAsyncGetShardIteratorResult GetShardIterator (const std::string& path, const std::string& shardId, NYdbProtos ::DataStreams::V1::ShardIteratorType shardIteratorTypeStr,
341
341
TGetShardIteratorSettings settings = TGetShardIteratorSettings());
342
342
// TAsyncSubscribeToShardResult SubscribeToShard(TSubscribeToShardSettings settings = TSubscribeToShardSettings());
343
343
TAsyncDescribeLimitsResult DescribeLimits (TDescribeLimitsSettings settings = TDescribeLimitsSettings());
0 commit comments