**Breaking Change**: Ydb.Sdk.Services.Topic moved to Ydb.Sdk.Topic.

Author: KirillKurdyukov

src/Ydb.Sdk/CHANGELOG.md

@@ -1,3 +1,5 @@
+- **Breaking Change**: `Ydb.Sdk.Services.Topic` moved to `Ydb.Sdk.Topic`.
+
 ## v0.24.0
 
 - **Breaking Change**: Renamed properties in `YdbConnectionStringBuilder`:
@@ -18,7 +20,7 @@
 - Fixed bug ADO.NET/PoolManager: `SemaphoreSlim.WaitAsync` over-release on cancellation.
 - Feat ADO.NET: Mark `YdbConnection.State` as `Broken` when the underlying session is broken, including background deactivation.
 - Feat ADO.NET: Added  YdbDataSource `ExecuteAsync` and `ExecuteInTransaction` convenience methods.
-- **Breaking Change**: moved and renamed `Ydb.Sdk.Services.Query.TxMode` -> `Ydb.Sdk.Ado.TransactionMode`.
+- **Breaking Change**: `Ydb.Sdk.Services.Query.TxMode` moved to `Ydb.Sdk.Ado.TransactionMode`.
 - Feat ADO.NET: Cache gRPC transport by `gRPCConnectionString` to reuse channels.
 - Fixed bug wrap-around ADO.NET: Big parameterized Decimal — `((ulong)bits[1] << 32)` -> `((ulong)(uint)bits[1] << 32)`.
 - Feat ADO.NET: Parameterized Decimal overflow check: `Precision` and `Scale`.

src/Ydb.Sdk/src/Services/Topic/Deserializer.cs renamed to src/Ydb.Sdk/src/Topic/Deserializer.cs

@@ -1,6 +1,6 @@
 using System.Text;
 
-namespace Ydb.Sdk.Services.Topic;
+namespace Ydb.Sdk.Topic;
 
 public interface IDeserializer<out TValue>
 {

src/Ydb.Sdk/src/Services/Topic/Exceptions.cs renamed to src/Ydb.Sdk/src/Topic/Exceptions.cs

@@ -1,4 +1,4 @@
-namespace Ydb.Sdk.Services.Topic;
+namespace Ydb.Sdk.Topic;
 
 public class WriterException : Exception
 {

src/Ydb.Sdk/src/Services/Topic/IReader.cs renamed to src/Ydb.Sdk/src/Topic/IReader.cs

@@ -1,6 +1,6 @@
-using Ydb.Sdk.Services.Topic.Reader;
+using Ydb.Sdk.Topic.Reader;
 
-namespace Ydb.Sdk.Services.Topic;
+namespace Ydb.Sdk.Topic;
 
 public interface IReader<TValue> : IAsyncDisposable
 {

src/Ydb.Sdk/src/Services/Topic/IWriter.cs renamed to src/Ydb.Sdk/src/Topic/IWriter.cs

@@ -1,6 +1,6 @@
-using Ydb.Sdk.Services.Topic.Writer;
+using Ydb.Sdk.Topic.Writer;
 
-namespace Ydb.Sdk.Services.Topic;
+namespace Ydb.Sdk.Topic;
 
 public interface IWriter<TValue> : IAsyncDisposable
 {

src/Ydb.Sdk/src/Services/Topic/Metadata.cs renamed to src/Ydb.Sdk/src/Topic/Metadata.cs

@@ -1,3 +1,3 @@
-namespace Ydb.Sdk.Services.Topic;
+namespace Ydb.Sdk.Topic;
 
 public record Metadata(string Key, byte[] Value);

src/Ydb.Sdk/src/Services/Topic/Reader/InternalBatchMessages.cs renamed to src/Ydb.Sdk/src/Topic/Reader/InternalBatchMessages.cs

@@ -2,7 +2,7 @@
 using System.Diagnostics.CodeAnalysis;
 using Ydb.Topic;
 
-namespace Ydb.Sdk.Services.Topic.Reader;
+namespace Ydb.Sdk.Topic.Reader;
 
 internal class InternalBatchMessages<TValue>
 {
@@ -66,7 +66,7 @@ internal bool TryDequeueMessage([MaybeNullWhen(false)] out Message<TValue> messa
             partitionSessionId: _partitionSession.PartitionSessionId,
             producerId: _batch.ProducerId,
             createdAt: messageData.CreatedAt.ToDateTime(),
-            metadata: messageData.MetadataItems.Select(item => new Metadata(item.Key, item.Value.ToByteArray()))
+            metadata: messageData.MetadataItems.Select(item => new Sdk.Topic.Metadata(item.Key, item.Value.ToByteArray()))
                 .ToImmutableArray(),
             seqNo: messageData.SeqNo,
             offsetsRange: new OffsetsRange

src/Ydb.Sdk/src/Services/Topic/Reader/Message.cs renamed to src/Ydb.Sdk/src/Topic/Reader/Message.cs

@@ -1,7 +1,7 @@
 using System.Collections.Immutable;
 using Ydb.Topic;
 
-namespace Ydb.Sdk.Services.Topic.Reader;
+namespace Ydb.Sdk.Topic.Reader;
 
 public class Message<TValue>
 {
@@ -47,7 +47,7 @@ internal Message(
 
     public DateTime CreatedAt { get; }
 
-    public IReadOnlyCollection<Metadata> Metadata { get; }
+    public IReadOnlyCollection<Sdk.Topic.Metadata> Metadata { get; }
 
     public long SeqNo { get; }
 

src/Ydb.Sdk/src/Services/Topic/Reader/PartitionSession.cs renamed to src/Ydb.Sdk/src/Topic/Reader/PartitionSession.cs

@@ -1,7 +1,7 @@
 using System.Collections.Concurrent;
 using Microsoft.Extensions.Logging;
 
-namespace Ydb.Sdk.Services.Topic.Reader;
+namespace Ydb.Sdk.Topic.Reader;
 
 internal class PartitionSession
 {

src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs renamed to src/Ydb.Sdk/src/Topic/Reader/Reader.cs

@@ -7,7 +7,7 @@
 using Ydb.Topic.V1;
 using static Ydb.Topic.StreamReadMessage.Types.FromServer;
 
-namespace Ydb.Sdk.Services.Topic.Reader;
+namespace Ydb.Sdk.Topic.Reader;
 
 using MessageFromClient = StreamReadMessage.Types.FromClient;
 using MessageFromServer = StreamReadMessage.Types.FromServer;