work

type CompositeWork ¶

type CompositeWork interface {
	// DoNext executes the next sub part of the work. It returns false when all sub parts are done
	DoNext() (hasMore bool, err error)
}

CompositeWork represents a unit work that has multiple sub parts

func NewDeleteRowWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewDeleteTxnWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewInsertRowWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewInsertTxnWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewSelectByPkRowWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewSelectByPkTxnWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewSelectByUkRowWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewSelectByUkTxnWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewUpdateRowWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

func NewUpdateTxnWork(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

type CompositeWorkFactory ¶

type CompositeWorkFactory func(id int, rp *RunParams, recRange *intgen.Range) CompositeWork

type DeleteRowWork ¶

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

DeleteRowWork is a CompositeWork that deletes one row each time DoNext is called

Since the same record cannot be deleted twice, the DeleteRowWork takes a slice of row indexes which has the indexes of the rows (as per the DataGen) that this instance should delete. The creator of DeleteRowWork must ensure that it is giving mutually exclusive sets of row indexes to the different DeleteRowWork instances.

This class is Thread Safe. DoNext can be invoked from multiple threads

func (w *DeleteRowWork) DoNext() (bool, error)

type DeleteTxnWork ¶

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

DeleteTxnWork is a CompositeWork that deletes one botch of rows using a transaction each time DoNext is called

Since the same record cannot be deleteed twice, the DeleteRowWork takes a slice of row indexes which has the indexes of the rows (as per the DataGen) that this instance should delete. The creator of DeleteRowWork must ensure that it is giving mutually exclusive sets of row indexes to the different DeleteRowWork instances.

This class is Thread Safe. DoNext can be invoked from multiple threads

func (w *DeleteTxnWork) DoNext() (bool, error)

type InsertRowWork ¶

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

InsertRowWork is a CompositeWork that inserts one row each time DoNext is called

Since the same record cannot be inserted twice, the InsertRowWork takes a slice of row indexes which has the indexes of the rows (as per the DataGen) that this instance should insert. The creator of InsertRowWork must ensure that it is giving mutually exclusive sets of row indexes to the different InsertRowWork instances.

This class is Thread Safe. DoNext can be invoked from multiple threads

func (w *InsertRowWork) DoNext() (bool, error)

type InsertTxnWork ¶

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

InsertTxnWork is a CompositeWork that inserts one botch of rows using a transaction each time DoNext is called

Since the same record cannot be inserted twice, the InsertRowWork takes a slice of row indexes which has the indexes of the rows (as per the DataGen) that this instance should insert. The creator of InsertRowWork must ensure that it is giving mutually exclusive sets of row indexes to the different InsertRowWork instances.

This class is Thread Safe. DoNext can be invoked from multiple threads

func (w *InsertTxnWork) DoNext() (bool, error)

type RunParams ¶

type RunParams struct {
	DB          *sql.DB
	DataGen     *datagen.DataGen
	Metrics     *metrics.DiligentMetrics
	Table       string
	Concurrency int
	EnableTxn   bool
	BatchSize   int
	DurationSec int
}

type SelectByPkRowWork ¶

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

SelectByPkRowWork is a CompositeWork that selects one row by primary key each time DoNext is called This class is Thread Safe. DoNext can be invoked from multiple threads

func (w *SelectByPkRowWork) DoNext() (bool, error)

type SelectByPkTxnWork ¶

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

func (w *SelectByPkTxnWork) DoNext() (bool, error)

type SelectByUkRowWork ¶

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

SelectByUkRowWork is a CompositeWork that selects one row by unique key each time DoNext is called This class is Thread Safe. DoNext can be invoked from multiple threads

func (w *SelectByUkRowWork) DoNext() (bool, error)

type SelectByUkTxnWork ¶

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

func (w *SelectByUkTxnWork) DoNext() (bool, error)

type UpdateRowWork ¶

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

UpdateRowWork is a CompositeWork that updates one row each time DoNext is called This class is Thread Safe. DoNext can be invoked from multiple threads

func (w *UpdateRowWork) DoNext() (bool, error)

type UpdateTxnWork ¶

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

func (w *UpdateTxnWork) DoNext() (bool, error)

type WorkAllocationStrategy ¶

type WorkAllocationStrategy int

const (
	Partitioned WorkAllocationStrategy = iota
	Shared
)

type Worker ¶

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

func NewWorker(id int, rp *RunParams, work CompositeWork) *Worker

func (w *Worker) Run(ctx context.Context, ch chan *WorkerResult)

type WorkerResult ¶ added in v0.2.0

type WorkerResult struct {
	FatalError     bool
	NonFatalErrors int
}

type Workload ¶

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

func NewDeleteRowWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewDeleteTxnWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewInsertRowWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewInsertTxnWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewSelectByPkRowWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewSelectByPkTxnWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewSelectByUkRowWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewSelectByUkTxnWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewUpdateRowWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewUpdateTxnWorkload(assignedRange *intgen.Range, rp *RunParams) *Workload

func NewWorkload(name string, rp *RunParams) *Workload

func (wl *Workload) Abort()

func (wl *Workload) CreateWorkerWithWork(work CompositeWork)

func (wl *Workload) Start(duration time.Duration, ch chan *WorkloadResult)

type WorkloadResult ¶ added in v0.2.0

type WorkloadResult struct {
	IsAborted      bool
	FatalErrors    int
	NonFatalErrors int
}