Versions in this module Expand all Collapse all v1 v1.0.1 Aug 8, 2022 v1.0.0 Aug 4, 2022 Changes in this version + var EventRunStarted = event.Name("RunStarted") + var EventTestError = event.Name("TestError") + func NewTestStepEventsEmitterFactory(vault storage.EngineVault, jobID types.JobID, runID types.RunID, ...) *testStepEventsEmitterFactory + type AddTargetToStep func(ctx xcontext.Context, tgt *target.Target) (ChanNotifier, error) + type ChanNotifier interface + NotifyCh func() <-chan error + type JobRunner struct + func NewJobRunner(js storage.JobStorage, storageVault storage.EngineVault, clk clock.Clock, ...) *JobRunner + func (jr *JobRunner) BuildRunStatus(ctx xcontext.Context, coordinates job.RunCoordinates, currentJob *job.Job) (*job.RunStatus, error) + func (jr *JobRunner) BuildRunStatuses(ctx xcontext.Context, currentJob *job.Job) ([]job.RunStatus, error) + func (jr *JobRunner) RefreshLocks() + func (jr *JobRunner) Run(ctx xcontext.Context, j *job.Job, resumeState *job.PauseEventPayload) (*job.PauseEventPayload, error) + func (jr *JobRunner) StartLockRefresh() + func (jr *JobRunner) StopLockRefresh() + type RunStartedPayload struct + RunID types.RunID + type StepResult struct + Err error + ResumeState json.RawMessage + type StepRunner struct + func NewStepRunner() *StepRunner + func (sr *StepRunner) Run(ctx xcontext.Context, bundle test.TestStepBundle, ev testevent.Emitter, ...) (AddTargetToStep, []ChanNotifier, ChanNotifier, error) + func (sr *StepRunner) Started() bool + func (sr *StepRunner) Stop() + func (sr *StepRunner) WaitResults(ctx context.Context) (stepResult StepResult, err error) + type TestRunner struct + func NewTestRunner() *TestRunner + func NewTestRunnerWithTimeouts(shutdownTimeout time.Duration) *TestRunner + func (tr *TestRunner) Run(ctx xcontext.Context, t *test.Test, targets []*target.Target, ...) (json.RawMessage, map[string]error, error) + type TestStepEventsEmitterFactory interface + New func(testStepLabel string) testevent.Emitter
Go to main page