control

type Controller struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type ErrorEvent struct {
	Err error
	// contains filtered or unexported fields
}

type Event interface {
	Time() time.Time // Time when the event happened.
}

type Job struct {
	// ID is the unique identifier of the job.
	ID string

	// Name is the fully qualified name of the test or control function.
	Name string

	// Args is the list of arguments to pass to the test.
	Args []string

	// Timeout is the duration after which the job will be stopped.
	Timeout time.Duration

	// Module Parameters
	ModulePars map[string]string

	// Dir specifies the working directory for the job.
	Dir string

	// Env specifies the environment variables to pass to the job.
	Env []string

	// Config provides the project configuration
	*project.Config
}

type JobError struct {
	*Job
	Err error
}

type LogEvent struct {
	Text string

	*Job
	// contains filtered or unexported fields
}

type Option func(*Controller) error

type Runner interface {
	Run(context.Context) <-chan Event
}

type RunnerFactory func() (Runner, error)

type StartEvent struct {
	Name string

	*Job
	// contains filtered or unexported fields
}

type StopEvent struct {
	Name    string
	Verdict string
	Begin   time.Time

	*Job
	// contains filtered or unexported fields
}

type TestPlan struct {

	// Controls is a ordered list of fully qualified control functions.
	Controls []string

	// Tests is a ordered list of fully qualified test case names.
	Tests []string
	// contains filtered or unexported fields
}

type TickerEvent struct {
	*Job
	// contains filtered or unexported fields
}