sandra

type Cassandra interface {
	Query(gocql.Consistency, string, ...interface{}) *gocql.Query
	ExecuteQuery(string, ...interface{}) error
	ExecuteBatch(gocql.BatchType, []string, [][]interface{}) error
	ExecuteUnloggedBatch([]string, [][]interface{}) error
	ScanQuery(string, []interface{}, ...interface{}) error
	ScanCASQuery(string, []interface{}, ...interface{}) (bool, error)
	IterQuery(string, []interface{}, ...interface{}) func() (int, bool, error)
	Close() error
	Config() CassandraConfig
}

type CassandraConfig struct {
	// Required Parameters
	Nodes                    []string // addresses for the initial connections
	DataCenter               string   // data center name
	Keyspace                 string   // initial keyspace
	ReadConsistency          string   // consistency for read operations
	WriteConsistency         string   // consistency for write operations
	Timeout                  string   `config:"optional"`                           // connection timeout (default: 600ms)
	ConnectTimeout           string   `config:"optional" yaml:"connect_timeout"`    // initial connection timeout (default: 600ms)
	KeepAlive                string   `config:"optional"`                           // The keepalive period to use default: 0
	NumConns                 int      `config:"optional"`                           // number of connections per host (default: 2)
	Port                     int      `config:"optional"`                           // port to connect to, default: 9042
	NumRetries               int      `config:"optional" yaml:"num_retries"`        // number of retries in case of connection timeout
	DisableInitialHostLookup bool     `config:"optional"`                           // Don't preform ip address discovery on the cluster, just use the Nodes provided
	PreferRPCAddress         bool     `config:"optional" yaml:"prefer_rpc_address"` // Prefer to connect to rpc_addresses during cluster discovery

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

type TestErrorCassandra struct{}