diff --git a/config.go b/config.go index 4ca09dda..8fd7efbf 100644 --- a/config.go +++ b/config.go @@ -822,7 +822,7 @@ func ValidateConnectTargetSessionAttrsPreferStandby(ctx context.Context, pgConn } if string(result.Rows[0][0]) != "t" { - return &NotStandbyError{err: errors.New("server is not in hot standby mode")} + return &NotPreferredError{err: errors.New("server is not in hot standby mode")} } return nil diff --git a/errors.go b/errors.go index 9f04476d..66d35584 100644 --- a/errors.go +++ b/errors.go @@ -220,19 +220,19 @@ func redactURL(u *url.URL) string { return u.String() } -type NotStandbyError struct { +type NotPreferredError struct { err error safeToRetry bool } -func (e *NotStandbyError) Error() string { +func (e *NotPreferredError) Error() string { return fmt.Sprintf("standby server not found: %s", e.err.Error()) } -func (e *NotStandbyError) SafeToRetry() bool { +func (e *NotPreferredError) SafeToRetry() bool { return e.safeToRetry } -func (e *NotStandbyError) Unwrap() error { +func (e *NotPreferredError) Unwrap() error { return e.err } diff --git a/pgconn.go b/pgconn.go index 5e436ffe..6093d17b 100644 --- a/pgconn.go +++ b/pgconn.go @@ -168,7 +168,7 @@ func ConnectConfig(ctx context.Context, config *Config) (pgConn *PgConn, err err break } } else if cerr, ok := err.(*connectError); ok { - if _, ok := cerr.err.(*NotStandbyError); ok { + if _, ok := cerr.err.(*NotPreferredError); ok { fallbackConfig = fc } }