gemini

May 16, 2023

Changes in this version

type ColumnDef

+ func (cd *ColumnDef) IsValidForPrimaryKey() bool

type Columns

+ func (c Columns) CreateIndexes(tableName string, maxIndexes int) []IndexDef

+ func (c Columns) CreateMaterializedViews(tableName string, partitionKeys, clusteringKeys Columns) []MaterializedView

+ func (c Columns) Random() *ColumnDef

+ func (c Columns) ValidColumnsForPrimaryKey() Columns

type Generator

+ func (g *Generator) ReleaseToken(token uint64)

type StatementType

+ const Updatetatement

type Stmt

+ ValuesWithToken *ValueWithToken

type Value

+ func (v Value) Copy() Value

Apr 25, 2023

Changes in this version

+ var ErrSchemaConfigInvalidCK = errors.New(...)

+ var ErrSchemaConfigInvalidCols = errors.New("max number of columns must be bigger than min number of columns")

+ var ErrSchemaConfigInvalidPK = errors.New(...)

+ func IgnoreError(fn func() error)

type CQLFeature

+ const KnownIssuesJSONWithTuples

Sep 1, 2022

Changes in this version

type MaterializedView

+ NonPrimaryKey ColumnDef

May 25, 2020

Changes in this version

type PartitionRangeConfig

+ UseLWT bool

type SchemaConfig

+ UseLWT bool

Feb 19, 2020

Changes in this version

type SchemaConfig

+ TableOptions []tableopts.Option

type Table

+ TableOptions []string

Feb 18, 2020

Changes in this version

type Keyspace

+ OracleReplication *replication.Replication

type Schema

+ func (s *Schema) GetCreateKeyspaces() (string, string)

type SchemaConfig

+ OracleReplicationStrategy *replication.Replication

Feb 12, 2020

Changes in this version

+ const TYPE_ASCII

+ const TYPE_BIGINT

+ const TYPE_BLOB

+ const TYPE_BOOLEAN

+ const TYPE_DATE

+ const TYPE_DECIMAL

+ const TYPE_DOUBLE

+ const TYPE_DURATION

+ const TYPE_FLOAT

+ const TYPE_INET

+ const TYPE_INT

+ const TYPE_SMALLINT

+ const TYPE_TEXT

+ const TYPE_TIME

+ const TYPE_TIMESTAMP

+ const TYPE_TIMEUUID

+ const TYPE_TINYINT

+ const TYPE_UUID

+ const TYPE_VARCHAR

+ const TYPE_VARINT

+ var SchemaConfigInvalidCK = errors.New(...)

+ var SchemaConfigInvalidCols = errors.New("max number of columns must be bigger than min number of columns")

+ var SchemaConfigInvalidPK = errors.New(...)

+ type AlterTableBuilder struct

+ func (atb *AlterTableBuilder) ToCql() (string, []string)

+ type BagType struct

+ Frozen bool

+ Kind string

+ Type SimpleType

+ func (ct BagType) CQLDef() string

+ func (ct BagType) CQLHolder() string

+ func (ct BagType) CQLPretty(query string, value []interface{}) (string, int)

+ func (ct BagType) GenValue(r *rand.Rand, p PartitionRangeConfig) []interface{}

+ func (ct BagType) Indexable() bool

+ func (ct BagType) Name() string

+ func (st BagType) CQLType() gocql.TypeInfo

+ type CQLFeature int

+ const CQL_FEATURE_ALL

+ const CQL_FEATURE_BASIC

+ const CQL_FEATURE_NORMAL

+ const KnownIssuesJsonWithTuples

+ type ColumnDef struct

+ Name string

+ Type Type

+ func (cd *ColumnDef) UnmarshalJSON(data []byte) error

+ type Columns []ColumnDef

+ func (c Columns) Names() []string

+ func (cs Columns) ToJSONMap(values map[string]interface{}, r *rand.Rand, p PartitionRangeConfig) map[string]interface{}

+ type CompactionStrategy struct

+ BucketHigh float32

+ BucketLow float32

+ Class string

+ CompactionWindowSize int

+ CompactionWindowUnit string

+ Enabled bool

+ MaxThreshold int

+ MinSSTableSize int

+ MinThreshold int

