运行时架构设计

// core/runtime/runtime.go

type PlatformRuntime interface {
    // ID 返回运行时标识
    ID() string

    // Create 创建新任务
    Create(ctx context.Context, taskID string, opts CreateOpts) (Task, error)

    // Get 获取已存在的任务
    Get(ctx context.Context, taskID string) (Task, error)

    // Tasks 返回所有任务
    Tasks(ctx context.Context, all bool) ([]Task, error)

    // Delete 删除任务
    Delete(ctx context.Context, taskID string) (*Exit, error)
}

// core/runtime/task.go

type Task interface {
    // ID 返回任务 ID
    ID() string

    // State 返回任务状态
    State(ctx context.Context) (State, error)

    // Start 启动任务
    Start(ctx context.Context) error

    // Kill 发送信号
    Kill(ctx context.Context, signal syscall.Signal, all bool) error

    // Exec 执行新进程
    Exec(ctx context.Context, id string, opts ExecOpts) (Process, error)

    // Pids 返回所有进程 PID
    Pids(ctx context.Context) ([]ProcessInfo, error)

    // Checkpoint 创建检查点
    Checkpoint(ctx context.Context, path string, opts *types.Any) error

    // Wait 等待任务退出
    Wait(ctx context.Context) (*Exit, error)

    // CloseIO 关闭 IO
    CloseIO(ctx context.Context) error

    // Resize 调整终端大小
    Resize(ctx context.Context, w, h uint32) error

    // Update 更新资源限制
    Update(ctx context.Context, resources *types.Any, annotations map[string]string) error

    // Process 获取指定进程
    Process(ctx context.Context, id string) (Process, error)
}

type Process interface {
    // ID 返回进程 ID
    ID() string

    // State 返回进程状态
    State(ctx context.Context) (State, error)

    // Kill 发送信号
    Kill(ctx context.Context, signal syscall.Signal, all bool) error

    // Wait 等待进程退出
    Wait(ctx context.Context) (*Exit, error)

    // CloseIO 关闭 IO
    CloseIO(ctx context.Context) error

    // Resize 调整终端大小
    Resize(ctx context.Context, w, h uint32) error

    // Start 启动进程
    Start(ctx context.Context) error

    // Delete 删除进程
    Delete(ctx context.Context) (*Exit, error)
}

// core/runtime/task.go

type Status int

const (
    UnknownStatus Status = iota
    CreatedStatus        // 已创建，未启动
    RunningStatus        // 运行中
    StoppedStatus        // 已停止
    PausedStatus         // 已暂停
    PausingStatus        // 正在暂停
)

// 从容器 Spec 生成 config.json
func generateOCISpec(container containers.Container, mounts []mount.Mount) (*specs.Spec, error) {
    // 解码容器规格
    var spec specs.Spec
    if err := typeurl.UnmarshalTo(container.Spec, &spec); err != nil {
        return nil, err
    }

    // 设置根文件系统
    spec.Root = &specs.Root{
        Path:     "rootfs",
        Readonly: false,
    }

    // 添加挂载点
    spec.Mounts = append(spec.Mounts, fromOCIMounts(mounts)...)

    return &spec, nil
}

// core/runtime/v2/shim_manager.go

type ShimManager struct {
    root          string      // 状态目录
    state         string      // 运行目录
    shims         sync.Map    // Shim 实例缓存
    events        *exchange.Exchange
    containers    containers.Store
}

// Start 启动新的 Shim
func (m *ShimManager) Start(ctx context.Context, id string, opts runtime.CreateOpts) (shim.Shim, error) {
    // 1. 构建 Bundle
    bundle, err := NewBundle(ctx, m.root, m.state, id, opts.Spec)
    if err != nil {
        return nil, err
    }

    // 2. 解析运行时路径
    shimPath, err := m.resolveRuntimePath(opts.Runtime)
    if err != nil {
        return nil, err
    }

    // 3. 启动 Shim 进程
    params, err := m.startShim(ctx, shimPath, bundle, opts)
    if err != nil {
        return nil, err
    }

    // 4. 连接到 Shim
    conn, err := m.connect(ctx, params.Address)
    if err != nil {
        return nil, err
    }

    // 5. 创建 Shim 客户端
    shim := newShim(conn, params)
    m.shims.Store(id, shim)

    return shim, nil
}