hypervisor

package
v0.0.0-...-1e561f4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 25, 2017 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BaseDir         = "/var/run/hyper"
	HyperSockName   = "hyper.sock"
	TtySockName     = "tty.sock"
	ConsoleSockName = "console.sock"
	ShareDirTag     = "share_dir"
	DefaultKernel   = "/var/lib/hyper/kernel"
	DefaultInitrd   = "/var/lib/hyper/hyper-initrd.img"
	DetachKeys      = "ctrl-p,ctrl-q"

	// cpu/mem hotplug constants
	DefaultMaxCpus = 8     // CONFIG_NR_CPUS hyperstart.git/build/kernel_config
	DefaultMaxMem  = 32768 // size in MiB
)
View Source 
const (
	ST_CREATING = iota
	ST_CREATED
	ST_STARTING
	ST_RUNNING
	ST_STOPPING
)
View Source 
const (
	EVENT_VM_EXIT = iota
	EVENT_VM_KILL
	EVENT_VM_TIMEOUT
	// TODO EVENT_BLOCK_EJECTED EVENT_BLOCK_INSERTED EVENT_INTERFACE_ADD EVENT_INTERFACE_INSERTED EVENT_INTERFACE_EJECTED are not referenced expect in events.go
	EVENT_BLOCK_INSERTED
	EVENT_BLOCK_EJECTED
	EVENT_INTERFACE_ADD
	EVENT_INTERFACE_INSERTED
	EVENT_INTERFACE_EJECTED
	COMMAND_SHUTDOWN
	COMMAND_RELEASE
	COMMAND_ATTACH
	COMMAND_PAUSEVM
	ERROR_VM_START_FAILED
	ERROR_INIT_FAIL
	ERROR_QMP_FAIL
	ERROR_INTERRUPTED
)
View Source 
const (
	PauseStateUnpaused = iota
	PauseStatePaused
)
View Source 
const (
	ET_SPEC      string = "SPEC_ERROR"
	ET_BUSY      string = "RESOURSE_UNAVAILABLE"
	ET_DEVICE    string = "DEVICE_OPERATION_FAIL"
	ET_NOT_READY string = "VM_NOT_READY"
)
View Source 
const (
	ERROR   = hlog.ERROR
	WARNING = hlog.WARNING
	INFO    = hlog.INFO
	DEBUG   = hlog.DEBUG
	TRACE   = hlog.TRACE
	EXTRA   = hlog.EXTRA
)
View Source 
const (
	MAX_NIC = int(^uint(0) >> 1) // Eth is network card, while lo is alias, what's the maximum for each? same?
	// let upper level logic care about the restriction. here is just an upbond.
	DEFAULT_LO_DEVICE_NAME = "lo"
)
View Source 
const (
	StateRunning     = "RUNNING"
	StateTerminating = "TERMINATING"
	StateNone        = "NONE"
)

states

View Source 
const CURRENT_PERSIST_VERSION = 20170611
View Source 
const (
	VmLogdSock = "/var/run/vmlogd.sock"
)

Variables

View Source 
var InterfaceCount int = 1
View Source 
var PciAddrFrom int = 0x05
View Source 
var VsockCidManager vsock.VsockCidAllocator

Functions

func EventString 

func EventString(ev int) string

func InitNetwork 

func InitNetwork(bIface, bIP string, disableIptables bool) error

func NewVmSpec 

func NewVmSpec() *hyperstartapi.Pod

func SupportLazyMode 

func SupportLazyMode() bool

func TtyLiner 

func TtyLiner(conn io.Reader, output chan string)

func UnblockSend 

func UnblockSend(ch chan *types.VmResponse, u *types.VmResponse)

Types

type AttachCommand 

type AttachCommand struct {
	Streams   *TtyIO
	Container string
}

func (*AttachCommand) Event 

func (qe *AttachCommand) Event() int

type BlockdevInsertedEvent 

type BlockdevInsertedEvent struct {
	DeviceName string
	ScsiAddr   string // pass scsi addr to hyperstart
}

func (*BlockdevInsertedEvent) Event 

func (qe *BlockdevInsertedEvent) Event() int

type BootConfig 

type BootConfig struct {
	CPU              int
	Memory           int
	BootToBeTemplate bool
	BootFromTemplate bool
	EnableVsock      bool
	EnableVhostUser  bool
	MemoryPath       string
	DevicesStatePath string
	Kernel           string
	Initrd           string
	Bios             string
	Cbfs             string

	// For network QoS (kilobytes/s)
	InboundAverage  string
	InboundPeak     string
	OutboundAverage string
	OutboundPeak    string
}

