mirror of
https://github.com/hanzoai/runtime.git
synced 2026-10-30 18:23:13 +00:00
zeekay
ea80dc3638
- Add main Dockerfile for production builds - Add Dockerfile.runtime for secure code execution - Add Dockerfile.runtime.fixed with improved configuration - Include .dockerignore for build optimization - Add integration documentation and publishing guides - Update API and CLI components for better runtime support - Enhance sandbox and container management features
86 lines
2.1 KiB
Go
86 lines
2.1 KiB
Go
// Copyright 2025 Hanzo Industries Inc.
|
|
// SPDX-License-Identifier: AGPL-3.0
|
|
|
|
package docker
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/hanzoai/runner/pkg/common"
|
|
"github.com/hanzoai/runner/pkg/models/enums"
|
|
"github.com/docker/docker/api/types/container"
|
|
"github.com/docker/docker/errdefs"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
func (d *DockerClient) Destroy(ctx context.Context, containerId string) error {
|
|
startTime := time.Now()
|
|
defer func() {
|
|
obs, err := common.ContainerOperationDuration.GetMetricWithLabelValues("destroy")
|
|
if err == nil {
|
|
obs.Observe(time.Since(startTime).Seconds())
|
|
}
|
|
}()
|
|
|
|
// Ignore err because we want to destroy the container even if it exited
|
|
state, _ := d.DeduceSandboxState(ctx, containerId)
|
|
if state == enums.SandboxStateDestroyed || state == enums.SandboxStateDestroying {
|
|
return nil
|
|
}
|
|
|
|
d.cache.SetSandboxState(ctx, containerId, enums.SandboxStateDestroying)
|
|
|
|
_, err := d.ContainerInspect(ctx, containerId)
|
|
if err != nil {
|
|
if errdefs.IsNotFound(err) {
|
|
d.cache.SetSandboxState(ctx, containerId, enums.SandboxStateDestroyed)
|
|
}
|
|
return err
|
|
}
|
|
|
|
err = d.apiClient.ContainerRemove(ctx, containerId, container.RemoveOptions{
|
|
Force: true,
|
|
})
|
|
if err != nil {
|
|
if errdefs.IsNotFound(err) {
|
|
d.cache.SetSandboxState(ctx, containerId, enums.SandboxStateDestroyed)
|
|
}
|
|
return err
|
|
}
|
|
|
|
d.cache.SetSandboxState(ctx, containerId, enums.SandboxStateDestroyed)
|
|
|
|
return nil
|
|
}
|
|
|
|
func (d *DockerClient) RemoveDestroyed(ctx context.Context, containerId string) error {
|
|
|
|
// Check if container exists and is in destroyed state
|
|
state, err := d.DeduceSandboxState(ctx, containerId)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if state != enums.SandboxStateDestroyed {
|
|
return common.NewBadRequestError(fmt.Errorf("container %s is not in destroyed state", containerId))
|
|
}
|
|
|
|
// Remove the container
|
|
err = d.apiClient.ContainerRemove(ctx, containerId, container.RemoveOptions{
|
|
Force: true,
|
|
})
|
|
if err != nil {
|
|
if errdefs.IsNotFound(err) {
|
|
return nil // Container already removed
|
|
}
|
|
return err
|
|
}
|
|
|
|
log.Infof("Destroyed container %s removed successfully", containerId)
|
|
|
|
return nil
|
|
}
|