ch

package

v1.0.8 Latest Latest Go to latest Published: Jan 12, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Details

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

Repository

github.com/pingcap/go-tpc

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewWorkloader ¶

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

NewWorkloader new work loader

Types ¶

type Config ¶

type Config struct {
	DBName               string
	RawQueries           string
	QueryNames           []string
	CreateTiFlashReplica bool
	AnalyzeTable         analyzeConfig
	RefreshConnWait      time.Duration
}

Config is the configuration for ch workload

type Workloader ¶

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

Workloader is CH workload

func (Workloader) Check ¶

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

Check checks data

func (Workloader) CheckPrepare ¶

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

CheckPrepare checks prepare

func (Workloader) Cleanup ¶

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

Cleanup cleans up workloader

func (Workloader) CleanupThread ¶

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

CleanupThread cleans up thread

func (Workloader) DBName ¶

func (w Workloader) DBName() string

DBName returns the name of test db.

func (Workloader) InitThread ¶

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

InitThread inits thread

func (Workloader) Name ¶

func (w Workloader) Name() string

Name return workloader name

func (Workloader) OutputStats ¶

func (w Workloader) OutputStats(ifSummaryReport bool)

func (Workloader) Prepare ¶

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

Prepare prepares data

func (Workloader) Run ¶

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

Run runs workload

Source Files ¶

View all Source files

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