jobs

package

v1.9.0 Latest Latest Go to latest Published: Mar 23, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/scylladb/gemini

Documentation ¶

Index ¶

Constants
func GenCheckStmt(s *typedef.Schema, table *typedef.Table, g generators.Interface, ...) *typedef.Stmt
func GenDDLStmt(s *typedef.Schema, t *typedef.Table, r *rand.Rand, ...) (*typedef.Stmts, error)
func GenMutateStmt(s *typedef.Schema, t *typedef.Table, g generators.Interface, r *rand.Rand, ...) (*typedef.Stmt, error)
type List
- func ListFromMode(mode string, duration time.Duration, workers uint64) List
- func (l List) Run(ctx context.Context, schema *typedef.Schema, schemaConfig typedef.SchemaConfig, ...) error
type PrettyCQLError
- func (e PrettyCQLError) Error() string

Constants ¶

View Source

const (
	WriteMode  = "write"
	ReadMode   = "read"
	MixedMode  = "mixed"
	WarmupMode = "warmup"
)

Variables ¶

This section is empty.

Functions ¶

func GenCheckStmt ¶ added in v1.8.3

func GenCheckStmt(
	s *typedef.Schema,
	table *typedef.Table,
	g generators.Interface,
	rnd *rand.Rand,
	p *typedef.PartitionRangeConfig,
) *typedef.Stmt

func GenDDLStmt ¶ added in v1.8.3

func GenDDLStmt(s *typedef.Schema, t *typedef.Table, r *rand.Rand, _ *typedef.PartitionRangeConfig, sc *typedef.SchemaConfig) (*typedef.Stmts, error)

func GenMutateStmt ¶ added in v1.8.3

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

Types ¶

type List ¶ added in v1.8.3

type List struct {
	// contains filtered or unexported fields
}

func ListFromMode ¶

func ListFromMode(mode string, duration time.Duration, workers uint64) List

func (List) Run ¶ added in v1.8.3

func (l List) Run(
	ctx context.Context,
	schema *typedef.Schema,
	schemaConfig typedef.SchemaConfig,
	s store.Store,
	generators *generators.Generators,
	globalStatus *status.GlobalStatus,
	logger *zap.Logger,
	seed uint64,
	stopFlag *stop.Flag,
	failFast, verbose bool,
) error

type PrettyCQLError ¶ added in v1.8.9

type PrettyCQLError struct {
	PrettyCQL error
	Err       error
	Stmt      *typedef.Stmt
}

func (PrettyCQLError) Error ¶ added in v1.8.9

func (e PrettyCQLError) Error() string

Source Files ¶

View all Source files

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