From db6449b4542f68ba879ef9f2e9fef7fc222421d8 Mon Sep 17 00:00:00 2001 From: MitulShah1 Date: Mon, 14 Apr 2025 13:00:25 +0530 Subject: [PATCH] Updated config --- cassandra/cassandra.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/cassandra/cassandra.go b/cassandra/cassandra.go index cd2c17cd..060dfac0 100644 --- a/cassandra/cassandra.go +++ b/cassandra/cassandra.go @@ -27,9 +27,14 @@ type SchemaInfo struct { } // New creates a new Cassandra storage instance -func New(cfg Config) *Storage { +func New(cnfg Config) *Storage { + + // Default config + cfg := configDefault(cnfg) + // Create cluster config cluster := gocql.NewCluster(cfg.Hosts...) + cluster.Consistency = cfg.Consistency // Don't set keyspace initially - we need to create it first // We'll connect to system keyspace first