containerruntime

type MonitoringRegistry interface {
	Mark(runtimeID string)
	Unmark(runtimeID string)
	IsMonitoring(runtimeID string) bool
	MarkIfNotMonitoring(runtimeID string) bool
	Snapshot() map[string]int
}

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

type Runtime interface {
	Name() string

	Create(ctx context.Context, spec *types.ContainerSpec) (string, error)

	Start(ctx context.Context, runtimeID string) error

	Stop(ctx context.Context, runtimeID string) error

	Pause(ctx context.Context, runtimeID string) error

	Resume(ctx context.Context, runtimeID string) error

	Delete(ctx context.Context, runtimeID string) error

	Logs(ctx context.Context, runtimeID string, tail int) (string, error)

	SetEventHandler(handler RuntimeEventHandler)

	Exec(ctx context.Context, runtimeID string, cmd []string) (string, error)
}

type RuntimeDescriber interface {
	Describe(ctx context.Context, runtimeID string) (*RuntimeDescription, error)
}

type RuntimeDescription struct {
	// Kind 标识资源类型，例如 container / deployment / job / service。
	Kind string `json:"kind"`
	// Name 资源名称（docker 容器名，或 k8s workload/service 名）。
	Name string `json:"name"`
	// Format 描述 Raw 的格式，便于前端渲染，例如 json / yaml / text。
	Format string `json:"format"`
	// Raw 原始 inspect/describe 输出，保持后端运行时的原生格式。
	Raw string `json:"raw"`
}

type RuntimeEvent struct {
	Type      string
	RuntimeID string
	Message   string
}

type RuntimeEventHandler interface {
	OnEvent(event RuntimeEvent)
}

type RuntimeHealth struct {
	// Name 运行时名称（docker / k8s / k3s）。
	Name string `json:"name"`
	// Registered 是否在运行时注册表中（即启动装配阶段是否成功注册）。
	Registered bool `json:"registered"`
	// Healthy 依赖探测是否通过；未注册时必然为 false。
	Healthy bool `json:"healthy"`
	// Checkable 运行时是否实现了 RuntimeHealthChecker（false 表示只做了注册检查）。
	Checkable bool `json:"checkable"`
	// Error 检测失败原因，正常时为空。
	Error string `json:"error,omitempty"`
}

type RuntimeHealthChecker interface {
	// HealthCheck 探测运行时依赖是否可用；返回 error 表示不可用（包含具体原因）。
	// ctx 由调用方设置超时，实现应尽量快速返回。
	HealthCheck(ctx context.Context) error
}

type RuntimeImageManager interface {
	EnsureImage(ctx context.Context, image string, pullPolicy string) error
}

type RuntimeInspection struct {
	IPAddress string
	NodeName  string
}

type RuntimeInspector interface {
	Inspect(ctx context.Context, runtimeID string) (*RuntimeInspection, error)
}

type RuntimeMonitor interface {
	Monitor(ctx context.Context, runtimeID string) error
}

type RuntimeTerminal interface {
	OpenTerminal(ctx context.Context, runtimeID string, opts TerminalOptions) (TerminalSession, error)
}

type TerminalOptions struct {
	// Command 是要在容器内执行的命令，例如 []string{"/bin/bash", "-l"}。
	Command []string
	// TTY 为 true 时申请伪终端（交互式 shell 必须为 true）。
	TTY bool
	// Rows / Cols 是初始终端尺寸。
	Rows uint16
	Cols uint16
}

type TerminalSession interface {
	io.Reader
	io.Writer
	// Resize 调整终端尺寸（行 / 列）。
	Resize(rows, cols uint16) error
	// Close 关闭会话与底层连接。
	Close() error
}