+ SSTableSizeInMB int

+ SplitDuringFlush bool

+ TombstoneCompactionInterval int

+ TombstoneThreshold float32

+ func NewLeveledCompactionStrategy() *CompactionStrategy

+ func NewSizeTieredCompactionStrategy() *CompactionStrategy

+ func NewTimeWindowCompactionStrategy() *CompactionStrategy

+ func (cs *CompactionStrategy) ToCQL() string

+ type CounterType struct

+ Value int64

+ func (ct CounterType) CQLDef() string

+ func (ct CounterType) CQLHolder() string

+ func (ct CounterType) CQLPretty(query string, value []interface{}) (string, int)

+ func (ct CounterType) CQLType() gocql.TypeInfo

+ func (ct CounterType) GenValue(r *rand.Rand, p PartitionRangeConfig) []interface{}

+ func (ct CounterType) Indexable() bool

+ func (ct CounterType) Name() string

+ type DistributionFunc func() TokenIndex

+ type Generator struct

+ func NewGenerator(table *Table, config *GeneratorConfig, logger *zap.Logger) *Generator

+ func (g *Generator) GiveOld(v ValueWithToken)

+ func (g *Generator) Stop()

+ func (g Generator) Get() (ValueWithToken, bool)

+ func (g Generator) GetOld() (ValueWithToken, bool)

+ type GeneratorConfig struct

+ PartitionsCount uint64

+ PartitionsDistributionFunc DistributionFunc

+ PartitionsRangeConfig PartitionRangeConfig

+ PkUsedBufferSize uint64

+ Seed uint64

+ type IndexDef struct

+ Column string

+ ColumnIdx int

+ Name string

+ type Keyspace struct

+ Name string

+ Replication *replication.Replication

+ type MapType struct

+ Frozen bool

+ KeyType SimpleType

+ ValueType SimpleType

+ func (mt MapType) CQLDef() string

+ func (mt MapType) CQLHolder() string

+ func (mt MapType) CQLPretty(query string, value []interface{}) (string, int)

+ func (mt MapType) GenValue(r *rand.Rand, p PartitionRangeConfig) []interface{}

+ func (mt MapType) Indexable() bool

+ func (mt MapType) Name() string

+ func (st MapType) CQLType() gocql.TypeInfo

+ type MaterializedView struct

+ ClusteringKeys Columns

+ Name string

+ PartitionKeys Columns

+ type Partition struct

+ type PartitionRangeConfig struct

+ MaxBlobLength int

+ MaxStringLength int

+ MinBlobLength int

+ MinStringLength int

+ type RoutingKeyCreator struct

+ func (rc *RoutingKeyCreator) CreateRoutingKey(table *Table, values []interface{}) ([]byte, error)

+ type Schema struct

+ Keyspace Keyspace

+ Tables []*Table

+ func GenSchema(sc SchemaConfig) *Schema

+ func (s *Schema) GenCheckStmt(t *Table, g *Generator, r *rand.Rand, p PartitionRangeConfig) *Stmt

+ func (s *Schema) GenDDLStmt(t *Table, r *rand.Rand, p PartitionRangeConfig, sc *SchemaConfig) ([]*Stmt, func(), error)

+ func (s *Schema) GenDeleteRows(t *Table, g *Generator, r *rand.Rand, p PartitionRangeConfig) (*Stmt, error)

+ func (s *Schema) GenInsertJsonStmt(t *Table, g *Generator, r *rand.Rand, p PartitionRangeConfig) (*Stmt, error)

+ func (s *Schema) GenInsertStmt(t *Table, g *Generator, r *rand.Rand, p PartitionRangeConfig) (*Stmt, error)

+ func (s *Schema) GenMutateStmt(t *Table, g *Generator, r *rand.Rand, p PartitionRangeConfig, deletes bool) (*Stmt, error)

+ func (s *Schema) GetCreateSchema() []string

+ func (s *Schema) GetDropSchema() []string

+ type SchemaBuilder interface

+ Build func() *Schema

+ Keyspace func(Keyspace) SchemaBuilder

+ Table func(*Table) SchemaBuilder

+ func NewSchemaBuilder() SchemaBuilder

+ type SchemaConfig struct

+ AsyncObjectStabilizationAttempts int

