Add comprehensive unit tests for internal/coordination package to increase test coverage (#1901)

Co-authored-by: copilot-swe-agent[bot] <[email protected]>
Co-authored-by: asmyasnikov <[email protected]>
Co-authored-by: Aleksey Myasnikov <[email protected]>

Author: Copilot

internal/coordination/client_test.go

@@ -386,3 +386,61 @@ func TestDropNode(t *testing.T) {
 		require.False(t, mustDeleteSession(err))
 	})
 }
+
+func TestConsistencyMode(t *testing.T) {
+	for _, tt := range []struct {
+		name     string
+		input    Ydb_Coordination.ConsistencyMode
+		expected coordination.ConsistencyMode
+	}{
+		{
+			name:     "Strict",
+			input:    Ydb_Coordination.ConsistencyMode_CONSISTENCY_MODE_STRICT,
+			expected: coordination.ConsistencyModeStrict,
+		},
+		{
+			name:     "Relaxed",
+			input:    Ydb_Coordination.ConsistencyMode_CONSISTENCY_MODE_RELAXED,
+			expected: coordination.ConsistencyModeRelaxed,
+		},
+		{
+			name:     "Unset",
+			input:    Ydb_Coordination.ConsistencyMode_CONSISTENCY_MODE_UNSET,
+			expected: coordination.ConsistencyModeUnset,
+		},
+	} {
+		t.Run(tt.name, func(t *testing.T) {
+			result := consistencyMode(tt.input)
+			require.Equal(t, tt.expected, result)
+		})
+	}
+}
+
+func TestRatelimiterCountersMode(t *testing.T) {
+	for _, tt := range []struct {
+		name     string
+		input    Ydb_Coordination.RateLimiterCountersMode
+		expected coordination.RatelimiterCountersMode
+	}{
+		{
+			name:     "Aggregated",
+			input:    Ydb_Coordination.RateLimiterCountersMode_RATE_LIMITER_COUNTERS_MODE_AGGREGATED,
+			expected: coordination.RatelimiterCountersModeAggregated,
+		},
+		{
+			name:     "Detailed",
+			input:    Ydb_Coordination.RateLimiterCountersMode_RATE_LIMITER_COUNTERS_MODE_DETAILED,
+			expected: coordination.RatelimiterCountersModeDetailed,
+		},
+		{
+			name:     "Unset",
+			input:    Ydb_Coordination.RateLimiterCountersMode_RATE_LIMITER_COUNTERS_MODE_UNSET,
+			expected: coordination.RatelimiterCountersModeUnset,
+		},
+	} {
+		t.Run(tt.name, func(t *testing.T) {
+			result := ratelimiterCountersMode(tt.input)
+			require.Equal(t, tt.expected, result)
+		})
+	}
+}

internal/coordination/config/config_test.go

@@ -0,0 +1,83 @@
+package config
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+
+	"github.com/ydb-platform/ydb-go-sdk/v3/internal/config"
+	"github.com/ydb-platform/ydb-go-sdk/v3/trace"
+)
+
+func TestNew(t *testing.T) {
+	t.Run("Default", func(t *testing.T) {
+		cfg := New()
+		require.NotNil(t, cfg)
+		require.NotNil(t, cfg.Trace())
+	})
+	t.Run("WithTrace", func(t *testing.T) {
+		traceCoordination := &trace.Coordination{
+			OnNew: func(info trace.CoordinationNewStartInfo) func(trace.CoordinationNewDoneInfo) {
+				return nil
+			},
+		}
+		cfg := New(WithTrace(traceCoordination))
+		require.NotNil(t, cfg)
+		require.NotNil(t, cfg.Trace())
+	})
+	t.Run("WithCommonConfig", func(t *testing.T) {
+		commonConfig := config.Common{}
+		cfg := New(With(commonConfig))
+		require.NotNil(t, cfg)
+		require.Equal(t, commonConfig.OperationTimeout(), cfg.OperationTimeout())
+	})
+	t.Run("WithMultipleOptions", func(t *testing.T) {
+		traceCoordination := &trace.Coordination{}
+		commonConfig := config.Common{}
+		cfg := New(
+			WithTrace(traceCoordination),
+			With(commonConfig),
+		)
+		require.NotNil(t, cfg)
+		require.NotNil(t, cfg.Trace())
+		require.Equal(t, commonConfig.OperationTimeout(), cfg.OperationTimeout())
+	})
+	t.Run("WithNilOption", func(t *testing.T) {
+		cfg := New(nil)
+		require.NotNil(t, cfg)
+		require.NotNil(t, cfg.Trace())
+	})
+	t.Run("WithTraceCompose", func(t *testing.T) {
+		trace1 := &trace.Coordination{
+			OnNew: func(info trace.CoordinationNewStartInfo) func(trace.CoordinationNewDoneInfo) {
+				return nil
+			},
+		}
+		trace2 := &trace.Coordination{
+			OnClose: func(info trace.CoordinationCloseStartInfo) func(trace.CoordinationCloseDoneInfo) {
+				return nil
+			},
+		}
+		cfg := New(WithTrace(trace1), WithTrace(trace2))
+		require.NotNil(t, cfg)
+		require.NotNil(t, cfg.Trace())
+	})
+}
+
+func TestTrace(t *testing.T) {
+	t.Run("DefaultTrace", func(t *testing.T) {
+		cfg := New()
+		trace := cfg.Trace()
+		require.NotNil(t, trace)
+	})
+	t.Run("CustomTrace", func(t *testing.T) {
+		traceCoordination := &trace.Coordination{
+			OnNew: func(info trace.CoordinationNewStartInfo) func(trace.CoordinationNewDoneInfo) {
+				return nil
+			},
+		}
+		cfg := New(WithTrace(traceCoordination))
+		trace := cfg.Trace()
+		require.NotNil(t, trace)
+	})
+}