|
@@ -21,7 +21,7 @@ type ClusterConfig struct {
|
|
|
Hosts []string // addresses for the initial connections
|
|
Hosts []string // addresses for the initial connections
|
|
|
CQLVersion string // CQL version (default: 3.0.0)
|
|
CQLVersion string // CQL version (default: 3.0.0)
|
|
|
ProtoVersion int // version of the native protocol (default: 2)
|
|
ProtoVersion int // version of the native protocol (default: 2)
|
|
|
- Timeout time.Duration // connection timeout (default: 200ms)
|
|
|
|
|
|
|
+ Timeout time.Duration // connection timeout (default: 600ms)
|
|
|
DefaultPort int // default port (default: 9042)
|
|
DefaultPort int // default port (default: 9042)
|
|
|
Keyspace string // initial keyspace (optional)
|
|
Keyspace string // initial keyspace (optional)
|
|
|
NumConns int // number of connections per host (default: 2)
|
|
NumConns int // number of connections per host (default: 2)
|
|
@@ -40,7 +40,7 @@ func NewCluster(hosts ...string) *ClusterConfig {
|
|
|
Hosts: hosts,
|
|
Hosts: hosts,
|
|
|
CQLVersion: "3.0.0",
|
|
CQLVersion: "3.0.0",
|
|
|
ProtoVersion: 2,
|
|
ProtoVersion: 2,
|
|
|
- Timeout: 200 * time.Millisecond,
|
|
|
|
|
|
|
+ Timeout: 600 * time.Millisecond,
|
|
|
DefaultPort: 9042,
|
|
DefaultPort: 9042,
|
|
|
NumConns: 2,
|
|
NumConns: 2,
|
|
|
NumStreams: 128,
|
|
NumStreams: 128,
|
Christoph Hack