vm

type CgroupLimit struct {
	CPUShares uint64
	MemoryMax int64
}

type CgroupManager struct {
	// contains filtered or unexported fields
}

type CommandFunc func(ctx context.Context, name string, args ...string) *exec.Cmd

type Config struct {
	// ImagePath is the raw disk image containing the kernel and application.
	ImagePath string
	// ImageRef is the image reference the VM was created from (e.g.
	// "flaskapp:latest"), preserved for display. Empty when the VM was started
	// from a raw ImagePath with no registered image.
	ImageRef string
	// Memory is the QEMU memory string (e.g. "256M").
	Memory string
	// CPUs is the number of virtual CPUs; 0 uses QEMU default.
	CPUs int
	// NetworkName is the TAP interface name to attach; empty disables networking.
	// Networking is TAP only (SLIRP is not supported), so PortMaps require a
	// non-empty NetworkName.
	NetworkName string
	// PortMaps is the list of host-to-guest port forwarding rules, published by
	// a userspace forwarder. Requires TAP networking (a non-empty NetworkName).
	PortMaps []PortMap
	// Env is a list of "KEY=VALUE" environment variable pairs injected at
	// boot time via QEMU fw_cfg. The kernel reads opt/uni/env to consume them.
	Env []string
	// Name is a human-readable identifier for the VM. If empty, the UUID is used.
	Name string
	// Volumes is the list of additional disk images to attach to the VM.
	Volumes []VolumeMount
	// Attach when true, creates a pipe for streaming serial console output.
	Attach bool
	// IPAddress is the static IP address to assign to the VM. Requires TAP
	// networking (NetworkName). If empty, no static IP is configured.
	IPAddress string
	// GatewayIP is the gateway IP for the VM's network. Derived from IPAddress
	// when using TAP networking. Used to assign an IP to the bridge interface.
	GatewayIP string
	// BridgeName is the Linux bridge interface name for the VM's network.
	// When set, the daemon creates/destroys this bridge on VM start/stop.
	BridgeName string
	// SubnetMask is the CIDR mask for the VM's network (e.g. "24").
	// Used to build the guest network configuration passed via fw_cfg.
	SubnetMask string
	// HealthCheck configures liveness probing for the VM. Nil disables probing.
	HealthCheck *HealthCheckConfig
	// Restart controls automatic restart behavior when the VM exits.
	Restart RestartConfig
	// CPUShares is the cgroup v2 CPU weight (1–10000). 0 means no limit.
	CPUShares uint64
	// MemoryMax is the cgroup v2 memory hard limit in bytes. 0 means no limit.
	MemoryMax int64
	// DiskIOPS is the maximum I/O operations per second for the boot disk (QEMU throttle). 0 means no limit.
	DiskIOPS uint64
	// DiskBPS is the maximum bytes per second for the boot disk (QEMU throttle). 0 means no limit.
	DiskBPS int64
}

type FCOption func(*FirecrackerManager)

type FileStore struct {
	MemoryStore
	// contains filtered or unexported fields
}

type FirecrackerManager struct {
	// contains filtered or unexported fields
}

type HealthCheckConfig struct {
	// Type is "tcp" or "http". For HTTP, a GET request is made to Path.
	Type string
	// Port is the guest port to probe.
	Port int
	// Path is the HTTP path (only used when Type is "http").
	Path string
	// Interval between probes. Defaults to 10s if zero.
	Interval time.Duration
	// Timeout per probe. Defaults to 3s if zero.
	Timeout time.Duration
	// Retries is the number of consecutive failures before marking unhealthy.
	// Defaults to 3 if zero.
	Retries int
}

type HealthChecker struct {
	// contains filtered or unexported fields
}

type HealthStatus string

