Function TestClassifyDbError

auth/strategy_database_test.go:101–199

TestClassifyDbError pins down the bounded set of telemetry labels. The new "db_not_ready" label is the operational signal that distinguishes "our PostgreSQLConnector is mid-reconnect — wait and retry" from "pgbouncer/postgres is actually unreachable — call ops". Before 2026-05-13 both rolled up int

(t *testing.T)

// 2026-05-13 both rolled up into "db_connection", which made the reconnect
// cascade look identical to a real outage on the dashboard.
func TestClassifyDbError(t *testing.T) {
	t.Parallel()

	s := &DatabaseStrategy{}

	tests := []struct {
		name string
		err  error
		want string
	}{
		{
			name: "nil",
			err:  nil,
			want: "db_query_error",
		},

		// --- db_not_ready: our own connector signalling mid-reconnect ---
		{
			name: "ErrConnectorNotReady direct",
			err:  data.ErrConnectorNotReady,
			want: "db_not_ready",
		},
		{
			name: "ErrConnectorNotReady wrapped",
			err:  fmt.Errorf("auth get failed: %w", data.ErrConnectorNotReady),
			want: "db_not_ready",
		},

		// --- db_timeout ---
		{
			name: "context deadline exceeded",
			err:  context.DeadlineExceeded,
			want: "db_timeout",
		},
		{
			name: "wrapped deadline exceeded",
			err:  fmt.Errorf("query: %w", context.DeadlineExceeded),
			want: "db_timeout",
		},
		{
			name: "substring: timeout",
			err:  errors.New("operation timeout: server did not respond"),
			want: "db_timeout",
		},

		// --- db_connection: real transport failures ---
		{
			name: "substring: connection refused",
			err:  errors.New("dial tcp: connection refused"),
			want: "db_connection",
		},
		{
			name: "substring: connection reset",
			err:  errors.New("write tcp: connection reset by peer"),
			want: "db_connection",
		},
		{
			name: "substring: broken pipe",