Merge pull request #169 from sylwiaszunejko/heartbeat

Send heartbeat OPTIONS message less frequent and enable keep alive

cluster.go

@@ -117,7 +117,7 @@ type ClusterConfig struct {
 	// Default reconnection policy to use for reconnecting before trying to mark host as down.
 	ReconnectionPolicy ReconnectionPolicy
 
-	// The keepalive period to use, enabled if > 0 (default: 0)
+	// The keepalive period to use, enabled if > 0 (default: 15 seconds)
 	// SocketKeepalive is used to set up the default dialer and is ignored if Dialer or HostDialer is provided.
 	SocketKeepalive time.Duration
 
@@ -290,6 +290,7 @@ func NewCluster(hosts ...string) *ClusterConfig {
 		ReconnectInterval:      60 * time.Second,
 		ConvictionPolicy:       &SimpleConvictionPolicy{},
 		ReconnectionPolicy:     &ConstantReconnectionPolicy{MaxRetries: 3, Interval: 1 * time.Second},
+		SocketKeepalive:        15 * time.Second,
 		WriteCoalesceWaitTime:  200 * time.Microsecond,
 	}
 

conn.go

@@ -680,7 +680,7 @@ func (c *Conn) heartBeat(ctx context.Context) {
 		switch resp.(type) {
 		case *supportedFrame:
 			// Everything ok
-			sleepTime = 5 * time.Second
+			sleepTime = 30 * time.Second
 			failures = 0
 		case error:
 			// TODO: should we do something here?

control.go

@@ -87,7 +87,7 @@ func (c *controlConn) heartBeat() {
 		switch resp.(type) {
 		case *supportedFrame:
 			// Everything ok
-			sleepTime = 5 * time.Second
+			sleepTime = 30 * time.Second
 			continue
 		case error:
 			goto reconn