gocassa

package module

Go to main page

Versions in this module

v1

v1.2.1

Jul 31, 2024

Changes in this version

+ func BucketerString(b Bucketer) string

+ func Dump(tc TableChanger, md MockDumper)

+ type Bucketer interface

+ Bucket func(int64) int64

+ Next func(int64) int64

+ String func() string

type Connection

+ Close func()

type KeySpace

+ FlexMultiTimeSeriesTable func(name, timeField, idField string, indexFields []string, bucketer Bucketer, ...) MultiTimeSeriesTable

+ type MockDumper func(k interface{}, row interface{})

type QueryExecutor

+ Close func()

v1.2.0

Dec 22, 2015

Changes in this version

type ColumnDirection

+ func (d ColumnDirection) String() string

v1.1.0

Nov 27, 2015

v1.0.0

Nov 20, 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL