runner

Documentation

Overview

Package runner provides runner implementations for running testcases at load.

Index

• func MasterAbort()
• func NewDelegateRunner(name string, testCase loadtest.Test, registry *runnerRegistry, ...) *delegateRunner
• func NewInitialRunner(name string, testCase loadtest.Test, registry *runnerRegistry, ...) *initialRunner
• func NewRunnerRegistry() *runnerRegistry
• type WorkProvider

Functions

func MasterAbort

func MasterAbort()

MasterAbort will prevent any further runners from executing Runners already in progress will complete normally, but any runners not yet started will do nothing (won't run any operations, but otherwise still behave normally) Use with extreme caution. The only real use is to cancel execution of downstream runners after some kind of failed set-up test

func NewDelegateRunner

func NewDelegateRunner(name string, testCase loadtest.Test, registry *runnerRegistry, maxInProgress int, bhca int) *delegateRunner

NewDelegateRunner creates a new delegate runner

func NewInitialRunner

func NewInitialRunner(name string, testCase loadtest.Test, registry *runnerRegistry, maxInProgress int, bhca int, iterations int) *initialRunner

NewInitialRunner creats a new initial runner

func NewRunnerRegistry

func NewRunnerRegistry() *runnerRegistry

NewRunnerRegistry will return a new runner registry

Types

type WorkProvider

type WorkProvider interface {
	// WorkReamining must return true if there is no more work to do
	WorkRemaining() bool

	// GetWork must provide the next work item, or nil if there is no more work to do
	GetWork() *loadtest.TestContext

	// Remaining should provide the remaining (un-started) test count, if known
	// if not known, nil
	GetRemainingCount() *int

	// AddWork is used to schedule a retry of a test, if needed
	// If the runner cannot do the retry, it should return an error
	// (initial runners for example, are fixed load and cannot do retries)
	AddWork(ctx *loadtest.TestContext) error
}

WorkProvider is used to provide work to a runner