type BuildinNetworkDriver 

type BuildinNetworkDriver interface {
	HypervisorDriver

	InitNetwork(bIface, bIP string, disableIptables bool) error
}

type CommonError 

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

implement error, hypervisor.Error, and api.Result

func NewBusyError 

func NewBusyError(id, cause string) *CommonError

func NewDeviceError 

func NewDeviceError(id, cause string) *CommonError

func NewNotReadyError 

func NewNotReadyError(id string) *CommonError

func NewSpecError 

func NewSpecError(id, cause string) *CommonError

Error in spec, which is either mistake format or content inconsistency, and is checked when elements are being added to Sandbox.

func (*CommonError) Error 

func (err *CommonError) Error() string

func (*CommonError) IsSuccess 

func (err *CommonError) IsSuccess() bool

func (*CommonError) Message 

func (err *CommonError) Message() string

func (*CommonError) ResultId 

func (err *CommonError) ResultId() string

func (*CommonError) Type 

func (err *CommonError) Type() string

type ConsoleDriverContext 

type ConsoleDriverContext interface {
	DriverContext

	ConnectConsole(console chan<- string) error
}

type ContainerContext 

type ContainerContext struct {
	*api.ContainerDescription
	// contains filtered or unexported fields
}

func (*ContainerContext) Log 

func (cc *ContainerContext) Log(level hlog.LogLevel, args ...interface{})

func (*ContainerContext) LogPrefix 

func (cc *ContainerContext) LogPrefix() string

func (*ContainerContext) VmSpec 

func (cc *ContainerContext) VmSpec() *hyperstartapi.Container

type DeviceFailed 

type DeviceFailed struct {
	Session VmEvent
}

func (*DeviceFailed) Event 

func (qe *DeviceFailed) Event() int

func (*DeviceFailed) IsSuccess 

func (df *DeviceFailed) IsSuccess() bool

func (*DeviceFailed) Message 

func (df *DeviceFailed) Message() string

func (*DeviceFailed) ResultId 

func (df *DeviceFailed) ResultId() string

Device Failed as api.Result

type DiskContext 

type DiskContext struct {
	*DiskDescriptor
	// contains filtered or unexported fields
}

func NewDiskContext 

func NewDiskContext(ctx *VmContext, vol *api.VolumeDescription) *DiskContext

type DiskDescriptor 

type DiskDescriptor struct {
	Name         string
	Filename     string
	Format       string
	Fstype       string
	DeviceName   string
	ScsiId       int
	ScsiAddr     string
	DockerVolume bool
	ReadOnly     bool
	Options      map[string]string
}

func (*DiskDescriptor) IsDir 

func (d *DiskDescriptor) IsDir() bool

func (*DiskDescriptor) IsNas 

func (d *DiskDescriptor) IsNas() bool

type DriverContext 

type DriverContext interface {
	Launch(ctx *VmContext)
	Associate(ctx *VmContext)
	Dump() (map[string]interface{}, error)

	AddDisk(ctx *VmContext, sourceType string, blockInfo *DiskDescriptor, result chan<- VmEvent)
	RemoveDisk(ctx *VmContext, blockInfo *DiskDescriptor, callback VmEvent, result chan<- VmEvent)

	AddNic(ctx *VmContext, host *HostNicInfo, guest *GuestNicInfo, result chan<- VmEvent)
	RemoveNic(ctx *VmContext, n *InterfaceCreated, callback VmEvent, result chan<- VmEvent)

	SetCpus(ctx *VmContext, cpus int) error
	AddMem(ctx *VmContext, slot, size int) error

	Save(ctx *VmContext, path string) error

	Shutdown(ctx *VmContext)
	Kill(ctx *VmContext)

	Pause(ctx *VmContext, pause bool) error

	Stats(ctx *VmContext) (*types.PodStats, error)

	Close()
}

type EmptyContext 

type EmptyContext struct{}

func (*EmptyContext) AddDisk 

func (ec *EmptyContext) AddDisk(ctx *VmContext, sourceType string, blockInfo *DiskDescriptor, result chan<- VmEvent)

func (*EmptyContext) AddMem 

func (ec *EmptyContext) AddMem(ctx *VmContext, slot, size int) error

func (*EmptyContext) AddNic 

func (ec *EmptyContext) AddNic(ctx *VmContext, host *HostNicInfo, guest *GuestNicInfo, result chan<- VmEvent)

