metricsHandler metrics.Handler,
serializer serialization.Serializer,
session, err := commongocql.NewSession(
func() (*gocql.ClusterConfig, error) {
return commongocql.NewCassandraCluster(cfg, r)
},
logger,
metricsHandler,
)
logger.Fatal("unable to initialize cassandra session", tag.Error(err))
}
cfg,
clusterName,
logger,
session,
serializer,
)
}