compute

Documentation

Index

• Constants
• func Capabilities(runtime string) worker.Descriptor
• func New(commandPath ...string) worker.Driver
• func NewFirecracker(engine vmexec.Engine) worker.Driver
• func NewNative() worker.Driver
• func NewQEMU(engine vmexec.Engine) worker.Driver
• type Driver
  • func (d *Driver) Capabilities() worker.Descriptor
  • func (d *Driver) Execute(ctx context.Context, method string, params worker.Params) (worker.Outcome, error)

Constants

const RuntimeFirecracker = "firecracker"

const RuntimeQEMU = "qemu-kvm"

const RuntimeShellDocker = "shell-docker"

Functions

func Capabilities

func Capabilities(runtime string) worker.Descriptor

func New

func New(commandPath ...string) worker.Driver

New preserves the command-backed constructor used by the fleet-worker config loader. Use NewNative for the shell/docker implementation.

func NewFirecracker

func NewFirecracker(engine vmexec.Engine) worker.Driver

NewFirecracker returns a compute driver whose execution is locked to the supplied VM engine and advertised as vm/firecracker.

func NewNative

func NewNative() worker.Driver

NewNative returns the native shell/docker implementation.

func NewQEMU

func NewQEMU(engine vmexec.Engine) worker.Driver

NewQEMU returns a compute driver whose execution is locked to the supplied libvirt QEMU/KVM engine and advertised as vm/qemu-kvm.

Types

type Driver

type Driver struct {
	Runtime string
	// contains filtered or unexported fields
}

Driver owns compute method routing, request lifecycle, cancellation, and outcome construction. Execution is delegated to a backend-specific executor.

func (*Driver) Capabilities

func (d *Driver) Capabilities() worker.Descriptor

func (*Driver) Execute

func (d *Driver) Execute(ctx context.Context, method string, params worker.Params) (worker.Outcome, error)