runner

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

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

type DistributedOptions struct {
	Coordinator *coordinator.Coordinator
	// Spec is the run to start. Spec.AllowHosts should name the verified
	// target host when it is public; private hosts are always allowed.
	Spec   coordinator.RunSpec
	Logger *slog.Logger
	// Progress receives each merged interval for live display.
	Progress func(Progress)
	// OnEvent receives run events: workers joining, saturating, being
	// lost, finishing.
	OnEvent func(coordinator.RunEvent)
	// AbortFloor stops runs that fail badly even when the scenario sets no
	// abort limits.
	AbortFloor *scenario.Abort
	// OnStart receives the run once every worker accepted it, so the
	// caller can Stop or Kill it.
	OnStart func(*coordinator.Run)
}

type FaultPlan struct {
	Client *agent.Client
	Steps  []scenario.FaultStep
}

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

type Options struct {
	Scenario  *scenario.Scenario
	RunID     string
	Env       map[string]string
	Secrets   map[string]string
	AllowHost func(*url.URL) bool
	Logger    *slog.Logger
	// Progress receives each interval's merged snapshot for live display.
	Progress func(p Progress)
	// Faults, when set, injects the scenario's fault timeline through a
	// stampede agent during the run. It is checked before any load.
	Faults *FaultPlan
}

type Progress struct {
	Elapsed  time.Duration
	Total    time.Duration
	Snapshot *metrics.Snapshot
	Planned  float64
	Mode     string
}

type Round func(ctx context.Context, level float64) (pass bool, failedOn []string, err error)

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