engine

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

type Options struct {
	Program *scenario.Program
	Plan    *scenario.Plan
	RunID   string

	// Env and Secrets back ${env.X} and ${secret.X}.
	Env     map[string]string
	Secrets map[string]string

	// ShareLo and ShareHi select this engine's slice of the total load as
	// cumulative fractions. A single engine uses 0 and 1. Workers with
	// slices [0, .5) and [.5, 1) together produce exactly the plan.
	ShareLo, ShareHi float64
	// WorkerIndex and WorkerCount partition unique test data.
	WorkerIndex, WorkerCount int

	// T0 is the synchronised start time. Zero starts immediately.
	T0 time.Time
	// Resume starts part-way through the plan, at T0 + Resume: the worker
	// takes over a lost worker's share. Arrivals before then are skipped.
	Resume time.Duration
	// Attempt counts takeovers of this share; generated data mixes it in
	// so values stay unique.
	Attempt int
	// Interval between snapshots (default 1s).
	Interval time.Duration
	// OnSnapshot receives each interval's metrics. It must not block for long.
	OnSnapshot func(*metrics.Snapshot)
	// AllowHost vets every request URL. Nil allows all hosts.
	AllowHost func(*url.URL) bool
	// MaxBodyBytes caps response bytes kept for checks and extraction
	// (default 10 MiB).
	MaxBodyBytes int64
	// Transport overrides the HTTP dialer (tests, network emulation).
	HTTP httpx.Options
	// PluginDir is where plugin executables are looked for before PATH
	// (default: pluginhost.Dir()).
	PluginDir string
	Logger    *slog.Logger
}

type Result struct {
	T0         time.Time
	End        time.Time
	StopReason string
	Phases     map[int]*[metrics.NumPhases]*metrics.Histogram
	PeakVUs    int
}

type VU struct {
	ID int
	// contains filtered or unexported fields
}