generators

package

Go to main page

Versions in this module

v1

v1.8.7

Jul 20, 2023

Changes in this version

type Generator

+ func (g *Generator) FindAndMarkStalePartitions()

+ func (g *Generator) GetPartitionForToken(token TokenIndex) *Partition

+ func (g *Generator) GiveOlds(tokens []*typedef.ValueWithToken)

type GeneratorInterface

+ GiveOlds func(_ []*typedef.ValueWithToken)

type Partition

+ func (s *Partition) MarkStale()

+ func (s *Partition) Stale() bool

v1.8.6

Jul 6, 2023

v1.8.5

Jul 5, 2023

Changes in this version

+ func CreatePartitionKeyValues(table *typedef.Table, r *rand.Rand, g *typedef.PartitionRangeConfig) []interface

type Generator

+ func (g *Generator) Start(stopFlag *stop.Flag)

+ type Generators []*Generator

+ func (g Generators) StartAll(stopFlag *stop.Flag)

type Partition

+ func (s *Partition) Close()

type Partitions

+ func NewPartitions(count, pkBufferSize int, wakeUpSignal chan struct{}) Partitions

+ func (p Partitions) CloseAll()

+ func (p Partitions) GetPartitionForToken(token TokenIndex) *Partition

v1.8.4

Jun 20, 2023

v1.8.3

Jun 15, 2023

Changes in this version

+ func CreateMaterializedViews(c typedef.Columns, tableName string, ...) []typedef.MaterializedView

type Partition

+ func (s *Partition) NeedMoreValues() bool

+ type Partitions []*Partition

+ func (p Partitions) NeedMoreValues() bool

v1.8.2

Jun 1, 2023

Changes in this version

+ func CreateIndexesForColumn(c testschema.Columns, tableName string, maxIndexes int) []typedef.IndexDef

+ func CreatePkColumns(cnt int, prefix string) testschema.Columns

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

+ func GenColumnName(prefix string, idx int) string

+ func GenColumnType(numColumns int, sc *typedef.SchemaConfig) typedef.Type

+ func GenDDLStmt(s *testschema.Schema, t *testschema.Table, r *rand.Rand, ...) (*typedef.Stmts, error)

+ func GenIndexName(prefix string, idx int) string

+ func GenListType(sc *typedef.SchemaConfig) *coltypes.BagType

+ func GenMapType(sc *typedef.SchemaConfig) *coltypes.MapType

+ func GenMutateStmt(s *testschema.Schema, t *testschema.Table, g *Generator, r *rand.Rand, ...) (*typedef.Stmt, error)

+ func GenPartitionKeyColumnType() typedef.Type

+ func GenPrimaryKeyColumnType() typedef.Type

+ func GenSchema(sc typedef.SchemaConfig) *testschema.Schema

+ func GenSetType(sc *typedef.SchemaConfig) *coltypes.BagType

+ func GenSimpleType(sc *typedef.SchemaConfig) coltypes.SimpleType

+ func GenTupleType(sc *typedef.SchemaConfig) typedef.Type

+ func GenUDTType(sc *typedef.SchemaConfig) *coltypes.UDTType

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

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

+ func GetCreateTable(t *testschema.Table, ks typedef.Keyspace) string

+ func GetCreateTypes(t *testschema.Table, keyspace typedef.Keyspace) []string

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

+ type Config struct

+ PartitionsCount uint64

+ PartitionsDistributionFunc DistributionFunc

+ PartitionsRangeConfig typedef.PartitionRangeConfig

+ PkUsedBufferSize uint64

+ Seed uint64

+ type DistributionFunc func() TokenIndex

+ type Generator struct

+ func NewGenerator(ctx context.Context, table *testschema.Table, config *Config, ...) *Generator

+ func (g *Generator) Get() *typedef.ValueWithToken

+ func (g *Generator) GetOld() *typedef.ValueWithToken

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

+ func (g *Generator) PartitionCount() uint64

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

+ type GeneratorInterface interface

+ Get func() *typedef.ValueWithToken

+ GetOld func() *typedef.ValueWithToken

+ GiveOld func(_ *typedef.ValueWithToken)

+ ReleaseToken func(_ uint64)

+ type MockGenerator struct

+ func NewTestGenerator(table *testschema.Table, rnd *rand.Rand, ...) *MockGenerator

+ func (g *MockGenerator) Get() *typedef.ValueWithToken

+ func (g *MockGenerator) GetOld() *typedef.ValueWithToken

+ func (g *MockGenerator) GiveOld(_ *typedef.ValueWithToken)

+ func (g *MockGenerator) ReleaseToken(_ uint64)

+ type Partition struct

+ type TokenIndex uint64

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