sandra

type Cassandra interface {
	QueryCtx(ctx context.Context, consistency gocql.Consistency, queryString string, queryParams ...interface{}) *gocql.Query
	Query(gocql.Consistency, string, ...interface{}) *gocql.Query
	ExecuteQueryCtx(ctx context.Context, queryString string, queryParams ...interface{}) error
	ExecuteQuery(string, ...interface{}) error
	ExecuteBatchCtx(ctx context.Context, batchType gocql.BatchType, queries []string, params [][]interface{}) error
	ExecuteBatch(gocql.BatchType, []string, [][]interface{}) error
	ExecuteUnloggedBatchCtx(ctx context.Context, queries []string, params [][]interface{}) error
	ExecuteUnloggedBatch([]string, [][]interface{}) error
	ScanQueryCtx(ctx context.Context, queryString string, queryParams []interface{}, outParams ...interface{}) error
	ScanQuery(string, []interface{}, ...interface{}) error
	ScanCASQueryCtx(ctx context.Context, queryString string, queryParams []interface{}, outParams ...interface{}) (applied bool, err error)
	ScanCASQuery(string, []interface{}, ...interface{}) (bool, error)
	IterQueryCtx(ctx context.Context, queryString string, queryParams []interface{}, outParams ...interface{}) func() (idx int, hasNext bool, err error)
	IterQuery(string, []interface{}, ...interface{}) func() (int, bool, error)
	Close() error
	Config() CassandraConfig
	Session() *gocql.Session
}

type CassandraConfig struct {
	// Required Parameters
	Nodes                    []string         `json:"nodes"`                        // addresses for the initial connections
	DataCenter               string           `json:"datacenter" config:"optional"` // data center name
	Keyspace                 string           `json:"keyspace"`                     // initial keyspace
	ReadConsistency          string           `json:"readconsistency"`              // consistency for read operations
	WriteConsistency         string           `json:"writeconsistency"`             // consistency for write operations
	SessionConsistency       string           `json:"session_consistency"`          // consistency that applies to all operations if no read or write consistency is set
	Timeout                  string           `json:"timeout"`                      // connection timeout (default: 600ms)
	ConnectTimeout           string           `json:"connect_timeout"`              // initial connection timeout (default: 600ms)
	KeepAlive                string           `json:"keepalive"`                    // The keepalive period to use default: 0
	NumConns                 int              `json:"numconns"`                     // number of connections per host (default: 2)
	Port                     int              `json:"port"`                         // port to connect to, default: 9042
	NumRetries               int              `json:"num_retries"`                  // number of retries in case of connection timeout
	DisableInitialHostLookup bool             `json:"disableinitialhostlookup"`     // Don't preform ip address discovery on the cluster, just use the Nodes provided
	PreferRPCAddress         bool             `json:"prefer_rpc_address"`           // Prefer to connect to rpc_addresses during cluster discovery
	PoolConfig               gocql.PoolConfig `json:""`
	// Authentication
	Username string `json:"username"`
	Password string `json:"password"`

	// SSL Options
	Ssl CassandraSslConfig `json:"ssl"` // ssl options cert/key/ca ...

	// TestMode affects whether a keyspace creation will be attempted on Cassandra initialization.
	TestMode bool `config:"optional"`
}

type CassandraSslConfig struct {
	Enabled bool
	Options *gocql.SslOptions
}

type TestErrorCassandra struct{}