comparison

type Config struct {
	// Cluster is the host's own identity. Every upstream request uses it.
	Cluster *rest.Config
	// NamespacePrefix names the scratch namespace, created by New and deleted by Close.
	NamespacePrefix string
	// Widgets and Secrets size the fixed object set. Defaults 8 and 3.
	Widgets, Secrets int
	// ViewerToken and RefusedToken are the session values the host accepts. The viewer may use
	// every source; the refused session is authenticated but every source refuses it.
	ViewerToken, RefusedToken string
	// ReauthorizeEvery is the gateway's timed recheck interval. Default 5s: short, so a 20-second
	// workload shows the per-subscriber cost of timed checks between its forced reconnects.
	ReauthorizeEvery time.Duration
	// Dist is the built library directory served at /packages/krm-stream/dist/. Page is
	// examples/comparison, served at /examples/comparison/.
	Dist, Page string
}

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

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

type PageConfig struct {
	Namespace    string   `json:"namespace"`
	Group        string   `json:"group"`
	Widgets      []string `json:"widgets"`
	Secrets      []string `json:"secrets"`
	Routes       []Route  `json:"routes"`
	RefusedToken string   `json:"refusedSession"`
	Workloads    []string `json:"workloads"`
}

type Plan struct {
	Request WorkloadRequest `json:"request"`
	Steps   []Step          `json:"steps"`
}

type Route struct {
	Name       string             `json:"name"`
	Path       string             `json:"path"`
	Projection gateway.Projection `json:"projection"`
	Shared     bool               `json:"shared"`
}

type Snapshot struct {
	Since     time.Time        `json:"since"`
	ElapsedMs int64            `json:"elapsedMs"`
	Counters  map[string]int64 `json:"counters"`
	Gauges    map[string]int64 `json:"gauges"`
}

type StateObject struct {
	Kind            string            `json:"kind"`
	UID             string            `json:"uid"`
	Name            string            `json:"name"`
	ResourceVersion string            `json:"resourceVersion"`
	Labels          map[string]string `json:"labels,omitempty"`
	Spec            any               `json:"spec,omitempty"`
	Status          any               `json:"status,omitempty"`
	Data            map[string]any    `json:"data,omitempty"`
}

type Step struct {
	At     time.Duration `json:"atMs"`
	Kind   StepKind      `json:"kind"`
	Object int           `json:"object"`
	Seq    int           `json:"seq"`
}

type StepKind string

type WorkloadRequest struct {
	Name string `json:"name"`
	// DurationMs is how long the schedule runs. Default 20000.
	DurationMs int `json:"durationMs"`
	// Seed picks which objects each write touches. Default 1.
	Seed uint64 `json:"seed"`
	// Rate is the write rate per second: status writes for churn, mixed writes for
	// forced-disconnect, writes per burst for burst. Defaults 10, 4 and 12.
	Rate float64 `json:"rate"`
	// Reconnects is how many forced downstream disconnects every workload includes, spread evenly.
	// Default 2. forced-disconnect adds one every DisconnectEveryMs on top.
	Reconnects int `json:"reconnects"`
	// DisconnectEveryMs is forced-disconnect's period. Default 4000.
	DisconnectEveryMs int `json:"disconnectEveryMs"`
	// Target is which downstream connections a disconnect closes: native, gateway or all. Default all.
	Target string `json:"target"`
}

type WorkloadResult struct {
	Plan   map[StepKind]int `json:"planned"`
	Done   map[StepKind]int `json:"done"`
	Closed int              `json:"connectionsClosed"`
	Errors []string         `json:"errors,omitempty"`
	// SecretRotations is, per Secret name, the resourceVersion of its last successful rotation. A
	// projected store shows a rotation only as a redaction revision under the same key, so this is
	// the version a subscriber must hold to prove it saw the final one.
	SecretRotations map[string]string `json:"secretRotations,omitempty"`
	MaxLateMs       int64             `json:"maxLateMs"`
	ElapsedMs       int64             `json:"elapsedMs"`
	DurationMs      int               `json:"durationMs"`
	Seed            uint64            `json:"seed"`
	Rate            float64           `json:"rate"`
	Reconnects      int               `json:"reconnects"`
	StartedUnix     int64             `json:"startedUnixMs"`
}