reporter

type FlowStartInfo struct {
	FlowID     string
	FlowName   string
	TotalNodes int
	NodeNames  []string
}

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

type FrameSinkOptions struct {
	// URL receives every frame and the final report, as JSON POSTs.
	URL string
	// Token is the bearer token; NewReporterGroup reads EnvFramesToken.
	Token string
	// WorkerID identifies this machine; NewReporterGroup reads EnvWorkerID,
	// falling back to the hostname.
	WorkerID string
	// Client is the HTTP client used for every request.
	Client *http.Client
	// QueueSize bounds the frames waiting to be sent. A frame that finds the
	// queue full is dropped (and counted), never waited for.
	QueueSize int
	// RetryBase is the first retry's backoff; each retry doubles it, up to
	// 5s.
	RetryBase time.Duration
	// FinalTimeout bounds Flush: draining queued frames plus posting the
	// final report.
	FinalTimeout time.Duration
	// DeadManAfter is how long the endpoint may go without accepting a
	// request, once the sink has started, before OnDeadMan fires.
	DeadManAfter time.Duration
	// OnDeadMan is called at most once, when the endpoint has been
	// unreachable for DeadManAfter. A load run uses it to stop itself, so a
	// generator whose controller has gone away cannot keep hitting a target.
	OnDeadMan func(reason string)
}

type LoadReport struct {
	Meta   LoadRunMeta
	Report loadmetrics.Report
	ByStep loadmetrics.Report
}

type LoadRunMeta struct {
	// ScenarioName is the `load:` block entry the profile came from, empty
	// for a run configured entirely from flags.
	ScenarioName string
	FlowName     string
	VUs          int
	// Duration and MaxIterations are the configured stop conditions.
	Duration      time.Duration
	MaxIterations int64
	// Iterations, Errors and Elapsed are what actually happened.
	Iterations int64
	Errors     int64
	Elapsed    time.Duration
	// Requests is how many HTTP requests the report counts. Only request
	// steps are counted - never the manual_start node or other non-request
	// nodes (see LoadMetricsScope).
	Requests int64
	// Interrupted counts iterations cut short by a graceful ramp-down or
	// stop; Dropped counts arrival-rate iterations that found no free VU.
	Interrupted int64
	Dropped     int64
	// WorkerVersion identifies the binary that produced the numbers, so
	// baselines from different builds are not silently compared.
	WorkerVersion string

	// Executor is the scheduling strategy; "" means constant-vus.
	Executor string
	// Profile describes a non-constant-vus schedule in one line, e.g.
	// "0->20 VUs over 3 stages (2m0s)". Unused for constant-vus, whose VUs
	// and stop conditions have their own fields.
	Profile string
	// Thresholds are the run's threshold verdicts, in configuration order.
	Thresholds []LoadThresholdResult
	// AbortReason says why the run stopped early, or is "".
	AbortReason string
}

type LoadThresholdResult struct {
	// Expression is the threshold in its canonical form, e.g. p95<300ms.
	Expression string
	Passed     bool
	// Observed is the measured value as text, or "no data".
	Observed string
}

type NodeStatusEvent struct {
	FlowID   string
	FlowName string
	Status   runner.FlowNodeStatus
	// Cleanup marks a step from the flow's cleanup: block.
	Cleanup bool
	// SkipReason is set when the step did not run; Status.State is then not
	// meaningful.
	SkipReason string
}

type ReportSpec struct {
	Format string
	Path   string
}

type Reporter interface {
	HandleFlowStart(info FlowStartInfo)
	HandleNodeStatus(event NodeStatusEvent)
	HandleFlowResult(result model.FlowRunResult)
	Flush() error
}

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

type ReporterOptions struct {
	ShowOutput bool // Show node output data in console reporter
}