func (*EmptyContext) Associate 

func (ec *EmptyContext) Associate(ctx *VmContext)

func (*EmptyContext) BuildinNetwork 

func (ec *EmptyContext) BuildinNetwork() bool

func (*EmptyContext) Close 

func (ec *EmptyContext) Close()

func (*EmptyContext) ConfigureNetwork 

func (ec *EmptyContext) ConfigureNetwork(config *api.InterfaceDescription) (*network.Settings, error)

func (*EmptyContext) Dump 

func (ec *EmptyContext) Dump() (map[string]interface{}, error)

func (*EmptyContext) Kill 

func (ec *EmptyContext) Kill(ctx *VmContext)

func (*EmptyContext) Launch 

func (ec *EmptyContext) Launch(ctx *VmContext)

func (*EmptyContext) Pause 

func (ec *EmptyContext) Pause(ctx *VmContext, pause bool) error

func (*EmptyContext) ReleaseNetwork 

func (ec *EmptyContext) ReleaseNetwork(releasedIP string) error

func (*EmptyContext) RemoveDisk 

func (ec *EmptyContext) RemoveDisk(ctx *VmContext, blockInfo *DiskDescriptor, callback VmEvent, result chan<- VmEvent)

func (*EmptyContext) RemoveNic 

func (ec *EmptyContext) RemoveNic(ctx *VmContext, n *InterfaceCreated, callback VmEvent, result chan<- VmEvent)

func (*EmptyContext) Save 

func (ec *EmptyContext) Save(ctx *VmContext, path string) error

func (*EmptyContext) SetCpus 

func (ec *EmptyContext) SetCpus(ctx *VmContext, cpus int) error

func (*EmptyContext) Shutdown 

func (ec *EmptyContext) Shutdown(ctx *VmContext)

func (*EmptyContext) Stats 

func (ec *EmptyContext) Stats(ctx *VmContext) (*types.PodStats, error)

type EmptyDriver 

type EmptyDriver struct{}

func (*EmptyDriver) InitContext 

func (ed *EmptyDriver) InitContext(homeDir string) DriverContext

func (*EmptyDriver) Initialize 

func (ed *EmptyDriver) Initialize() error

func (*EmptyDriver) LoadContext 

func (ed *EmptyDriver) LoadContext(persisted map[string]interface{}) (DriverContext, error)

func (*EmptyDriver) Name 

func (ed *EmptyDriver) Name() string

func (*EmptyDriver) SupportLazyMode 

func (ed *EmptyDriver) SupportLazyMode() bool

func (*EmptyDriver) SupportVmSocket 

func (ed *EmptyDriver) SupportVmSocket() bool

type Errors 

type Errors interface {
	Type() string
}

type Fanout 

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

func CreateFanout 

func CreateFanout(upstream chan *types.VmResponse, size int, block bool) *Fanout

CreateFanout create a new fanout, and if it is non-blocked, it will start the fanout goroutine at once, otherwise it will start the goroutine when it get the first client

func (*Fanout) Acquire 

func (fo *Fanout) Acquire() (chan *types.VmResponse, error)

func (*Fanout) Close 

func (fo *Fanout) Close()

func (*Fanout) Release 

func (fo *Fanout) Release(client chan *types.VmResponse) error

type GuestNicInfo 

type GuestNicInfo struct {
	Device  string
	Ipaddr  string
	Index   int
	Busaddr int
}

type HostNicInfo 

type HostNicInfo struct {
	Id      string
	Device  string
	Mac     string
	Bridge  string
	Gateway string
	Options string
}

type HypervisorDriver 

type HypervisorDriver interface {
	Name() string
	InitContext(homeDir string) DriverContext

	LoadContext(persisted map[string]interface{}) (DriverContext, error)

	SupportLazyMode() bool
	SupportVmSocket() bool
}
var HDriver HypervisorDriver

type InitFailedEvent 

type InitFailedEvent struct {
	Reason string
}

func (*InitFailedEvent) Event 

func (qe *InitFailedEvent) Event() int

type InterfaceCreated 

type InterfaceCreated struct {
	Id         string //user specified in (ref api.InterfaceDescription: a user identifier of interface, user may use this to specify a nic, normally you can use IPAddr as an Id.)
	Index      int
	PCIAddr    int
	TapFd      int
	Bridge     string
	HostDevice string
	DeviceName string
	MacAddr    string
	IpAddr     string
	NewName    string
	Mtu        uint64
	RouteTable []*RouteRule
}

func (*InterfaceCreated) Event 

