GOMODULES
/
pgx
mirror of https://github.com/jackc/pgx.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Always use keep-alive on TCP conns

pull/41/head
Jack Christensen 2014-09-27 12:13:10 -05:00
parent a724d7bce6
commit 3d7974ce30
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
conn.go
View File

@ -28,7 +28,6 @@ type ConnConfig struct {
Password string Password string
TLSConfig *tls.Config // config for TLS connection -- nil disables TLS TLSConfig *tls.Config // config for TLS connection -- nil disables TLS
Logger Logger Logger Logger
KeepAlive uint16 // keep-alive period for the connetion (0 disables keep-alive)
} }
// Conn is a PostgreSQL connection handle. It is not safe for concurrent usage. // Conn is a PostgreSQL connection handle. It is not safe for concurrent usage.
@ -133,10 +132,7 @@ func Connect(config ConnConfig) (c *Conn, err error) {
} }
} else { } else {
c.logger.Info(fmt.Sprintf("Dialing PostgreSQL server at host: %s:%d", c.config.Host, c.config.Port)) c.logger.Info(fmt.Sprintf("Dialing PostgreSQL server at host: %s:%d", c.config.Host, c.config.Port))
var d net.Dialer d := net.Dialer{KeepAlive: 5 * time.Minute}
if c.config.KeepAlive != 0 {
d.KeepAlive = time.Duration(c.config.KeepAlive) * time.Second
}
c.conn, err = d.Dial("tcp", fmt.Sprintf("%s:%d", c.config.Host, c.config.Port)) c.conn, err = d.Dial("tcp", fmt.Sprintf("%s:%d", c.config.Host, c.config.Port))
if err != nil { if err != nil {
c.logger.Error(fmt.Sprintf("Connection failed: %v", err)) c.logger.Error(fmt.Sprintf("Connection failed: %v", err))