Versions in this module Expand all Collapse all v1 v1.0.2 Jun 18, 2020 v1.0.1 Jun 18, 2020 Changes in this version + var BooksColumnsMock = []*gocql.ColumnMetadata + func NewDcInferringPolicy() *dcInferringPolicy + func NewDefaultHostSelectionPolicy() gocql.HostSelectionPolicy + func NewKeyspaceMock(ksName string, tables map[string][]*gocql.ColumnMetadata) *gocql.KeyspaceMetadata + type AlterTableAddInfo struct + Keyspace string + Table string + ToAdd []*gocql.ColumnMetadata + type AlterTableDropInfo struct + Keyspace string + Table string + ToDrop []string + type ColumnOrder struct + Column string + Order string + type Config struct + Password string + SslOptions *SslOptions + Username string + type CreateKeyspaceInfo struct + DCReplicas map[string]int + IfNotExists bool + Name string + type CreateTableInfo struct + ClusteringKeys []*gocql.ColumnMetadata + IfNotExists bool + Keyspace string + PartitionKeys []*gocql.ColumnMetadata + Table string + Values []*gocql.ColumnMetadata + type Db struct + func NewDb(config Config, hosts ...string) (*Db, error) + func NewDbWithConnectedInstance(session *gocql.Session) *Db + func NewDbWithSession(session Session) *Db + func (db *Db) AlterTableAdd(info *AlterTableAddInfo, options *QueryOptions) error + func (db *Db) AlterTableDrop(info *AlterTableDropInfo, options *QueryOptions) error + func (db *Db) CreateKeyspace(info *CreateKeyspaceInfo, options *QueryOptions) error + func (db *Db) CreateTable(info *CreateTableInfo, options *QueryOptions) error + func (db *Db) Delete(info *DeleteInfo, options *QueryOptions) (ResultSet, error) + func (db *Db) DropKeyspace(info *DropKeyspaceInfo, options *QueryOptions) error + func (db *Db) DropTable(info *DropTableInfo, options *QueryOptions) error + func (db *Db) Execute(query string, options *QueryOptions, values ...interface{}) (ResultSet, error) + func (db *Db) ExecuteNoResult(query string, options *QueryOptions, values ...interface{}) error + func (db *Db) Insert(info *InsertInfo, options *QueryOptions) (ResultSet, error) + func (db *Db) Keyspace(keyspace string) (*gocql.KeyspaceMetadata, error) + func (db *Db) KeyspaceNamingInfo(ks *gocql.KeyspaceMetadata) config.KeyspaceNamingInfo + func (db *Db) Keyspaces() ([]string, error) + func (db *Db) Select(info *SelectInfo, options *QueryOptions) (ResultSet, error) + func (db *Db) Update(info *UpdateInfo, options *QueryOptions) (ResultSet, error) + func (db *Db) Views(ksName string) (map[string]bool, error) + type DeleteInfo struct + Columns []string + IfCondition []types.ConditionItem + IfExists bool + Keyspace string + QueryParams []interface{} + Table string + type DropKeyspaceInfo struct + IfExists bool + Name string + type DropTableInfo struct + IfExists bool + Keyspace string + Table string + type GoCqlSession struct + func (session *GoCqlSession) ChangeSchema(query string, options *QueryOptions) error + func (session *GoCqlSession) Execute(query string, options *QueryOptions, values ...interface{}) error + func (session *GoCqlSession) ExecuteIter(query string, options *QueryOptions, values ...interface{}) (ResultSet, error) + func (session *GoCqlSession) KeyspaceMetadata(keyspaceName string) (*gocql.KeyspaceMetadata, error) + type InsertInfo struct + Columns []string + IfNotExists bool + Keyspace string + QueryParams []interface{} + TTL int + Table string + type QueryOptions struct + Consistency gocql.Consistency + Context context.Context + PageSize int + PageState []byte + SerialConsistency gocql.SerialConsistency + UserOrRole string + func NewQueryOptions() *QueryOptions + func (q *QueryOptions) WithConsistency(consistency gocql.Consistency) *QueryOptions + func (q *QueryOptions) WithContext(ctx context.Context) *QueryOptions + func (q *QueryOptions) WithPageSize(pageSize int) *QueryOptions + func (q *QueryOptions) WithPageState(pageState []byte) *QueryOptions + func (q *QueryOptions) WithSerialConsistency(serialConsistency gocql.SerialConsistency) *QueryOptions + func (q *QueryOptions) WithUserOrRole(userOrRole string) *QueryOptions + type ResultMock struct + func (o ResultMock) PageState() []byte + func (o ResultMock) Values() []map[string]interface{} + type ResultSet interface + PageState func() []byte + Values func() []map[string]interface{} + type SelectInfo struct + Keyspace string + Options *types.QueryOptions + OrderBy []ColumnOrder + Table string + Where []types.ConditionItem + type Session interface + ChangeSchema func(query string, options *QueryOptions) error + Execute func(query string, options *QueryOptions, values ...interface{}) error + ExecuteIter func(query string, options *QueryOptions, values ...interface{}) (ResultSet, error) + KeyspaceMetadata func(keyspaceName string) (*gocql.KeyspaceMetadata, error) + type SessionMock struct + func NewSessionMock() *SessionMock + func (o *SessionMock) AddKeyspace(keyspace *gocql.KeyspaceMetadata) *mock.Call + func (o *SessionMock) AddViews(views []string) *mock.Call + func (o *SessionMock) ChangeSchema(query string, options *QueryOptions) error + func (o *SessionMock) Default() *SessionMock + func (o *SessionMock) Execute(query string, options *QueryOptions, values ...interface{}) error + func (o *SessionMock) ExecuteIter(query string, options *QueryOptions, values ...interface{}) (ResultSet, error) + func (o *SessionMock) KeyspaceMetadata(keyspaceName string) (*gocql.KeyspaceMetadata, error) + func (o *SessionMock) SetSchemaVersion(version string) *mock.Call + type SslOptions struct + CaPath string + CertPath string + HostVerification bool + KeyPath string + type UpdateInfo struct + Columns []string + IfCondition []types.ConditionItem + IfExists bool + Keyspace string + QueryParams []interface{} + TTL int + Table *gocql.TableMetadata
Go to main page