func (qe *InterfaceCreated) Event() int

type Interrupted 

type Interrupted struct {
	Reason string
}

func (*Interrupted) Event 

func (qe *Interrupted) Event() int

type LazyDriverContext 

type LazyDriverContext interface {
	DriverContext

	LazyLaunch(ctx *VmContext)
	InitVM(ctx *VmContext) error
	LazyAddDisk(ctx *VmContext, name, sourceType, filename, format string, id int)
	LazyAddNic(ctx *VmContext, host *HostNicInfo, guest *GuestNicInfo)
}

type LogMessage 

type LogMessage struct {
	Message string
	Id      string
	Path    string
}

type NetDevInsertedEvent 

type NetDevInsertedEvent struct {
	Id         string
	Index      int
	DeviceName string
	Address    int
	TapFd      int
}

func (*NetDevInsertedEvent) Event 

func (qe *NetDevInsertedEvent) Event() int

func (*NetDevInsertedEvent) IsSuccess 

func (ne *NetDevInsertedEvent) IsSuccess() bool

func (*NetDevInsertedEvent) Message 

func (ne *NetDevInsertedEvent) Message() string

func (*NetDevInsertedEvent) ResultId 

func (ne *NetDevInsertedEvent) ResultId() string

type NetDevRemovedEvent 

type NetDevRemovedEvent struct {
	Index int
}

func (*NetDevRemovedEvent) Event 

func (qe *NetDevRemovedEvent) Event() int

type NetworkContext 

type NetworkContext struct {
	*api.SandboxConfig
	// contains filtered or unexported fields
}

func NewNetworkContext 

func NewNetworkContext() *NetworkContext

type PersistInfo 

type PersistInfo struct {
	PersistVersion int
	Id             string
	Paused         bool
	DriverInfo     map[string]interface{}
	VmSpec         *hyperstartapi.Pod
	HwStat         *VmHwStatus
	VolumeList     []*PersistVolumeInfo
	NetworkList    []*PersistNetworkInfo
	PortList       []*api.PortDescription
}

func (*PersistInfo) Log 

func (p *PersistInfo) Log(level hlog.LogLevel, args ...interface{})

func (*PersistInfo) LogLevel 

func (p *PersistInfo) LogLevel(level hlog.LogLevel) bool

func (*PersistInfo) LogPrefix 

func (p *PersistInfo) LogPrefix() string

type PersistNetworkInfo 

type PersistNetworkInfo struct {
	Id         string
	Index      int
	PciAddr    int
	HostDevice string
	DeviceName string
	NewName    string
	IpAddr     string
	Mac        string
	Mtu        uint64
}

type PersistVolumeInfo 

type PersistVolumeInfo struct {
	Name         string
	Filename     string
	Format       string
	Fstype       string
	DeviceName   string
	ScsiId       int
	ContainerIds []string
	IsRootVol    bool
	Containers   []int // deprecated
	MontPoints   []string
}

type ReleaseVMCommand 

type ReleaseVMCommand struct{}

func (*ReleaseVMCommand) Event 

func (qe *ReleaseVMCommand) Event() int

type RouteRule 

type RouteRule struct {
	Destination string
	Gateway     string
	ViaThis     bool
}

type ShutdownCommand 

type ShutdownCommand struct {
	Wait bool
}

func (*ShutdownCommand) Event 

func (qe *ShutdownCommand) Event() int

type TtyIO 

type TtyIO struct {
	Stdin  io.ReadCloser
	Stdout io.Writer
	Stderr io.Writer
}

TODO move this logic to hyperd

func (*TtyIO) Close 

func (tty *TtyIO) Close()

type Vm 

type Vm struct {
	Id string

	Cpu  int
	Mem  int
	Lazy bool
	// contains filtered or unexported fields
}

func AssociateVm 

func AssociateVm(vmId string, data []byte) (*Vm, error)

This function will only be invoked during daemon start

func GetVm 

func GetVm(vmId string, b *BootConfig, waitStarted bool) (*Vm, error)

func (*Vm) AddContainer 

func (vm *Vm) AddContainer(c *api.ContainerDescription) api.Result

func (*Vm) AddMem 

func (vm *Vm) AddMem(totalMem int) error

func (*Vm) AddNic 

func (vm *Vm) AddNic(info *api.InterfaceDescription) error

func (*Vm) AddProcess 

func (vm *Vm) AddProcess(process *api.Process, tty *TtyIO) error

func (*Vm) AddRoute 

func (vm *Vm) AddRoute() error

