start doc

Author: KirillKurdyukov

src/Ydb.Sdk/CHANGELOG.md

@@ -1,3 +1,4 @@
+- XML documentation for all public APIs in `Ydb.Sdk`.
 - Feat ADO.NET: Added dispose timeout (10 seconds) to `PoolingSessionSource`.
 - Feat ADO.NET: Added `EnableImplicitSession` to support implicit sessions.
 

src/Ydb.Sdk/src/Ado/BulkUpsert/BulkUpsertImporter.cs

@@ -6,7 +6,7 @@
 
 namespace Ydb.Sdk.Ado.BulkUpsert;
 
-public sealed class BulkUpsertImporter : IBulkUpsertImporter
+internal class BulkUpsertImporter : IBulkUpsertImporter
 {
     private readonly IDriver _driver;
     private readonly string _tablePath;

src/Ydb.Sdk/src/Ado/RetryPolicy/IRetryPolicy.cs

@@ -1,6 +1,27 @@
 namespace Ydb.Sdk.Ado.RetryPolicy;
 
+/// <summary>
+/// Defines the contract for retry policies used by YDB operations.
+/// </summary>
+/// <remarks>
+/// IRetryPolicy provides a way to implement custom retry logic for YDB operations.
+/// The recommended implementation is <see cref="YdbRetryPolicy"/>, but custom implementations
+/// can be created for specific use cases. When implementing a custom retry policy, ensure
+/// you understand the implications of retrying operations and handle idempotency correctly.
+/// </remarks>
 public interface IRetryPolicy
 {
+    /// <summary>
+    /// Calculates the delay before the next retry attempt.
+    /// </summary>
+    /// <param name="ydbException">The <see cref="YdbException"/> that was thrown during the last execution attempt.</param>
+    /// <param name="attempt">The current attempt number (0-based).</param>
+    /// <returns>
+    /// The delay before the next retry attempt, or null if no more retries should be attempted.
+    /// </returns>
+    /// <remarks>
+    /// This method is called for each retry attempt. Return null to stop retrying.
+    /// Consider the <see cref="YdbException"/>, attempt number, and operation idempotency when making retry decisions.
+    /// </remarks>
     public TimeSpan? GetNextDelay(YdbException ydbException, int attempt);
 }

src/Ydb.Sdk/src/Ado/RetryPolicy/YdbRetryPolicy.cs

@@ -3,10 +3,23 @@
 namespace Ydb.Sdk.Ado.RetryPolicy;
 
 /// <summary>
-/// See <a href="https://aws.amazon.com/ru/blogs/architecture/exponential-backoff-and-jitter/">AWS paper</a>
+/// Default retry policy implementation for YDB operations using exponential backoff with jitter.
 /// </summary>
+/// <remarks>
+/// YdbRetryPolicy implements the recommended retry strategy for YDB operations based on
+/// <a href="https://aws.amazon.com/ru/blogs/architecture/exponential-backoff-and-jitter/">AWS best practices</a>.
+/// It uses different backoff strategies for different types of errors and includes jitter
+/// to prevent thundering herd problems. This is the recommended implementation of <see cref="IRetryPolicy"/>.
+/// </remarks>
 public class YdbRetryPolicy : IRetryPolicy
 {
+    /// <summary>
+    /// Gets the default retry policy instance with default configuration.
+    /// </summary>
+    /// <remarks>
+    /// This instance uses the default configuration from <see cref="YdbRetryPolicyConfig.Default"/>.
+    /// It's suitable for most use cases and provides a good balance between retry frequency and performance.
+    /// </remarks>
     public static readonly YdbRetryPolicy Default = new(YdbRetryPolicyConfig.Default);
 
     private readonly int _maxAttempt;
@@ -19,6 +32,14 @@ public class YdbRetryPolicy : IRetryPolicy
     private readonly bool _enableRetryIdempotence;
     private readonly IRandom _random;
 
+    /// <summary>
+    /// Initializes a new instance of the <see cref="YdbRetryPolicy"/> class with the specified configuration.
+    /// </summary>
+    /// <param name="config">The <see cref="YdbRetryPolicyConfig"/> retry policy configuration.</param>
+    /// <remarks>
+    /// This constructor creates a retry policy with the specified configuration.
+    /// The policy will use different backoff strategies based on the error type and attempt number.
+    /// </remarks>
     public YdbRetryPolicy(YdbRetryPolicyConfig config)
     {
         _maxAttempt = config.MaxAttempts;
@@ -32,11 +53,31 @@ public YdbRetryPolicy(YdbRetryPolicyConfig config)
         _random = ThreadLocalRandom.Instance;
     }
 
+    /// <summary>
+    /// Initializes a new instance of the <see cref="YdbRetryPolicy"/> class with the specified configuration and random number generator.
+    /// </summary>
+    /// <param name="config">The <see cref="YdbRetryPolicyConfig"/> retry policy configuration.</param>
+    /// <param name="random">The random number generator for jitter calculations.</param>
+    /// <remarks>
+    /// This constructor is primarily used for testing purposes to provide deterministic behavior.
+    /// In production code, use the constructor that takes only the configuration parameter.
+    /// </remarks>
     internal YdbRetryPolicy(YdbRetryPolicyConfig config, IRandom random) : this(config)
     {
         _random = random;
     }
 
+    /// <inheritdoc/>
+    /// <remarks>
+    /// This method implements different retry strategies based on the error type:
+    /// - BadSession/SessionBusy: Immediate retry (TimeSpan.Zero)
+    /// - Aborted/Undetermined: Fast backoff with full jitter
+    /// - Unavailable/Transport errors: Fast backoff with equal jitter
+    /// - Overloaded/Resource exhausted: Slow backoff with equal jitter
+    /// - Other errors: No retry (null)
+    /// 
+    /// The policy respects the maximum attempt limit and idempotence settings.
+    /// </remarks>
     public TimeSpan? GetNextDelay(YdbException ydbException, int attempt)
     {
         if (attempt >= _maxAttempt - 1 || (!_enableRetryIdempotence && !ydbException.IsTransient))

src/Ydb.Sdk/src/Ado/RetryPolicy/YdbRetryPolicyConfig.cs

@@ -1,21 +1,97 @@
 namespace Ydb.Sdk.Ado.RetryPolicy;
 
+/// <summary>
+/// Configuration settings for the <see cref="YdbRetryPolicy"/>.
+/// </summary>
+/// <remarks>
+/// YdbRetryPolicyConfig provides configuration options for customizing the retry behavior
+/// of YDB operations. The default values are suitable for most use cases, but can be
+/// adjusted based on specific requirements and performance characteristics.
+/// </remarks>
 public class YdbRetryPolicyConfig
 {
+    /// <summary>
+    /// Gets the default retry policy configuration.
+    /// </summary>
+    /// <remarks>
+    /// This configuration provides a good balance between retry frequency and performance
+    /// for most YDB operations. It can be used as a starting point for custom configurations.
+    /// </remarks>
     public static readonly YdbRetryPolicyConfig Default = new();
 
+    /// <summary>
+    /// Gets or sets the maximum number of retry attempts.
+    /// </summary>
+    /// <remarks>
+    /// The total number of attempts will be MaxAttempts (including the initial attempt).
+    /// Setting this to 1 disables retries entirely.
+    /// Default value: 10.
+    /// </remarks>
     public int MaxAttempts { get; init; } = 10;
 
+    /// <summary>
+    /// Gets or sets the base delay in milliseconds for fast backoff strategies.
+    /// </summary>
+    /// <remarks>
+    /// This is used for errors that typically resolve quickly, such as temporary
+    /// unavailability or TLI (Transaction Lock Invalidated).
+    /// The actual delay will be calculated using exponential backoff with jitter.
+    /// Default value: 5 ms.
+    /// </remarks>
     public int FastBackoffBaseMs { get; init; } = 5;
 
+    /// <summary>
+    /// Gets or sets the base delay in milliseconds for slow backoff strategies.
+    /// </summary>
+    /// <remarks>
+    /// This is used for errors that may take longer to resolve, such as overload
+    /// or resource exhaustion. The actual delay will be calculated using
+    /// exponential backoff with jitter.
+    /// Default value: 50 ms.
+    /// </remarks>
     public int SlowBackoffBaseMs { get; init; } = 50;
 
+    /// <summary>
+    /// Gets or sets the maximum delay in milliseconds for fast backoff strategies.
+    /// </summary>
+    /// <remarks>
+    /// This caps the maximum delay for fast backoff to prevent excessively long waits.
+    /// The exponential backoff will not exceed this value.
+    /// Default value: 500 ms.
+    /// </remarks>
     public int FastCapBackoffMs { get; init; } = 500;
 
+    /// <summary>
+    /// Gets or sets the maximum delay in milliseconds for slow backoff strategies.
+    /// </summary>
+    /// <remarks>
+    /// This caps the maximum delay for slow backoff to prevent excessively long waits.
+    /// The exponential backoff will not exceed this value.
+    /// Default value: 5000 ms.
+    /// </remarks>
     public int SlowCapBackoffMs { get; init; } = 5_000;
 
+    /// <summary>
+    /// Gets or sets a value indicating whether to enable retry for idempotent statuses.
+    /// </summary>
+    /// <remarks>
+    /// When false, only transient errors are retried. When true, all retryable statuses
+    /// are retried, which means the operation may be executed twice. This happens because
+    /// some statuses (like unavailable) don't indicate whether the server processed the
+    /// operation - the connection might have been lost during the response. Enable this
+    /// only if you are certain that the operations being retried are idempotent.
+    /// Default value: false.
+    /// </remarks>
     public bool EnableRetryIdempotence { get; init; } = false;
 
+    /// <summary>
+    /// Returns a string representation of the retry policy configuration.
+    /// </summary>
+    /// <returns>A string containing all configuration values in a readable format.</returns>
+    /// <remarks>
+    /// This method is useful for logging and debugging purposes to see the current
+    /// retry policy configuration values.
+    /// </remarks>
     public override string ToString() => $"MaxAttempt={MaxAttempts};" +
                                          $"FastBackoffBaseMs={FastBackoffBaseMs};" +
                                          $"SlowBackoffBaseMs={SlowBackoffBaseMs};" +

src/Ydb.Sdk/src/Ado/RetryPolicy/YdbRetryPolicyExecutor.cs

@@ -10,20 +10,20 @@ public YdbRetryPolicyExecutor(IRetryPolicy retryPolicy)
     }
 
     /// <summary>
-    ///     Executes the specified asynchronous operation and returns the result.
+    /// Executes the specified asynchronous operation and returns the result.
     /// </summary>
     /// <param name="operation">
-    ///     A function that returns a started task of type <typeparamref name="TResult" />.
+    /// A function that returns a started task of type <typeparamref name="TResult" />.
     /// </param>
     /// <param name="cancellationToken">
-    ///     A cancellation token used to cancel the retry operation, but not operations that are already in flight
-    ///     or that already completed successfully.
+    /// A cancellation token used to cancel the retry operation, but not operations that are already in flight
+    /// or that already completed successfully.
     /// </param>
     /// <typeparam name="TResult"> The result type of the <see cref="Task{TResult}" /> returned by <paramref name="operation" />. </typeparam>
     /// <returns>
-    ///     A task that will run to completion if the original task completes successfully (either the
-    ///     first time or after retrying transient failures). If the task fails with a non-transient error or
-    ///     the retry limit is reached, the returned task will become faulted and the exception must be observed.
+    /// A task that will run to completion if the original task completes successfully (either the
+    /// first time or after retrying transient failures). If the task fails with a non-transient error or
+    /// the retry limit is reached, the returned task will become faulted and the exception must be observed.
     /// </returns>
     public Task<TResult> ExecuteAsync<TResult>(
         Func<CancellationToken, Task<TResult>> operation,

src/Ydb.Sdk/src/Ado/Transaction/TransactionMode.cs

@@ -2,12 +2,62 @@
 
 namespace Ydb.Sdk.Ado;
 
+/// <summary>
+/// Specifies the transaction isolation mode for YDB operations.
+/// </summary>
+/// <remarks>
+/// TransactionMode defines the isolation level and consistency guarantees
+/// for database operations within a transaction.
+/// </remarks>
 public enum TransactionMode
 {
+    /// <summary>
+    /// Serializable read-write transaction mode.
+    /// </summary>
+    /// <remarks>
+    /// Provides the highest isolation level with full ACID guarantees.
+    /// All reads and writes are serializable, ensuring complete consistency.
+    /// This is the default mode for read-write operations.
+    /// </remarks>
     SerializableRw,
+
+    /// <summary>
+    /// Snapshot read-only transaction mode.
+    /// </summary>
+    /// <remarks>
+    /// Provides a consistent snapshot of the database at a specific point in time.
+    /// All reads within the transaction see the same consistent state.
+    /// Only read operations are allowed.
+    /// </remarks>
     SnapshotRo,
+
+    /// <summary>
+    /// Stale read-only transaction mode.
+    /// </summary>
+    /// <remarks>
+    /// Allows reading potentially stale data for better performance.
+    /// Provides eventual consistency guarantees but may return outdated information.
+    /// Only read operations are allowed.
+    /// </remarks>
     StaleRo,
 
+    /// <summary>
+    /// Online read-only transaction mode.
+    /// </summary>
+    /// <remarks>
+    /// Provides real-time read access with strong consistency.
+    /// Reads the most recent committed data without allowing inconsistent reads.
+    /// Only read operations are allowed.
+    /// </remarks>
     OnlineRo,
+
+    /// <summary>
+    /// Online inconsistent read-only transaction mode.
+    /// </summary>
+    /// <remarks>
+    /// Provides real-time read access but allows inconsistent reads for better performance.
+    /// May return data from different points in time within the same transaction.
+    /// Only read operations are allowed.
+    /// </remarks>
     OnlineInconsistentRo
 }

src/Ydb.Sdk/src/Ado/YdbCommand.cs

@@ -6,6 +6,13 @@
 
 namespace Ydb.Sdk.Ado;
 
+/// <summary>
+/// Represents a SQL command to execute against a YDB database. This class cannot be inherited.
+/// </summary>
+/// <remarks>
+/// YdbCommand provides a standard ADO.NET command interface for executing SQL statements
+/// against YDB databases. It supports both synchronous and asynchronous execution methods.
+/// </remarks>
 public sealed class YdbCommand : DbCommand
 {
     private YdbConnection? _ydbConnection;
@@ -14,15 +21,34 @@ public sealed class YdbCommand : DbCommand
     private YdbConnection YdbConnection =>
         _ydbConnection ?? throw new InvalidOperationException("Connection property has not been initialized");
 
+    /// <summary>
+    /// Initializes a new instance of the <see cref="YdbCommand"/> class.
+    /// </summary>
     public YdbCommand()
     {
     }
 
+    /// <summary>
+    /// Initializes a new instance of the <see cref="YdbCommand"/> class with the specified connection.
+    /// </summary>
+    /// <param name="ydbConnection">A <see cref="YdbConnection"/> that represents the connection to a YDB server.</param>
     public YdbCommand(YdbConnection ydbConnection)
     {
         _ydbConnection = ydbConnection;
     }
 
+    /// <summary>
+    /// Initializes a new instance of the <see cref="YdbCommand"/> class with the text of the query, a
+    /// <see cref="YdbConnection"/>, and the <see cref="YdbTransaction"/>.
+    /// </summary>
+    /// <param name="commandText">The text of the query.</param>
+    /// <param name="ydbConnection">A <see cref="YdbConnection"/> that represents the connection to a YDB server.</param>
+    public YdbCommand(string commandText, YdbConnection? ydbConnection = null)
+    {
+        _commandText = commandText;
+        _ydbConnection = ydbConnection;
+    }
+
     public override void Cancel()
     {
     }

src/Ydb.Sdk/src/Ado/YdbConnection.cs

@@ -8,6 +8,13 @@
 
 namespace Ydb.Sdk.Ado;
 
+/// <summary>
+/// Represents a connection to a YDB database.
+/// </summary>
+/// <remarks>
+/// YdbConnection provides a standard ADO.NET connection interface for YDB databases.
+/// It manages database sessions and provides access to YDB-specific functionality.
+/// </remarks>
 public sealed class YdbConnection : DbConnection
 {
     private static readonly StateChangeEventArgs ClosedToOpenEventArgs =
@@ -39,10 +46,17 @@ internal ISession Session
 
     private ISession _session = null!;
 
+    /// <summary>
+    /// Initializes a new instance of the YdbConnection class.
+    /// </summary>
     public YdbConnection()
     {
     }
 
+    /// <summary>
+    /// Initializes a new instance of the YdbConnection class with the specified connection string.
+    /// </summary>
+    /// <param name="connectionString">The connection string used to establish the connection.</param>
     public YdbConnection(string connectionString)
     {
         ConnectionStringBuilder = new YdbConnectionStringBuilder(connectionString);