rawsql

package

v1.0.12 Latest Latest Go to latest Published: Jul 9, 2025 License: Apache-2.0 Imports: 10 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

Types ¶

type Config ¶

type Config struct {
	DBName             string
	Queries            map[string]string // query name: query SQL
	QueryNames         []string
	ExecExplainAnalyze bool
	RefreshWait        time.Duration

	// output style
	OutputStyle        string
	EnablePlanReplayer bool
	PlanReplayerConfig replayer.PlanReplayerConfig
}

type Workloader ¶

type Workloader struct {
	PlanReplayerRunner *replayer.PlanReplayerRunner
	// contains filtered or unexported fields
}

func (*Workloader) Check ¶

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

func (*Workloader) CheckPrepare ¶

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

func (*Workloader) Cleanup ¶

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

func (*Workloader) CleanupThread ¶

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

func (*Workloader) DBName ¶

func (w *Workloader) DBName() string

func (*Workloader) Exec ¶ added in v1.0.10

func (w *Workloader) Exec(sql string) error

func (*Workloader) FinishPlanReplayerDump ¶ added in v1.0.9

func (w *Workloader) FinishPlanReplayerDump() error

func (*Workloader) InitThread ¶

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

func (*Workloader) IsPlanReplayerDumpEnabled ¶ added in v1.0.9

func (w *Workloader) IsPlanReplayerDumpEnabled() bool

func (*Workloader) Name ¶

func (w *Workloader) Name() string

func (*Workloader) OutputStats ¶

func (w *Workloader) OutputStats(ifSummaryReport bool)

func (*Workloader) Prepare ¶

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

func (*Workloader) PreparePlanReplayerDump ¶ added in v1.0.9

func (w *Workloader) PreparePlanReplayerDump() error

func (*Workloader) Run ¶

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

Source Files ¶

View all Source files

workload.go

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