func (*Vm) AddVolume 

func (vm *Vm) AddVolume(vol *api.VolumeDescription) api.Result

func (*Vm) AllNics 

func (vm *Vm) AllNics() []*InterfaceCreated

func (*Vm) AssociateContainer 

func (vm *Vm) AssociateContainer(container string) (alive bool, err error)

Should only be called near after AssociateVm

func (*Vm) Attach 

func (vm *Vm) Attach(tty *TtyIO, container string) error

func (*Vm) ContainerList 

func (vm *Vm) ContainerList() []string

func (*Vm) DeleteNic 

func (vm *Vm) DeleteNic(id string) error

func (*Vm) Dump 

func (vm *Vm) Dump() ([]byte, error)

func (*Vm) Exec 

func (vm *Vm) Exec(container, execId, cmd string, terminal bool, tty *TtyIO) error

func (*Vm) GetIPAddrs 

func (vm *Vm) GetIPAddrs() []string

func (*Vm) GetResponseChan 

func (vm *Vm) GetResponseChan() (chan *types.VmResponse, error)

func (*Vm) HyperstartExec 

func (vm *Vm) HyperstartExec(cmd string, tty *TtyIO) (int, error)

func (*Vm) HyperstartExecSync 

func (vm *Vm) HyperstartExecSync(cmd []string, stdin []byte) (stdout, stderr []byte, err error)

func (*Vm) InitSandbox 

func (vm *Vm) InitSandbox(config *api.SandboxConfig) error

func (*Vm) Kill 

func (vm *Vm) Kill()

TODO: should we provide a method to force kill vm

func (*Vm) KillContainer 

func (vm *Vm) KillContainer(container string, signal syscall.Signal) error

func (*Vm) Log 

func (v *Vm) Log(level hlog.LogLevel, args ...interface{})

func (*Vm) LogLevel 

func (v *Vm) LogLevel(level hlog.LogLevel) bool

func (*Vm) LogPrefix 

func (v *Vm) LogPrefix() string

func (*Vm) OnlineCpuMem 

func (vm *Vm) OnlineCpuMem() error

func (*Vm) Pause 

func (vm *Vm) Pause(pause bool) error

func (*Vm) ReadFile 

func (vm *Vm) ReadFile(container, target string) ([]byte, error)

func (*Vm) ReleaseResponseChan 

func (vm *Vm) ReleaseResponseChan(ch chan *types.VmResponse)

func (*Vm) ReleaseVm 

func (vm *Vm) ReleaseVm() error

func (*Vm) RemoveContainer 

func (vm *Vm) RemoveContainer(id string) api.Result

func (*Vm) RemoveContainers 

func (vm *Vm) RemoveContainers(ids ...string) (bool, map[string]api.Result)

func (*Vm) RemoveVolume 

func (vm *Vm) RemoveVolume(name string) api.Result

func (*Vm) RemoveVolumes 

func (vm *Vm) RemoveVolumes(names ...string) (bool, map[string]api.Result)

func (*Vm) Save 

func (vm *Vm) Save(path string) error

func (*Vm) SetCpus 

func (vm *Vm) SetCpus(cpus int) error

func (*Vm) Shutdown 

func (vm *Vm) Shutdown() api.Result

func (*Vm) SignalProcess 

func (vm *Vm) SignalProcess(container, process string, signal syscall.Signal) error

func (*Vm) StartContainer 

func (vm *Vm) StartContainer(id string) error

func (*Vm) Stats 

func (vm *Vm) Stats() *types.PodStats

func (*Vm) Tty 

func (vm *Vm) Tty(containerId, execId string, row, column int) error

func (*Vm) UpdateNic 

func (vm *Vm) UpdateNic(inf *api.InterfaceDescription) error

func (*Vm) WaitInit 

func (vm *Vm) WaitInit() api.Result

func (*Vm) WaitProcess 

func (vm *Vm) WaitProcess(isContainer bool, ids []string, timeout int) <-chan *api.ProcessExit

func (*Vm) WaitResponse 

func (vm *Vm) WaitResponse(match matchResponse, timeout int) chan error

func (*Vm) WaitVm 

func (vm *Vm) WaitVm(timeout int) <-chan error

func (*Vm) WriteFile 

func (vm *Vm) WriteFile(container, target string, data []byte) error

type VmContext 

