From 434d686687d6ce80749ad57763fc347412db9b94 Mon Sep 17 00:00:00 2001 From: kilocaleb Date: Fri, 14 Aug 2020 15:17:47 +0200 Subject: [PATCH 1/2] setting option for gocql: DisableInitialHostLookup thru backend config section --- physical/cassandra/cassandra.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/physical/cassandra/cassandra.go b/physical/cassandra/cassandra.go index 6530bd204137..4a9dacbb3657 100644 --- a/physical/cassandra/cassandra.go +++ b/physical/cassandra/cassandra.go @@ -132,6 +132,13 @@ func NewCassandraBackend(conf map[string]string, logger log.Logger) (physical.Ba cluster.Timeout = time.Duration(connectionTimeout) * time.Second } + if disableInitialHostLookupStr, ok := conf["disable_host_initial_lookup"]; ok { + disableInitialHostLookup, err := strconv.ParseBool(disableInitialHostLookupStr) + if err != nil { + return nil, fmt.Errorf("'disable_host_initial_lookup' must be a bool") + } + cluster.DisableInitialHostLookup = disableInitialHostLookup + } if err := setupCassandraTLS(conf, cluster); err != nil { return nil, err } From 02a33c4bfc765e2afdff903bed355dc4b1c74d71 Mon Sep 17 00:00:00 2001 From: kilocaleb Date: Fri, 14 Aug 2020 17:53:10 +0200 Subject: [PATCH 2/2] adding newline between 'if' blocks to keep code strict --- physical/cassandra/cassandra.go | 1 + 1 file changed, 1 insertion(+) diff --git a/physical/cassandra/cassandra.go b/physical/cassandra/cassandra.go index 4a9dacbb3657..73f2f2dbc0de 100644 --- a/physical/cassandra/cassandra.go +++ b/physical/cassandra/cassandra.go @@ -139,6 +139,7 @@ func NewCassandraBackend(conf map[string]string, logger log.Logger) (physical.Ba } cluster.DisableInitialHostLookup = disableInitialHostLookup } + if err := setupCassandraTLS(conf, cluster); err != nil { return nil, err }