Versions in this module Expand all Collapse all v1 v1.0.0 Nov 10, 2017 Changes in this version + var NotFound = errors.New("Not found") + func WaitForTables(db Cassandra, timeout time.Duration, tables ...string) error + type Cassandra interface + Close func() error + Config func() CassandraConfig + ExecuteBatch func(gocql.BatchType, []string, [][]interface{}) error + ExecuteQuery func(string, ...interface{}) error + ExecuteUnloggedBatch func([]string, [][]interface{}) error + IterQuery func(string, []interface{}, ...interface{}) func() (int, bool, error) + Query func(gocql.Consistency, string, ...interface{}) *gocql.Query + ScanCASQuery func(string, []interface{}, ...interface{}) (bool, error) + ScanQuery func(string, []interface{}, ...interface{}) error + func NewCassandra(config CassandraConfig) (Cassandra, error) + type CassandraConfig struct + ConnectTimeout string + DataCenter string + DisableInitialHostLookup bool + KeepAlive string + Keyspace string + Nodes []string + NumConns int + NumRetries int + Port int + PreferRPCAddress bool + ReadConsistency string + TestMode bool + Timeout string + WriteConsistency string + func (c CassandraConfig) String() string + type TestErrorCassandra struct + func (c *TestErrorCassandra) Close() error + func (c *TestErrorCassandra) Config() CassandraConfig + func (c *TestErrorCassandra) ExecuteBatch(batchType gocql.BatchType, queries []string, params [][]interface{}) error + func (c *TestErrorCassandra) ExecuteQuery(queryString string, queryParams ...interface{}) error + func (c *TestErrorCassandra) ExecuteUnloggedBatch(queries []string, params [][]interface{}) error + func (c *TestErrorCassandra) IterQuery(queryString string, queryParams []interface{}, outParams ...interface{}) func() (int, bool, error) + func (c *TestErrorCassandra) Query(consistency gocql.Consistency, queryString string, queryParams ...interface{}) *gocql.Query + func (c *TestErrorCassandra) ScanCASQuery(queryString string, queryParams []interface{}, outParams ...interface{}) (bool, error) + func (c *TestErrorCassandra) ScanQuery(queryString string, queryParams []interface{}, outParams ...interface{}) error
Go to main page