rename error

pull/1281/head
sergey.bashilov 2022-06-24 14:20:36 +03:00 committed by Jack Christensen
parent 618a12a094
commit cdc240d920
3 changed files with 6 additions and 6 deletions

View File

@ -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

View File

@ -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
}

View File

@ -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
}
}