runtime

type Factory func(ctx context.Context, logger *slog.Logger) (Runtime, error)

type HealthInfo struct {
	HasHealthCheck bool
	Status         string // "healthy", "unhealthy", "starting", "none"
	FailingStreak  int
	LastOutput     string
}

type RawStats struct {
	CPUPercent      float64
	MemUsed         int64
	MemLimit        int64
	NetRxBytes      int64 // -1 if unavailable
	NetTxBytes      int64 // -1 if unavailable
	BlockReadBytes  int64 // -1 if unavailable
	BlockWriteBytes int64 // -1 if unavailable
	Timestamp       time.Time
}

type Runtime interface {
	// Lifecycle
	Connect(ctx context.Context) error
	// TryConnect attempts a single bounded connection (~3s). Non-fatal: returns error without retrying.
	TryConnect(ctx context.Context) error
	IsConnected() bool
	SetDisconnected()
	Close() error

	// Identity
	Name() string // "docker" or "kubernetes"

	// Discovery
	DiscoverAll(ctx context.Context) ([]*container.Container, error)

	// Events
	StreamEvents(ctx context.Context) <-chan RuntimeEvent

	// Stats
	StatsSnapshot(ctx context.Context, externalID string) (*RawStats, error)

	// Logs
	FetchLogs(ctx context.Context, externalID string, lines int, timestamps bool) ([]string, error)
	StreamLogs(ctx context.Context, externalID string, lines int, timestamps bool) (io.ReadCloser, error)

	// Health
	GetHealthInfo(ctx context.Context, externalID string) (*HealthInfo, error)
}

type RuntimeEvent struct {
	Action       string
	ExternalID   string
	Name         string
	Image        string
	ExitCode     string
	HealthStatus string
	ErrorDetail  string
	ResourceType string // "container", "service", or "node"
	Timestamp    time.Time
	Labels       map[string]string
}