execution

Jan 29, 2024

Changes in this version

+ func SignalAndWait(c Controller, eventID string) error

+ func SignalErrorOrWait(c Controller, eventID string, err error) error

+ type Controller interface

+ GetOrCreateData func(ID string, callback func() ([]byte, error)) ([]byte, error)

+ Signal func(eventID string, err error) error

+ Subscribe func(eventID string) (wait func() error)

Feb 20, 2023

Changes in this version

+ func AbortTestRun(ctx context.Context, err error) bool

+ func GetCancelReasonIfTestAborted(ctx context.Context) error

+ func NewTestRunContext(ctx context.Context, logger logrus.FieldLogger) (newCtx context.Context, abortTest func(reason error))

+ type Scheduler struct

+ func NewScheduler(trs *lib.TestRunState) (*Scheduler, error)

+ func (e *Scheduler) GetExecutionPlan() []lib.ExecutionStep

+ func (e *Scheduler) GetExecutorConfigs() []lib.ExecutorConfig

+ func (e *Scheduler) GetExecutors() []lib.Executor

+ func (e *Scheduler) GetInitProgressBar() *pb.ProgressBar

+ func (e *Scheduler) GetState() *lib.ExecutionState

+ func (e *Scheduler) Init(runCtx context.Context, samplesOut chan<- metrics.SampleContainer) (stopVUEmission func(), err error)

+ func (e *Scheduler) Run(globalCtx, runCtx context.Context, samplesOut chan<- metrics.SampleContainer) (err error)

+ func (e *Scheduler) SetPaused(pause bool) error