+ AsyncObjectStabilizationDelay time.Duration

+ CQLFeature CQLFeature

+ CompactionStrategy *CompactionStrategy

+ MaxBlobLength int

+ MaxClusteringKeys int

+ MaxColumns int

+ MaxPartitionKeys int

+ MaxStringLength int

+ MaxTables int

+ MaxTupleParts int

+ MaxUDTParts int

+ MinBlobLength int

+ MinClusteringKeys int

+ MinColumns int

+ MinPartitionKeys int

+ MinStringLength int

+ ReplicationStrategy *replication.Replication

+ UseCounters bool

+ func (sc *SchemaConfig) GetMaxClusteringKeys() int

+ func (sc *SchemaConfig) GetMaxColumns() int

+ func (sc *SchemaConfig) GetMaxPartitionKeys() int

+ func (sc *SchemaConfig) GetMaxTables() int

+ func (sc *SchemaConfig) GetMinClusteringKeys() int

+ func (sc *SchemaConfig) GetMinColumns() int

+ func (sc *SchemaConfig) GetMinPartitionKeys() int

+ func (sc *SchemaConfig) Valid() error

+ type SimpleType string

+ func (st SimpleType) CQLDef() string

+ func (st SimpleType) CQLHolder() string

+ func (st SimpleType) CQLPretty(query string, value []interface{}) (string, int)

+ func (st SimpleType) CQLType() gocql.TypeInfo

+ func (st SimpleType) GenValue(r *rand.Rand, p PartitionRangeConfig) []interface{}

+ func (st SimpleType) Indexable() bool

+ func (st SimpleType) Name() string

+ type StatementType uint8

+ const AlterColumnStatementType

+ const DeleteStatementType

+ const DropColumnStatementType

+ const InsertStatement

+ const SelectByIndexStatementType

+ const SelectFromMaterializedViewStatementType

+ const SelectRangeStatementType

+ const SelectStatementType

+ func (st StatementType) PossibleAsyncOperation() bool

+ type Stmt struct

+ Query qb.Builder

+ QueryType StatementType

+ Types []Type

+ Values func() (uint64, []interface{})

+ func (s *Stmt) PrettyCQL() string

+ type Table struct

+ ClusteringKeys Columns

+ Columns Columns

+ CompactionStrategy *CompactionStrategy

+ Indexes []IndexDef

+ KnownIssues map[string]bool

+ MaterializedViews []MaterializedView

+ Name string

+ PartitionKeys Columns

+ func (t *Table) GetCreateTable(ks Keyspace) string

+ func (t *Table) GetCreateTypes(keyspace Keyspace) []string

+ func (t *Table) Lock()

+ func (t *Table) Unlock()

+ type TokenIndex uint64

+ type TupleType struct

+ Frozen bool

+ Types []SimpleType

+ func (st TupleType) CQLType() gocql.TypeInfo

+ func (st TupleType) Indexable() bool

+ func (tt TupleType) CQLDef() string

+ func (tt TupleType) CQLHolder() string

+ func (tt TupleType) CQLPretty(query string, value []interface{}) (string, int)

+ func (tt TupleType) GenValue(r *rand.Rand, p PartitionRangeConfig) []interface{}

+ func (tt TupleType) Name() string

+ type Type interface

+ CQLDef func() string

+ CQLHolder func() string

+ CQLPretty func(string, []interface{}) (string, int)

+ CQLType func() gocql.TypeInfo

+ GenValue func(*rand.Rand, PartitionRangeConfig) []interface{}

+ Indexable func() bool

+ Name func() string

+ type UDTType struct

+ Frozen bool

+ TypeName string

+ Types map[string]SimpleType

+ func (st UDTType) CQLType() gocql.TypeInfo

+ func (tt UDTType) CQLDef() string

+ func (tt UDTType) CQLHolder() string

+ func (tt UDTType) CQLPretty(query string, value []interface{}) (string, int)

+ func (tt UDTType) GenValue(r *rand.Rand, p PartitionRangeConfig) []interface{}

+ func (tt UDTType) Indexable() bool

+ func (tt UDTType) Name() string

+ type Value []interface

+ type ValueWithToken struct

+ Token uint64

+ Value Value