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 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
}