agent

type Activity interface {
	Record(uuid string, at time.Time) error
}

type Agent struct {

	// Settle is how long the agent waits after a container event before
	// reading the real state: a replacement (stop old → rm → rename
	// candidate) must have landed, or the reading describes a container that
	// no longer exists. Resync is the safety net that repairs any state a
	// missed event left stale.
	Settle time.Duration
	Resync time.Duration

	Heartbeat time.Duration
	Flush     time.Duration
	Backoff   time.Duration
	// WSCooldown is how long the agent stays on the POST fallback after a
	// WebSocket failure before re-dialing (ADR-041 §4).
	WSCooldown time.Duration
	// DisableWS forces the POST fallback (tests, or an egress known to break
	// WebSockets).
	DisableWS bool
	// Executor serves the ADR-052 typed commands when the control plane
	// speaks v2; nil keeps the channel observation-only (v1).
	Executor *Executor
	// contains filtered or unexported fields
}

type Config struct {
	Routes    []Route    `json:"routes"`
	Resources []Resource `json:"resources"`
}

type ContainerEvent struct {
	Container string // container name
	Action    string // start, die, stop, oom, health_status: healthy, …
	At        time.Time
}

type ContainerState struct {
	Running bool
	// Health is the healthcheck status: "healthy", "unhealthy", "starting", or
	// "none" when the image declares no healthcheck (§8.2, running-stable path).
	Health string
}

type Docker interface {
	Start(ctx context.Context, container string) error
	Inspect(ctx context.Context, container string) (ContainerState, error)
	Stop(ctx context.Context, container string) error
}

type Enrollment struct {
	InstanceURL string
	Token       string
}

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

type FileActivity struct {
	Dir string
}

type Observation = agentwire.Observation

type Resource struct {
	UUID       string          `json:"uuid"`
	Containers []string        `json:"containers"`
	WakeSet    []WakeContainer `json:"wake_set,omitempty"`
}

type Route struct {
	Host         string `json:"host"`
	ResourceUUID string `json:"resource_uuid"`
	Container    string `json:"container"`
	Port         int    `json:"port"`
}

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

type WakeContainer struct {
	Container string `json:"container"`
	// Needs lists the containers this one waits for before starting — the
	// compose depends_on edges, container-name resolved. A dependency this
	// wake started must be READY (healthy, or running-stable); one already
	// running before the wake satisfies its edge as-is.
	Needs []string `json:"needs,omitempty"`
}

type Waker struct {
	WakeTimeout time.Duration
	Poll        time.Duration
	StableFor   time.Duration
	// Logger records wake failures with their real cause; nil uses slog.Default.
	Logger *slog.Logger

	// OnWake, when set, is told about every wake that actually started
	// containers — the agent pushes it as an "stz_woken" observation
	// (ADR-040) so the control plane can flip the resource's status without
	// waiting for its next SSH scan. Called outside any lock; must not block.
	OnWake func(resourceUUID string)
	// contains filtered or unexported fields
}