kubernetes

func (*KubernetesRuntime) Create ¶

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

func (*KubernetesRuntime) Delete ¶

func (k *KubernetesRuntime) Delete(ctx context.Context, runtimeID string) error

func (*KubernetesRuntime) Describe ¶ added in v0.1.4

func (k *KubernetesRuntime) Describe(ctx context.Context, runtimeID string) (*containerruntime.RuntimeDescription, error)

func (*KubernetesRuntime) Endpoint ¶ added in v0.2.4

func (k *KubernetesRuntime) Endpoint() (string, string)

Endpoint satisfies containerruntime.RuntimeEndpointReporter. 返回 apiserver 地址（来自 kubeconfig / 集群内 ServiceAccount），已脱敏。

func (*KubernetesRuntime) EnsureImage ¶

func (k *KubernetesRuntime) EnsureImage(_ context.Context, imageName string, pullPolicy string) error

EnsureImage satisfies containerruntime.RuntimeImageManager. For Kubernetes runtimes, image pull is performed by kubelet during pod scheduling. This method validates input and enforces pull-policy constraints that can be checked early.

func (*KubernetesRuntime) Exec ¶

func (k *KubernetesRuntime) Exec(_ context.Context, _ string, _ []string) (string, error)

func (*KubernetesRuntime) HealthCheck ¶ added in v0.2.2

func (k *KubernetesRuntime) HealthCheck(ctx context.Context) error

HealthCheck satisfies containerruntime.RuntimeHealthChecker. 通过 apiserver 的 ServerVersion 探测集群连通性与凭据有效性 （kubeconfig 不存在 / 证书过期 / apiserver 不可达都会在这里暴露）。

func (*KubernetesRuntime) Inspect ¶

func (k *KubernetesRuntime) Inspect(ctx context.Context, runtimeID string) (*containerruntime.RuntimeInspection, error)

func (*KubernetesRuntime) Logs ¶

func (k *KubernetesRuntime) Logs(ctx context.Context, runtimeID string, tail int) (string, error)

func (*KubernetesRuntime) Monitor ¶

func (k *KubernetesRuntime) Monitor(ctx context.Context, runtimeID string) error

监控 deployment 和 job 的生命周期（启动与退出）。

func (*KubernetesRuntime) Name ¶

func (k *KubernetesRuntime) Name() string

func (*KubernetesRuntime) OpenTerminal ¶ added in v0.2.0

func (k *KubernetesRuntime) OpenTerminal(ctx context.Context, runtimeID string, opts containerruntime.TerminalOptions) (containerruntime.TerminalSession, error)

OpenTerminal 等价于 `kubectl exec -it <pod> -c main -- <command>`。

它通过 client-go 的 remotecommand（SPDY）在 Pod 内新建一个进程并申请 TTY， 不依赖容器内任何终端服务。

func (*KubernetesRuntime) Pause ¶

func (k *KubernetesRuntime) Pause(ctx context.Context, runtimeID string) error

func (*KubernetesRuntime) Resume ¶

func (k *KubernetesRuntime) Resume(ctx context.Context, runtimeID string) error

func (*KubernetesRuntime) ServerVersion ¶ added in v0.2.4

func (k *KubernetesRuntime) ServerVersion(ctx context.Context) (string, error)

ServerVersion satisfies containerruntime.RuntimeVersionReporter.

func (*KubernetesRuntime) SetEventHandler ¶

func (k *KubernetesRuntime) SetEventHandler(handler containerruntime.RuntimeEventHandler)

func (*KubernetesRuntime) Start ¶

func (k *KubernetesRuntime) Start(ctx context.Context, runtimeID string) error

func (*KubernetesRuntime) Stop ¶

func (k *KubernetesRuntime) Stop(ctx context.Context, runtimeID string) error