sysbench

package
v0.0.0-...-32dc681 Latest Latest
Warning

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

Go to latest
Published: Jun 7, 2021 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDelete

func NewDelete(conf *xcommon.Conf, workers []xworker.Worker) xworker.Handler

NewDelete creates the new handler.

func NewInsert

func NewInsert(conf *xcommon.Conf, workers []xworker.Worker) xworker.Handler

NewInsert creates the new insert handler.

func NewQuery

func NewQuery(conf *xcommon.Conf, workers []xworker.Worker) xworker.Handler

NewQuery creates the new query handler.

func NewUpdate

func NewUpdate(conf *xcommon.Conf, workers []xworker.Worker) xworker.Handler

NewUpdate creates the new update handler.

Types

type Delete

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

Delete tuple.

func (*Delete) Delete

func (delete *Delete) Delete(worker *xworker.Worker, num int, id int)

Delete used to execute delete query.

func (*Delete) Rows

func (delete *Delete) Rows() uint64

Rows returns the row numbers.

func (*Delete) Run

func (delete *Delete) Run()

Run used to start the worker.

func (*Delete) Stop

func (delete *Delete) Stop()

Stop used to stop the worker.

type Insert

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

Insert tuple.

func (*Insert) Insert

func (insert *Insert) Insert(worker *xworker.Worker, num int, id int)

Insert used to execute the insert query.

func (*Insert) Rows

func (insert *Insert) Rows() uint64

Rows returns the row numbers.

func (*Insert) Run

func (insert *Insert) Run()

Run used to start the worker.

func (*Insert) Stop

func (insert *Insert) Stop()

Stop used to stop the worker.

type Query

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

Query tuple.

func (*Query) Query

func (q *Query) Query(worker *xworker.Worker, num int, id int)

Query used to execute the query.

func (*Query) Rows

func (q *Query) Rows() uint64

Rows returns the row numbers.

func (*Query) Run

func (q *Query) Run()

Run used to start the worker.

func (*Query) Stop

func (q *Query) Stop()

Stop used to stop the worker.

type Range

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

Range tuple.

func NewRange

func NewRange(conf *xcommon.Conf, workers []xworker.Worker, order string) *Range

NewRange creates the new range handler.

func (*Range) Query

func (r *Range) Query(worker *xworker.Worker, num int, id int)

Query used to execute the range query.

func (*Range) Rows

func (r *Range) Rows() uint64

Rows returns the row numbers.

func (*Range) Run

func (r *Range) Run()

Run used to start the worker.

func (*Range) Stop

func (r *Range) Stop()

Stop used to stop the worker.

type Table

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

Table tuple.

func NewTable

func NewTable(workers []xworker.Worker) *Table

NewTable creates the new table.

func (*Table) Cleanup

func (t *Table) Cleanup()

Cleanup used to cleanup the tables.

func (*Table) Prepare

func (t *Table) Prepare()

Prepare used to prepare the tables.

type Update

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

Update tuple.

func (*Update) Rows

func (update *Update) Rows() uint64

Rows returns the row numbers.

func (*Update) Run

func (update *Update) Run()

Run used to start the worker.

func (*Update) Stop

func (update *Update) Stop()

Stop used to stop the worker.

func (*Update) Update

func (update *Update) Update(worker *xworker.Worker, num int, id int)

Update used to execute the update query.

Jump to

Keyboard shortcuts

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