no closing connections mode

pgconn/config.go

@@ -65,6 +65,10 @@ type Config struct {
 	// that you close on FATAL errors by returning false.
 	OnPgError PgErrorHandler
 
+	// NoClosingConnMode enables mode when connections are not closed when timeout happens but cleaned up
+	// and returned back to the pool.
+	NoClosingConnMode bool
+
 	createdByParseConfig bool // Used to enforce created by ParseConfig rule.
 }
 

pgconn/errors.go

@@ -76,6 +76,8 @@ func (e *connectError) Unwrap() error {
 	return e.err
 }
 
+var ErrLockCleanupConn = &connLockError{status: "conn need to cleanup"}
+
 type connLockError struct {
 	status string
 }
@@ -163,25 +165,25 @@ func (e *errTimeout) Unwrap() error {
 	return e.err
 }
 
-type contextAlreadyDoneError struct {
+type ContextAlreadyDoneError struct {
 	err error
 }
 
-func (e *contextAlreadyDoneError) Error() string {
+func (e *ContextAlreadyDoneError) Error() string {
 	return fmt.Sprintf("context already done: %s", e.err.Error())
 }
 
-func (e *contextAlreadyDoneError) SafeToRetry() bool {
+func (e *ContextAlreadyDoneError) SafeToRetry() bool {
 	return true
 }
 
-func (e *contextAlreadyDoneError) Unwrap() error {
+func (e *ContextAlreadyDoneError) Unwrap() error {
 	return e.err
 }
 
-// newContextAlreadyDoneError double-wraps a context error in `contextAlreadyDoneError` and `errTimeout`.
+// newContextAlreadyDoneError double-wraps a context error in `ContextAlreadyDoneError` and `errTimeout`.
 func newContextAlreadyDoneError(ctx context.Context) (err error) {
-	return &errTimeout{&contextAlreadyDoneError{err: ctx.Err()}}
+	return &errTimeout{&ContextAlreadyDoneError{err: ctx.Err()}}
 }
 
 func redactPW(connString string) string {