392ad68047
Build system, release automation, SDK generation, Ansible executor, LinuxKit dev environments, container runtime, deployment, infra metrics, and developer toolkit. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
106 lines
3.6 KiB
Go
106 lines
3.6 KiB
Go
// Package container provides a runtime for managing LinuxKit containers.
|
|
// It supports running LinuxKit images (ISO, qcow2, vmdk, raw) using
|
|
// available hypervisors (QEMU on Linux, Hyperkit on macOS).
|
|
package container
|
|
|
|
import (
|
|
"context"
|
|
"crypto/rand"
|
|
"encoding/hex"
|
|
"io"
|
|
"time"
|
|
)
|
|
|
|
// Container represents a running LinuxKit container/VM instance.
|
|
type Container struct {
|
|
// ID is a unique identifier for the container (8 character hex string).
|
|
ID string `json:"id"`
|
|
// Name is the optional human-readable name for the container.
|
|
Name string `json:"name,omitempty"`
|
|
// Image is the path to the LinuxKit image being run.
|
|
Image string `json:"image"`
|
|
// Status represents the current state of the container.
|
|
Status Status `json:"status"`
|
|
// PID is the process ID of the hypervisor running this container.
|
|
PID int `json:"pid"`
|
|
// StartedAt is when the container was started.
|
|
StartedAt time.Time `json:"started_at"`
|
|
// Ports maps host ports to container ports.
|
|
Ports map[int]int `json:"ports,omitempty"`
|
|
// Memory is the amount of memory allocated in MB.
|
|
Memory int `json:"memory,omitempty"`
|
|
// CPUs is the number of CPUs allocated.
|
|
CPUs int `json:"cpus,omitempty"`
|
|
}
|
|
|
|
// Status represents the state of a container.
|
|
type Status string
|
|
|
|
const (
|
|
// StatusRunning indicates the container is running.
|
|
StatusRunning Status = "running"
|
|
// StatusStopped indicates the container has stopped.
|
|
StatusStopped Status = "stopped"
|
|
// StatusError indicates the container encountered an error.
|
|
StatusError Status = "error"
|
|
)
|
|
|
|
// RunOptions configures how a container should be run.
|
|
type RunOptions struct {
|
|
// Name is an optional human-readable name for the container.
|
|
Name string
|
|
// Detach runs the container in the background.
|
|
Detach bool
|
|
// Memory is the amount of memory to allocate in MB (default: 1024).
|
|
Memory int
|
|
// CPUs is the number of CPUs to allocate (default: 1).
|
|
CPUs int
|
|
// Ports maps host ports to container ports.
|
|
Ports map[int]int
|
|
// Volumes maps host paths to container paths.
|
|
Volumes map[string]string
|
|
// SSHPort is the port to use for SSH access (default: 2222).
|
|
SSHPort int
|
|
// SSHKey is the path to the SSH private key for exec commands.
|
|
SSHKey string
|
|
}
|
|
|
|
// Manager defines the interface for container lifecycle management.
|
|
type Manager interface {
|
|
// Run starts a new container from the given image.
|
|
Run(ctx context.Context, image string, opts RunOptions) (*Container, error)
|
|
// Stop stops a running container by ID.
|
|
Stop(ctx context.Context, id string) error
|
|
// List returns all known containers.
|
|
List(ctx context.Context) ([]*Container, error)
|
|
// Logs returns a reader for the container's log output.
|
|
// If follow is true, the reader will continue to stream new log entries.
|
|
Logs(ctx context.Context, id string, follow bool) (io.ReadCloser, error)
|
|
// Exec executes a command inside the container via SSH.
|
|
Exec(ctx context.Context, id string, cmd []string) error
|
|
}
|
|
|
|
// GenerateID creates a new unique container ID (8 hex characters).
|
|
func GenerateID() (string, error) {
|
|
bytes := make([]byte, 4)
|
|
if _, err := rand.Read(bytes); err != nil {
|
|
return "", err
|
|
}
|
|
return hex.EncodeToString(bytes), nil
|
|
}
|
|
|
|
// ImageFormat represents the format of a LinuxKit image.
|
|
type ImageFormat string
|
|
|
|
const (
|
|
// FormatISO is an ISO image format.
|
|
FormatISO ImageFormat = "iso"
|
|
// FormatQCOW2 is a QEMU Copy-On-Write image format.
|
|
FormatQCOW2 ImageFormat = "qcow2"
|
|
// FormatVMDK is a VMware disk image format.
|
|
FormatVMDK ImageFormat = "vmdk"
|
|
// FormatRaw is a raw disk image format.
|
|
FormatRaw ImageFormat = "raw"
|
|
// FormatUnknown indicates an unknown image format.
|
|
FormatUnknown ImageFormat = "unknown"
|
|
)
|