loadwavev1

type Accepted struct {
	AssignedNodeId    string               `protobuf:"bytes,1,opt,name=assigned_node_id,json=assignedNodeId,proto3" json:"assigned_node_id,omitempty"`
	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,2,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	MetricsInterval   *durationpb.Duration `protobuf:"bytes,3,opt,name=metrics_interval,json=metricsInterval,proto3" json:"metrics_interval,omitempty"`
	SupervisorVersion string               `protobuf:"bytes,4,opt,name=supervisor_version,json=supervisorVersion,proto3" json:"supervisor_version,omitempty"`
	// contains filtered or unexported fields
}

type ControlServiceClient interface {
	// The envelope names describe direction rather than the RPC, because the
	// same pair is reused for the agent tier and the worker tier. JoinRequest /
	// JoinResponse would obscure that symmetry.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	Join(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[NodeUp, NodeDown], error)
}

type ControlServiceServer interface {
	// The envelope names describe direction rather than the RPC, because the
	// same pair is reused for the agent tier and the worker tier. JoinRequest /
	// JoinResponse would obscure that symmetry.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	Join(grpc.BidiStreamingServer[NodeUp, NodeDown]) error
	// contains filtered or unexported methods
}

type ControlService_JoinClient = grpc.BidiStreamingClient[NodeUp, NodeDown]

type ControlService_JoinServer = grpc.BidiStreamingServer[NodeUp, NodeDown]

type ExecutorType int32

type FailureSample struct {

	// The request's metric name, already collapsed to bounded cardinality.
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// HTTP status, or 0 when no response arrived.
	Status int32 `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	// Transport failure classification: "timeout", "connection_refused" and
	// the like. Empty when a response was received.
	ErrorClass string `protobuf:"bytes,4,opt,name=error_class,json=errorClass,proto3" json:"error_class,omitempty"`
	// A short, truncated excerpt of the response body or the transport error.
	// Never the whole body: this is a hint for a human, not a payload.
	Message  string                 `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	Count    uint64                 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	LastSeen *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	// contains filtered or unexported fields
}

type HistogramSnapshot struct {
	LowestTrackableValue  int64 `protobuf:"varint,1,opt,name=lowest_trackable_value,json=lowestTrackableValue,proto3" json:"lowest_trackable_value,omitempty"`
	HighestTrackableValue int64 `` /* 127-byte string literal not displayed */
	SignificantFigures    int32 `protobuf:"varint,3,opt,name=significant_figures,json=significantFigures,proto3" json:"significant_figures,omitempty"`
	// Bucket counts, run-length encoded: a zero is followed by the length of
	// the zero run. Non-zero values stand alone. HDR count arrays are mostly
	// empty, so this typically shrinks the payload by one to two orders of
	// magnitude.
	CountsRle  []int64 `protobuf:"varint,4,rep,packed,name=counts_rle,json=countsRle,proto3" json:"counts_rle,omitempty"`
	TotalCount int64   `protobuf:"varint,5,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

type LoadProfile struct {
	Executor ExecutorType `protobuf:"varint,1,opt,name=executor,proto3,enum=loadwave.v1.ExecutorType" json:"executor,omitempty"`
	// constant-vus: the VU count to hold, and for how long.
	Vus      uint32               `protobuf:"varint,2,opt,name=vus,proto3" json:"vus,omitempty"`
	Duration *durationpb.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"`
	// ramping-vus: the stages to walk through.
	Stages []*Stage `protobuf:"bytes,4,rep,name=stages,proto3" json:"stages,omitempty"`
	// Global ceiling on scenario iterations started per second across the whole
	// run, which is the arrival rate a closed-model run would otherwise leave
	// implicit. Zero means unlimited, and the VU count alone governs. The
	// coordinator divides this budget across agents.
	//
	// This throttles iterations rather than individual requests: a scenario
	// issuing five requests per iteration at a limit of 100 produces roughly
	// 500 requests per second.
	MaxIterationsPerSecond uint32 `` /* 132-byte string literal not displayed */
	// How long VUs are given to finish their in-flight iteration once the run
	// is asked to stop before they are cancelled outright.
	GracefulStop *durationpb.Duration `protobuf:"bytes,6,opt,name=graceful_stop,json=gracefulStop,proto3" json:"graceful_stop,omitempty"`
	// Stop the run after this many completed iterations across all VUs.
	// Zero means the profile's duration governs instead.
	Iterations uint64 `protobuf:"varint,7,opt,name=iterations,proto3" json:"iterations,omitempty"`
	// contains filtered or unexported fields
}

