Versions in this module Expand all Collapse all v1 v1.1.0 Nov 27, 2015 Changes in this version + type ClusteringOrderColumn struct + Column string + Direction ColumnDirection + type ColumnDirection bool + const ASC + const DESC + type Connection interface + CreateKeySpace func(name string) error + DropKeySpace func(name string) error + KeySpace func(name string) KeySpace + func Connect(nodeIps []string, username, password string) (Connection, error) + func NewConnection(q QueryExecutor) Connection + type Counter int + type Filter interface + Delete func() Op + Read func(pointerToASlice interface{}) Op + ReadOne func(pointer interface{}) Op + Update func(m map[string]interface{}) Op + type KeySpace interface + DebugMode func(bool) + Exists func(string) (bool, error) + MapTable func(tableName, id string, row interface{}) MapTable + MultiTimeSeriesTable func(tableName, fieldToIndexByField, timeField, uniqueKey string, ...) MultiTimeSeriesTable + MultimapMultiKeyTable func(tableName string, fieldToIndexBy, uniqueKey []string, row interface{}) MultimapMkTable + MultimapTable func(tableName, fieldToIndexBy, uniqueKey string, row interface{}) MultimapTable + Name func() string + Table func(tableName string, row interface{}, keys Keys) Table + Tables func() ([]string, error) + TimeSeriesTable func(tableName, timeField, uniqueKey string, bucketSize time.Duration, ...) TimeSeriesTable + func ConnectToKeySpace(keySpace string, nodeIps []string, username, password string) (KeySpace, error) + func NewMockKeySpace() KeySpace + type Keys struct + ClusteringColumns []string + Compound bool + PartitionKeys []string + type MapTable interface + Delete func(id interface{}) Op + MultiRead func(ids []interface{}, pointerToASlice interface{}) Op + Read func(id, pointer interface{}) Op + Set func(v interface{}) Op + Update func(id interface{}, m map[string]interface{}) Op + WithOptions func(Options) MapTable + type MockFilter struct + func (f *MockFilter) Delete() Op + func (f *MockFilter) Update(m map[string]interface{}) Op + func (f *MockFilter) UpdateWithOptions(m map[string]interface{}, options Options) Op + func (q *MockFilter) Read(out interface{}) Op + func (q *MockFilter) ReadOne(out interface{}) Op + type MockTable struct + func (t *MockTable) Create() error + func (t *MockTable) CreateIfNotExist() error + func (t *MockTable) CreateIfNotExistStatement() (string, error) + func (t *MockTable) CreateStatement() (string, error) + func (t *MockTable) Name() string + func (t *MockTable) Recreate() error + func (t *MockTable) Set(i interface{}) Op + func (t *MockTable) SetWithOptions(i interface{}, options Options) Op + func (t *MockTable) Where(relations ...Relation) Filter + func (t *MockTable) WithOptions(o Options) Table + type Modifier struct + func CounterIncrement(value int) Modifier + func ListAppend(value interface{}) Modifier + func ListPrepend(value interface{}) Modifier + func ListRemove(value interface{}) Modifier + func ListSetAtIndex(index int, value interface{}) Modifier + func MapSetField(key, value interface{}) Modifier + func MapSetFields(fields map[string]interface{}) Modifier + type MultiTimeSeriesTable interface + Delete func(v interface{}, timeStamp time.Time, id interface{}) Op + List func(v interface{}, start, end time.Time, pointerToASlice interface{}) Op + Read func(v interface{}, timeStamp time.Time, id, pointer interface{}) Op + Set func(v interface{}) Op + Update func(v interface{}, timeStamp time.Time, id interface{}, m map[string]interface{}) Op + WithOptions func(Options) MultiTimeSeriesTable + type MultimapMkTable interface + Delete func(v, id map[string]interface{}) Op + DeleteAll func(v map[string]interface{}) Op + List func(v, startId map[string]interface{}, limit int, pointerToASlice interface{}) Op + MultiRead func(v, id map[string]interface{}, pointerToASlice interface{}) Op + Read func(v, id map[string]interface{}, pointer interface{}) Op + Set func(v interface{}) Op + Update func(v, id map[string]interface{}, m map[string]interface{}) Op + WithOptions func(Options) MultimapMkTable + type MultimapTable interface + Delete func(v, id interface{}) Op + DeleteAll func(v interface{}) Op + List func(v, startId interface{}, limit int, pointerToASlice interface{}) Op + MultiRead func(v interface{}, ids []interface{}, pointerToASlice interface{}) Op + Read func(v, id, pointer interface{}) Op + Set func(v interface{}) Op + Update func(v, id interface{}, m map[string]interface{}) Op + WithOptions func(Options) MultimapTable + type Op interface + Add func(...Op) Op + GenerateStatement func() (string, []interface{}) + Preflight func() error + QueryExecutor func() QueryExecutor + Run func() error + RunAtomically func() error + WithOptions func(Options) Op + func Noop() Op + type Options struct + AllowFiltering bool + ClusteringOrder []ClusteringOrderColumn + CompactStorage bool + Compressor string + Consistency *gocql.Consistency + Limit int + Select []string + TTL time.Duration + TableName string + func (o Options) AppendClusteringOrder(column string, direction ColumnDirection) Options + func (o Options) Merge(neu Options) Options + type QueryExecutor interface + Execute func(stmt string, params ...interface{}) error + ExecuteAtomically func(stmt []string, params [][]interface{}) error + ExecuteWithOptions func(opts Options, stmt string, params ...interface{}) error + Query func(stmt string, params ...interface{}) ([]map[string]interface{}, error) + QueryWithOptions func(opts Options, stmt string, params ...interface{}) ([]map[string]interface{}, error) + func GoCQLSessionToQueryExecutor(sess *gocql.Session) QueryExecutor + type Relation struct + func Eq(key string, term interface{}) Relation + func GT(key string, term interface{}) Relation + func GTE(key string, term interface{}) Relation + func In(key string, terms ...interface{}) Relation + func LT(key string, term interface{}) Relation + func LTE(key string, term interface{}) Relation + type RowNotFoundError struct + func (r RowNotFoundError) Error() string + type Table interface + Set func(v interface{}) Op + Where func(relations ...Relation) Filter + WithOptions func(Options) Table + type TableChanger interface + Create func() error + CreateIfNotExist func() error + CreateIfNotExistStatement func() (string, error) + CreateStatement func() (string, error) + Name func() string + Recreate func() error + type TimeSeriesTable interface + Delete func(timeStamp time.Time, id interface{}) Op + List func(start, end time.Time, pointerToASlice interface{}) Op + Read func(timeStamp time.Time, id, pointer interface{}) Op + Set func(v interface{}) Op + Update func(timeStamp time.Time, id interface{}, m map[string]interface{}) Op + WithOptions func(Options) TimeSeriesTable
Go to main page