type VmContext struct {
	Id string

	PauseState int
	Boot       *BootConfig

	// Communication Context
	Hub chan VmEvent

	DCtx DriverContext

	HomeDir         string
	HyperSockName   string
	TtySockName     string
	ConsoleSockName string
	ShareDir        string
	GuestCid        uint32
	// contains filtered or unexported fields
}

func InitContext 

func InitContext(id string, hub chan VmEvent, client chan *types.VmResponse, dc DriverContext, boot *BootConfig) (*VmContext, error)

func VmAssociate 

func VmAssociate(vmId string, hub chan VmEvent, client chan *types.VmResponse, pack []byte) (*VmContext, error)

func (*VmContext) AddContainer 

func (ctx *VmContext) AddContainer(c *api.ContainerDescription, result chan api.Result)

func (*VmContext) AddInterface 

func (ctx *VmContext) AddInterface(inf *api.InterfaceDescription, result chan api.Result)

func (*VmContext) AddPortmapping 

func (ctx *VmContext) AddPortmapping(ports []*api.PortDescription)

func (*VmContext) AddVolume 

func (ctx *VmContext) AddVolume(vol *api.VolumeDescription, result chan api.Result)

func (*VmContext) AllInterfaces 

func (ctx *VmContext) AllInterfaces() []*InterfaceCreated

func (*VmContext) Become 

func (ctx *VmContext) Become(handler stateHandler, desc string)

func (*VmContext) Close 

func (ctx *VmContext) Close()

func (*VmContext) IsRunning 

func (ctx *VmContext) IsRunning() bool

func (*VmContext) Launch 

func (ctx *VmContext) Launch()

func (*VmContext) Log 

func (ctx *VmContext) Log(level hlog.LogLevel, args ...interface{})

func (*VmContext) LogLevel 

func (ctx *VmContext) LogLevel(level hlog.LogLevel) bool

func (*VmContext) LogPrefix 

func (ctx *VmContext) LogPrefix() string

func (*VmContext) NextPciAddr 

func (ctx *VmContext) NextPciAddr() int

func (*VmContext) RemoveContainer 

func (ctx *VmContext) RemoveContainer(id string, result chan<- api.Result)

func (*VmContext) RemoveInterface 

func (ctx *VmContext) RemoveInterface(id string, result chan api.Result)

func (*VmContext) RemoveVolume 

func (ctx *VmContext) RemoveVolume(name string, result chan<- api.Result)

func (*VmContext) SendVmEvent 

func (ctx *VmContext) SendVmEvent(ev VmEvent) error

SendVmEvent enqueues a VmEvent onto the context. Returns an error if there is no handler associated with the context. VmEvent handling happens in a separate goroutine, so this is thread-safe and asynchronous.

func (*VmContext) SetNetworkEnvironment 

func (ctx *VmContext) SetNetworkEnvironment(net *api.SandboxConfig)

User API

func (*VmContext) UpdateInterface 

func (ctx *VmContext) UpdateInterface(inf *api.InterfaceDescription) error

func (*VmContext) WaitSockConnected 

func (ctx *VmContext) WaitSockConnected()

type VmEvent 

type VmEvent interface {
	Event() int
}

type VmExit 

type VmExit struct{}

func (*VmExit) Event 

func (qe *VmExit) Event() int

type VmHwStatus 

type VmHwStatus struct {
	PciAddr  int    //next available pci addr for pci hotplug
	ScsiId   int    //next available scsi id for scsi hotplug
	AttachId uint64 //next available attachId for attached tty
	GuestCid uint32 //vsock guest cid
}

type VmKilledEvent 

type VmKilledEvent struct {
	Success bool
}

func (*VmKilledEvent) Event 

func (qe *VmKilledEvent) Event() int

type VmStartFailEvent 

type VmStartFailEvent struct {
	Message string
}

func (*VmStartFailEvent) Event 

func (qe *VmStartFailEvent) Event() int

type VmTimeout 

type VmTimeout struct{}

func (*VmTimeout) Event 

func (qe *VmTimeout) Event() int

type VolumeInfo 

type VolumeInfo struct {
	Name         string //volumen name in spec
	Filepath     string //block dev absolute path, or dir path relative to share dir
	Fstype       string //"xfs", "ext4" etc. for block dev, or "dir" for dir path
	Format       string //"raw" (or "qcow2") for volume, no meaning for dir path
	DockerVolume bool
}

type VolumeUnmounted 

type VolumeUnmounted struct {
	Name    string
	Success bool
}

func (*VolumeUnmounted) Event 

func (qe *VolumeUnmounted) Event() int

Source Files

View all Source files

Directories

Path Synopsis
ipallocator

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.