type Manager interface {
	// Create registers a new VM with the given config.
	Create(ctx context.Context, cfg Config) (*VM, error)
	// Start launches the QEMU process for the VM with the given id.
	Start(ctx context.Context, id string) error
	// Stop gracefully shuts down the VM: SIGTERM, 30s grace, then SIGKILL.
	Stop(ctx context.Context, id string) error
	// Kill immediately sends SIGKILL to the VM process.
	Kill(ctx context.Context, id string) error
	// Signal sends an arbitrary OS signal to the VM process.
	Signal(ctx context.Context, id string, sig os.Signal) error
	// Remove deletes a stopped VM from the registry.
	Remove(ctx context.Context, id string) error
	// Get returns the VM with the given id.
	Get(id string) (*VM, error)
	// List returns all registered VMs.
	List() []*VM
}

type MemoryStore struct {
	// contains filtered or unexported fields
}

type Migrator struct {
	// contains filtered or unexported fields
}

type MockManager struct {
	CreateFn func(ctx context.Context, cfg Config) (*VM, error)
	StartFn  func(ctx context.Context, id string) error
	StopFn   func(ctx context.Context, id string) error
	KillFn   func(ctx context.Context, id string) error
	SignalFn func(ctx context.Context, id string, sig os.Signal) error
	RemoveFn func(ctx context.Context, id string) error
	GetFn    func(id string) (*VM, error)
	ListFn   func() []*VM
	// contains filtered or unexported fields
}

type NoopStatsCollector struct {
	ID    string
	State string
}

type Option func(*QEMUManager)

type PortMap struct {
	// HostPort is the port on the host to listen on.
	HostPort uint16
	// GuestPort is the port inside the VM to forward to.
	GuestPort uint16
	// Protocol is "tcp" or "udp"; defaults to "tcp".
	Protocol PortProtocol
}

type PortProtocol string

type ProcStatsCollector struct {
	// contains filtered or unexported fields
}

type QEMUManager struct {
	// contains filtered or unexported fields
}

type RestartConfig struct {
	// Policy is the restart policy: "never", "on-failure", or "always".
	Policy RestartPolicy
	// MaxRetries is the maximum number of restart attempts. 0 means unlimited.
	MaxRetries int
}

type RestartPolicy string

type RuntimeStats struct {
	ID         string
	State      string
	CPUPct     float64
	MemBytes   int64
	DiskBytes  int64
	NetRxBytes int64
	NetTxBytes int64
	Timestamp  time.Time
	Source     string
}

type SQLiteStore struct {
	MemoryStore
	// contains filtered or unexported fields
}

type State string

type StatsCollector interface {
	Collect() RuntimeStats
}

type Store interface {
	Create(cfg Config) (*VM, error)
	Get(id string) (*VM, error)
	Resolve(nameOrID string) (*VM, error)
	List() []*VM
	Remove(id string) error
	Save(v *VM) error
	Restore() error
}

type VM struct {
	// ID uniquely identifies the VM.
	ID string
	// Cfg is the configuration the VM was created with.
	Cfg Config
	// State is the current lifecycle state.
	State State
	// CreatedAt is when the VM was registered.
	CreatedAt time.Time
	// StartedAt is when the QEMU process started (nil until then).
	StartedAt *time.Time
	// StoppedAt is when the QEMU process exited (nil until then).
	StoppedAt *time.Time
	// DaemonRecovered is true when this VM was recovered from a previous
	// daemon run. The original QEMU process is gone; the VM is in StateStopped.
	DaemonRecovered bool
	// HealthStatus is the latest probe result. "unknown" if no health check.
	HealthStatus HealthStatus
	// RestartCount is the number of times this VM has been restarted.
	RestartCount int
	// contains filtered or unexported fields
}

type VolumeMount struct {
	// DiskPath is the absolute path to the raw disk image on the host.
	DiskPath string
	// GuestPath is the mount point inside the VM. The hypervisor passes
	// "Label:GuestPath" to the guest kernel (QEMU fw_cfg opt/uni/mounts or
	// Firecracker boot args) so the volume is mounted there.
	GuestPath string
	// ReadOnly marks the volume as read-only.
	ReadOnly bool
	// Label is the volume's TFS filesystem label, used by the guest kernel's
	// volume_match to bind this disk to GuestPath. Empty volumes are skipped
	// for mount injection (attached as a bare block device only).
	Label string
}