type LogEvent struct {
	Time    *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Level   LogLevel               `protobuf:"varint,2,opt,name=level,proto3,enum=loadwave.v1.LogLevel" json:"level,omitempty"`
	NodeId  string                 `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	RunId   string                 `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Message string                 `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	Fields  map[string]string      `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type LogLevel int32

type MetricBatch struct {
	RunId       string                 `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	NodeId      string                 `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	BucketStart *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=bucket_start,json=bucketStart,proto3" json:"bucket_start,omitempty"`
	BucketWidth *durationpb.Duration   `protobuf:"bytes,4,opt,name=bucket_width,json=bucketWidth,proto3" json:"bucket_width,omitempty"`
	Series      []*SeriesDelta         `protobuf:"bytes,5,rep,name=series,proto3" json:"series,omitempty"`
	// Instantaneous VU count on this node at the close of the bucket.
	ActiveVus uint32 `protobuf:"varint,6,opt,name=active_vus,json=activeVus,proto3" json:"active_vus,omitempty"`
	// Samples the node had to discard because its buffer was full. Non-zero
	// here means the reported numbers understate reality and the UI says so.
	DroppedSamples uint64 `protobuf:"varint,7,opt,name=dropped_samples,json=droppedSamples,proto3" json:"dropped_samples,omitempty"`
	// What went wrong during this bucket, and why.
	Failures []*FailureSample `protobuf:"bytes,8,rep,name=failures,proto3" json:"failures,omitempty"`
	// contains filtered or unexported fields
}

type MetricKind int32

type NodeDown struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*NodeDown_Accepted
	//	*NodeDown_StartRun
	//	*NodeDown_SetQuota
	//	*NodeDown_StopRun
	//	*NodeDown_Ping
	Payload isNodeDown_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type NodeDown_Accepted struct {
	Accepted *Accepted `protobuf:"bytes,1,opt,name=accepted,proto3,oneof"`
}

type NodeDown_Ping struct {
	Ping *Ping `protobuf:"bytes,5,opt,name=ping,proto3,oneof"`
}

type NodeDown_SetQuota struct {
	SetQuota *SetQuota `protobuf:"bytes,3,opt,name=set_quota,json=setQuota,proto3,oneof"`
}

type NodeDown_StartRun struct {
	StartRun *StartRun `protobuf:"bytes,2,opt,name=start_run,json=startRun,proto3,oneof"`
}

type NodeDown_StopRun struct {
	StopRun *StopRun `protobuf:"bytes,4,opt,name=stop_run,json=stopRun,proto3,oneof"`
}

type NodeHeartbeat struct {
	Sequence       int64  `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	ActiveVus      uint32 `protobuf:"varint,2,opt,name=active_vus,json=activeVus,proto3" json:"active_vus,omitempty"`
	HealthyWorkers uint32 `protobuf:"varint,3,opt,name=healthy_workers,json=healthyWorkers,proto3" json:"healthy_workers,omitempty"`
	// This node's own process: an agent's supervisory footprint, or a
	// worker's own usage generating load.
	CpuPercent float64                `protobuf:"fixed64,4,opt,name=cpu_percent,json=cpuPercent,proto3" json:"cpu_percent,omitempty"`
	MemBytes   uint64                 `protobuf:"varint,5,opt,name=mem_bytes,json=memBytes,proto3" json:"mem_bytes,omitempty"`
	SentAt     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// Per-worker breakdown, populated only by an agent reporting on the
	// worker processes it supervises. Empty on a worker's own heartbeat,
	// which has no children of its own to report.
	Workers []*WorkerStats `protobuf:"bytes,7,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

type NodeHello struct {
	NodeId   string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Version  string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	CpuCores uint32 `protobuf:"varint,4,opt,name=cpu_cores,json=cpuCores,proto3" json:"cpu_cores,omitempty"`
	// Worker processes this node is willing to run.
	MaxWorkers uint32 `protobuf:"varint,5,opt,name=max_workers,json=maxWorkers,proto3" json:"max_workers,omitempty"`
	// Virtual users this node is willing to carry, across all its workers.
	MaxVus uint32            `protobuf:"varint,6,opt,name=max_vus,json=maxVus,proto3" json:"max_vus,omitempty"`
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type NodeUp struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*NodeUp_Hello
	//	*NodeUp_Heartbeat
	//	*NodeUp_Metrics
	//	*NodeUp_RunStatus
	//	*NodeUp_Log
	//	*NodeUp_Pong
	Payload isNodeUp_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type NodeUp_Heartbeat struct {
	Heartbeat *NodeHeartbeat `protobuf:"bytes,2,opt,name=heartbeat,proto3,oneof"`
}

type NodeUp_Hello struct {
	Hello *NodeHello `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}

type NodeUp_Log struct {
	Log *LogEvent `protobuf:"bytes,5,opt,name=log,proto3,oneof"`
}

type NodeUp_Metrics struct {
	Metrics *MetricBatch `protobuf:"bytes,3,opt,name=metrics,proto3,oneof"`
}

type NodeUp_Pong struct {
	Pong *Pong `protobuf:"bytes,6,opt,name=pong,proto3,oneof"`
}

type NodeUp_RunStatus struct {
	RunStatus *RunStatusUpdate `protobuf:"bytes,4,opt,name=run_status,json=runStatus,proto3,oneof"`
}

type Ping struct {
	Nonce  int64                  `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	SentAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

type Pong struct {
	Nonce  int64                  `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	SentAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

type RunPhase int32

type RunStatusUpdate struct {
	RunId               string   `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Phase               RunPhase `protobuf:"varint,2,opt,name=phase,proto3,enum=loadwave.v1.RunPhase" json:"phase,omitempty"`
	Message             string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	ActiveVus           uint32   `protobuf:"varint,4,opt,name=active_vus,json=activeVus,proto3" json:"active_vus,omitempty"`
	CompletedIterations uint64   `protobuf:"varint,5,opt,name=completed_iterations,json=completedIterations,proto3" json:"completed_iterations,omitempty"`
	// contains filtered or unexported fields
}

type ScenarioRef struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// contains filtered or unexported fields
}

type SeriesDelta struct {
	Metric string            `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Kind   MetricKind        `protobuf:"varint,2,opt,name=kind,proto3,enum=loadwave.v1.MetricKind" json:"kind,omitempty"`
	Tags   map[string]string `` /* 135-byte string literal not displayed */
	Count  uint64            `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	Sum    float64           `protobuf:"fixed64,5,opt,name=sum,proto3" json:"sum,omitempty"`
	Min    float64           `protobuf:"fixed64,6,opt,name=min,proto3" json:"min,omitempty"`
	Max    float64           `protobuf:"fixed64,7,opt,name=max,proto3" json:"max,omitempty"`
	// Populated for TREND metrics only.
	Histogram *HistogramSnapshot `protobuf:"bytes,8,opt,name=histogram,proto3" json:"histogram,omitempty"`
	// Populated for RATE metrics: how many of `count` observations were truthy.
	NonZero uint64 `protobuf:"varint,9,opt,name=non_zero,json=nonZero,proto3" json:"non_zero,omitempty"`
	// contains filtered or unexported fields
}

type SetQuota struct {
	RunId              string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	VuQuota            uint32 `protobuf:"varint,2,opt,name=vu_quota,json=vuQuota,proto3" json:"vu_quota,omitempty"`
	IterationRateQuota uint32 `protobuf:"varint,3,opt,name=iteration_rate_quota,json=iterationRateQuota,proto3" json:"iteration_rate_quota,omitempty"`
	// How long the node should take to reach the new virtual user quota.
	//
	// Zero means immediately, which is what a rebalance after an agent is lost
	// wants: the surviving nodes should pick up the missing load now, not in a
	// minute. An operator changing the target usually wants the opposite —
	// spawning several hundred users in one tick is a step change that tells
	// you how the service handles a thundering herd, not how it handles the
	// load level you asked for.
	Ramp *durationpb.Duration `protobuf:"bytes,4,opt,name=ramp,proto3" json:"ramp,omitempty"`
	// contains filtered or unexported fields
}

type Stage struct {
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	Target   uint32               `protobuf:"varint,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

type StartRun struct {
	RunId string    `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Plan  *TestPlan `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	// VUs this node is responsible for at peak. The node scales within this
	// ceiling as the profile ramps.
	VuQuota uint32 `protobuf:"varint,3,opt,name=vu_quota,json=vuQuota,proto3" json:"vu_quota,omitempty"`
	// Worker processes to spawn. Meaningful for agents; ignored by workers.
	WorkerCount uint32 `protobuf:"varint,4,opt,name=worker_count,json=workerCount,proto3" json:"worker_count,omitempty"`
	// Iterations per second this node may start, zero for unlimited.
	IterationRateQuota uint32 `protobuf:"varint,5,opt,name=iteration_rate_quota,json=iterationRateQuota,proto3" json:"iteration_rate_quota,omitempty"`
	// Total iterations this node should complete before stopping, zero for
	// unbounded. Set only when the plan caps total iterations.
	IterationQuota uint64 `protobuf:"varint,9,opt,name=iteration_quota,json=iterationQuota,proto3" json:"iteration_quota,omitempty"`
	// Wall-clock instant at which every node should consider the run started,
	// so ramp curves line up across hosts despite staggered delivery.
	StartAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"`
	// This node's index and the total node count, used to deterministically
	// partition shared test data without any cross-node coordination.
	ShardIndex uint32 `protobuf:"varint,7,opt,name=shard_index,json=shardIndex,proto3" json:"shard_index,omitempty"`
	ShardCount uint32 `protobuf:"varint,8,opt,name=shard_count,json=shardCount,proto3" json:"shard_count,omitempty"`
	// First virtual user id this node may allocate. The supervisor hands out
	// non-overlapping ranges so that every VU in a distributed run has a
	// globally unique id without any node having to ask for one.
	VuIdBase int64 `protobuf:"varint,10,opt,name=vu_id_base,json=vuIdBase,proto3" json:"vu_id_base,omitempty"`
	// contains filtered or unexported fields
}

type StopRun struct {
	RunId    string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Graceful bool   `protobuf:"varint,2,opt,name=graceful,proto3" json:"graceful,omitempty"`
	Reason   string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type TestPlan struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	BaseUrl    string            `protobuf:"bytes,2,opt,name=base_url,json=baseUrl,proto3" json:"base_url,omitempty"`
	Load       *LoadProfile      `protobuf:"bytes,3,opt,name=load,proto3" json:"load,omitempty"`
	Scenarios  []*ScenarioRef    `protobuf:"bytes,4,rep,name=scenarios,proto3" json:"scenarios,omitempty"`
	Thresholds []*Threshold      `protobuf:"bytes,5,rep,name=thresholds,proto3" json:"thresholds,omitempty"`
	Tags       map[string]string `` /* 135-byte string literal not displayed */
	// Worker processes each agent should spawn for this run. Zero lets the
	// agent choose based on its core count.
	WorkersPerAgent uint32 `protobuf:"varint,7,opt,name=workers_per_agent,json=workersPerAgent,proto3" json:"workers_per_agent,omitempty"`
	// Verbatim YAML of the configuration this plan was built from.
	//
	// Workers need more than the structured fields above: the HTTP client
	// settings, and the step definitions of any declaratively-authored
	// scenario. Rather than mirror the whole configuration schema into
	// protobuf — and have to keep the two in step forever — the original
	// source travels with the plan and each worker parses it locally.
	ConfigYaml []byte `protobuf:"bytes,8,opt,name=config_yaml,json=configYaml,proto3" json:"config_yaml,omitempty"`
	// contains filtered or unexported fields
}

type Threshold struct {
	Metric string        `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Stat   ThresholdStat `protobuf:"varint,2,opt,name=stat,proto3,enum=loadwave.v1.ThresholdStat" json:"stat,omitempty"`
	Op     ThresholdOp   `protobuf:"varint,3,opt,name=op,proto3,enum=loadwave.v1.ThresholdOp" json:"op,omitempty"`
	Value  float64       `protobuf:"fixed64,4,opt,name=value,proto3" json:"value,omitempty"`
	// Abort the run immediately on breach rather than only failing at the end.
	AbortOnFail bool `protobuf:"varint,5,opt,name=abort_on_fail,json=abortOnFail,proto3" json:"abort_on_fail,omitempty"`
	// contains filtered or unexported fields
}

type ThresholdOp int32

type ThresholdStat int32

type UnimplementedControlServiceServer struct{}

type UnsafeControlServiceServer interface {
	// contains filtered or unexported methods
}

type WorkerStats struct {
	WorkerId   string  `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Index      uint32  `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	ActiveVus  uint32  `protobuf:"varint,3,opt,name=active_vus,json=activeVus,proto3" json:"active_vus,omitempty"`
	CpuPercent float64 `protobuf:"fixed64,4,opt,name=cpu_percent,json=cpuPercent,proto3" json:"cpu_percent,omitempty"`
	MemBytes   uint64  `protobuf:"varint,5,opt,name=mem_bytes,json=memBytes,proto3" json:"mem_bytes,omitempty"`
	// contains filtered or unexported fields
}