rawsql

package

v1.0.8 Latest Latest Go to latest Published: Jan 12, 2022 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
}

type Workloader ¶

type Workloader struct {
	// 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) InitThread ¶

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

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) 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