coordinator

type AgentInfo struct {
	ID             string            `json:"id"`
	Hostname       string            `json:"hostname"`
	Version        string            `json:"version"`
	Cores          uint32            `json:"cores"`
	MaxWorkers     uint32            `json:"maxWorkers"`
	MaxVUs         uint32            `json:"maxVUs"`
	Labels         map[string]string `json:"labels,omitempty"`
	RemoteAddr     string            `json:"remoteAddr"`
	JoinedAt       time.Time         `json:"joinedAt"`
	LastSeen       time.Time         `json:"lastSeen"`
	ActiveVUs      uint32            `json:"activeVUs"`
	HealthyWorkers uint32            `json:"healthyWorkers"`
	Healthy        bool              `json:"healthy"`
	VUQuota        int               `json:"vuQuota"`

	// CPUPercent and MemBytes describe the agent process itself — its
	// supervisory footprint, not the workers it spawns. Zero until its
	// first heartbeat arrives.
	CPUPercent float64 `json:"cpuPercent"`
	MemBytes   uint64  `json:"memBytes"`

	// Workers is the per-process breakdown within this agent. Never nil:
	// this is JSON-encoded straight to the dashboard, which maps over it
	// unconditionally.
	Workers []WorkerInfo `json:"workers"`
}

type Config struct {
	// ListenAddr is where agents connect. ":0" picks a free port, which is
	// what the single-process `loadwave run` path uses.
	ListenAddr string

	Logger *slog.Logger

	// HeartbeatInterval is how often agents should report liveness.
	HeartbeatInterval time.Duration

	// MetricsInterval is the reporting period, and therefore the width of a
	// chart bucket.
	MetricsInterval time.Duration

	// AgentTimeout is how long an agent may go unheard from before it is
	// treated as gone. Generous relative to the heartbeat, so that one
	// dropped packet does not evict a healthy agent mid-run.
	AgentTimeout time.Duration

	// StartDelay is the lead time built into a run's agreed start instant, so
	// that every agent has received its orders before the clock starts.
	StartDelay time.Duration

	// Store configures each run's metric store.
	Store metrics.StoreConfig

	// MaxRunHistory is how many finished runs are retained in memory.
	MaxRunHistory int
}

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

type EndpointTick struct {
	Avg       float64 `json:"avg"`
	Requests  uint64  `json:"requests"`
	ErrorRate float64 `json:"errorRate"`
}

type Event struct {
	Time    time.Time         `json:"time"`
	Level   string            `json:"level"`
	Source  string            `json:"source"`
	Message string            `json:"message"`
	Fields  map[string]string `json:"fields,omitempty"`
}

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

type ScenarioTick struct {
	VUs        float64 `json:"vus"`
	Iterations uint64  `json:"iterations"`
	Requests   uint64  `json:"requests"`
	ErrorRate  float64 `json:"errorRate"`
	P95        float64 `json:"p95"`
}

type Snapshot struct {
	Build      buildinfo.Info          `json:"build"`
	Run        *Summary                `json:"run,omitempty"`
	Runs       []Summary               `json:"runs"`
	Agents     []AgentInfo             `json:"agents"`
	Ticks      []TickDTO               `json:"ticks"`
	Series     []metrics.SeriesSummary `json:"series"`
	Events     []Event                 `json:"events"`
	Resolution float64                 `json:"resolutionSeconds"`

	// Totals holds one correctly merged aggregate per metric. Clients must
	// use these for whole-run figures rather than folding Series, which
	// cannot be done correctly outside the store.
	Totals map[string]metrics.SeriesSummary `json:"totals,omitempty"`

	// Endpoints is the per-request-name breakdown, with percentiles
	// recomputed from each endpoint's merged distribution.
	Endpoints []metrics.EndpointSummary `json:"endpoints,omitempty"`

	// Failures explains what went wrong, which the metrics only count.
	Failures []metrics.FailureSummary `json:"failures,omitempty"`
}

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

type Summary struct {
	ID         string            `json:"id"`
	Name       string            `json:"name"`
	Phase      string            `json:"phase"`
	CreatedAt  time.Time         `json:"createdAt"`
	StartAt    time.Time         `json:"startAt,omitempty"`
	StartedAt  time.Time         `json:"startedAt,omitempty"`
	EndedAt    time.Time         `json:"endedAt,omitempty"`
	ElapsedSec float64           `json:"elapsedSeconds"`
	PeakVUs    int               `json:"peakVUs"`
	Profile    string            `json:"profile"`
	BaseURL    string            `json:"baseURL"`
	StopReason string            `json:"stopReason,omitempty"`
	Failure    string            `json:"failure,omitempty"`
	Breached   bool              `json:"thresholdsBreached"`
	Tags       map[string]string `json:"tags,omitempty"`

	Participants []participant     `json:"participants"`
	Thresholds   []ThresholdResult `json:"thresholds"`
	Stats        metrics.Stats     `json:"stats"`
}

type ThresholdResult struct {
	Metric string  `json:"metric"`
	Stat   string  `json:"stat"`
	Op     string  `json:"op"`
	Value  float64 `json:"value"`

	// Actual is the observed statistic. Meaningful only when Evaluated.
	Actual float64 `json:"actual"`

	// Evaluated is false when the metric has not been observed yet. A
	// threshold on a metric that never appeared is reported as unevaluated
	// rather than as a pass, because "we never measured it" and "it was fine"
	// are very different things to hand back to a CI pipeline.
	Evaluated bool `json:"evaluated"`

	Passed bool `json:"passed"`

	// AbortOnFail means a breach should end the run immediately.
	AbortOnFail bool `json:"abortOnFail"`

	// Description renders the assertion for display, e.g.
	// "http_req_duration p95 < 500".
	Description string `json:"description"`
}

type TickDTO struct {
	T          int64   `json:"t"`
	VUs        uint32  `json:"vus"`
	Requests   uint64  `json:"requests"`
	Failures   uint64  `json:"failures"`
	Iterations uint64  `json:"iterations"`
	RPS        float64 `json:"rps"`
	ErrorRate  float64 `json:"errorRate"`
	Avg        float64 `json:"avg"`
	P50        float64 `json:"p50"`
	P90        float64 `json:"p90"`
	P95        float64 `json:"p95"`
	P99        float64 `json:"p99"`

	Status    map[string]uint64       `json:"status,omitempty"`
	Scenarios map[string]ScenarioTick `json:"scenarios,omitempty"`

	// Endpoints is the per-request-name breakdown, which is what the response
	// time chart plots one line from.
	Endpoints map[string]EndpointTick `json:"endpoints,omitempty"`
}

type Update struct {
	Type       string            `json:"type"`
	Run        *Summary          `json:"run,omitempty"`
	Agents     []AgentInfo       `json:"agents,omitempty"`
	Ticks      []TickDTO         `json:"ticks,omitempty"`
	Thresholds []ThresholdResult `json:"thresholds,omitempty"`
	Events     []Event           `json:"events,omitempty"`
}

type WorkerInfo struct {
	ID         string  `json:"id"`
	Index      uint32  `json:"index"`
	ActiveVUs  uint32  `json:"activeVUs"`
	CPUPercent float64 `json:"cpuPercent"`
	MemBytes   uint64  `json:"memBytes"`
}