tpcc

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2020 License: Apache-2.0 Imports: 15 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewWorkloader

func NewWorkloader(db *sql.DB, cfg *Config) (workload.Workloader, error)

NewWorkloader creates the tpc-c workloader

Types

type Config

type Config struct {
	DBName          string
	Threads         int
	Parts           int
	Warehouses      int
	UseFK           bool
	Isolation       int
	CheckAll        bool
	OutputDir       string
	SpecifiedTables string
}

Config is the configuration for tpcc workload

type Workloader

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

Workloader is TPCC workload

func (*Workloader) Check

func (w *Workloader) Check(ctx context.Context, threadID int) error

Check implements Workloader interface

func (*Workloader) CheckPrepare

func (w *Workloader) CheckPrepare(ctx context.Context, threadID int) error

CheckPrepare implements Workloader interface

func (*Workloader) Cleanup

func (w *Workloader) Cleanup(ctx context.Context, threadID int) error

Cleanup implements Workloader interface

func (*Workloader) CleanupThread

func (w *Workloader) CleanupThread(ctx context.Context, threadID int)

CleanupThread implements Workloader interface

func (*Workloader) DBName

func (w *Workloader) DBName() string

DBName returns the name of test db.

func (*Workloader) DataGen

func (w *Workloader) DataGen() bool

DataGen returns a bool to represent whether to generate csv data or load data to db.

func (*Workloader) InitThread

func (w *Workloader) InitThread(ctx context.Context, threadID int) context.Context

InitThread implements Workloader interface

func (*Workloader) Name

func (w *Workloader) Name() string

Name implements Workloader interface

func (*Workloader) Prepare

func (w *Workloader) Prepare(ctx context.Context, threadID int) error

Prepare implements Workloader interface

func (*Workloader) Run

func (w *Workloader) Run(ctx context.Context, threadID int) error

Run implements Workloader interface

Jump to

Keyboard shortcuts

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