agent

type Active struct {
	ID      string    `json:"id"`
	Request Request   `json:"request"`
	Started time.Time `json:"started"`
	Ends    time.Time `json:"ends"`
	// contains filtered or unexported fields
}

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

type Client struct {
	BaseURL string
	Token   string
	HTTP    *http.Client
}

type Config struct {
	Proxies []*Proxy
	// Docker, when set, allows container actions.
	Docker *Docker
	// Kubernetes, when set, allows deployment scaling.
	Kubernetes *Kubernetes
	// MaxDuration caps every fault (default 30 minutes), so a forgotten
	// fault always ends.
	MaxDuration time.Duration
	// Audit receives one record per action and revert.
	Audit  *slog.Logger
	Logger *slog.Logger
}

type Docker struct {
	// Allowed lists container names (globs) the agent may act on.
	Allowed []string
	// contains filtered or unexported fields
}

type Fault struct {
	// Latency is added to each direction of every connection, so a
	// request and its response together take twice Latency longer.
	Latency time.Duration `json:"latency,omitempty"`
	// Jitter adds a random delay in [0, Jitter) on top of Latency.
	Jitter time.Duration `json:"jitter,omitempty"`
	// Bandwidth caps each direction of each connection, in bytes per
	// second (0 = unlimited).
	Bandwidth int64 `json:"bandwidth,omitempty"`
	// Reset resets every open connection when the fault starts, and every
	// new connection while it lasts.
	Reset bool `json:"reset,omitempty"`
	// Refuse resets new connections as soon as they arrive; open ones are
	// left alone.
	Refuse bool `json:"refuse,omitempty"`
	// Blackhole stops forwarding in both directions: connections stay
	// open and requests time out.
	Blackhole bool `json:"blackhole,omitempty"`
}

type Kind string

type Kubernetes struct {
	// Allowed lists deployments (namespace/name globs) the agent may scale.
	Allowed []string
	// contains filtered or unexported fields
}

type Proxy struct {
	Name     string
	Listen   string
	Upstream string
	// contains filtered or unexported fields
}

type ProxyInfo struct {
	Name     string `json:"name"`
	Listen   string `json:"listen"`
	Upstream string `json:"upstream"`
	Conns    int    `json:"conns"`
	Fault    Fault  `json:"fault"`
}

type Request struct {
	Kind Kind `json:"kind"`
	// Target is a proxy name, a container name or id, or a deployment as
	// namespace/name.
	Target string `json:"target"`
	// Fault applies to proxies.
	Fault Fault `json:"fault,omitempty"`
	// Action applies to containers: pause, stop or restart.
	Action string `json:"action,omitempty"`
	// Replicas applies to deployments.
	Replicas *int `json:"replicas,omitempty"`
	// Duration is how long the fault lasts; required, at most MaxDuration.
	Duration time.Duration `json:"duration"`
	// Run and Label say who asked, for the audit log.
	Run   string `json:"run,omitempty"`
	Label string `json:"label,omitempty"`
}

type Status struct {
	Proxies     []ProxyInfo `json:"proxies"`
	Active      []Active    `json:"active"`
	Docker      bool        `json:"docker"`
	Kubernetes  bool        `json:"kubernetes"`
	MaxDuration string      `json:"maxDuration"`
}