guestman

package
v0.0.0-...-6410feb Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	VNC_PORT_BASE           = 5900
	GUEST_RUNNING           = compute.VM_RUNNING
	GUEST_BLOCK_STREAM      = compute.VM_BLOCK_STREAM
	GUEST_BLOCK_STREAM_FAIL = compute.VM_BLOCK_STREAM_FAIL
	GUEST_SUSPEND           = compute.VM_SUSPEND
	GUSET_STOPPED           = "stopped"
	GUEST_NOT_FOUND         = "notfound"
)
View Source 
const (
	STATE_FILE_PREFIX             = "STATEFILE"
	MONITOR_PORT_BASE             = 55900
	QMP_MONITOR_PORT_BASE         = 56100
	LIVE_MIGRATE_PORT_BASE        = 4396
	BUILT_IN_NBD_SERVER_PORT_BASE = 7777
	MAX_TRY                       = 3
)
View Source 
const (
	OS_NAME_LINUX   = qemu.OS_NAME_LINUX
	OS_NAME_WINDOWS = qemu.OS_NAME_WINDOWS
	OS_NAME_MACOS   = qemu.OS_NAME_MACOS
	OS_NAME_ANDROID = qemu.OS_NAME_ANDROID
	OS_NAME_VMWARE  = qemu.OS_NAME_VMWARE
	OS_NAME_CIRROS  = qemu.OS_NAME_CIRROS
	OS_NAME_OPENWRT = qemu.OS_NAME_OPENWRT

	MODE_READLINE = qemu.MODE_READLINE
	MODE_CONTROL  = qemu.MODE_CONTROL

	DISK_DRIVER_VIRTIO = qemu.DISK_DRIVER_VIRTIO
	DISK_DRIVER_SCSI   = qemu.DISK_DRIVER_SCSI
	DISK_DRIVER_PVSCSI = qemu.DISK_DRIVER_PVSCSI
	DISK_DRIVER_IDE    = qemu.DISK_DRIVER_IDE
	DISK_DRIVER_SATA   = qemu.DISK_DRIVER_SATA
)

Variables

View Source 
var (
	LAST_USED_PORT            = 0
	LAST_USED_NBD_SERVER_PORT = 0
	LAST_USED_MIGRATE_PORT    = 0
	NbdWorker                 *appsrv.SWorkerManager
)

Functions

func DeleteHomeDir 

func DeleteHomeDir(s GuestRuntimeInstance) error

func GetMemorySnapshotPath 

func GetMemorySnapshotPath(serverId, instanceSnapshotId string) string

func GetPowerStates 

func GetPowerStates(s GuestRuntimeInstance) string

func Init 

func Init(host hostutils.IHost, serversPath string, workerCnt int) error

func IsMacInGuestConfig 

func IsMacInGuestConfig(guestConfig *compute.SImportGuestDesc, mac string) bool

func LoadDesc 

func LoadDesc(s GuestRuntimeInstance) error

func LoadGuestCpuset 

func LoadGuestCpuset(m *SGuestManager, s GuestRuntimeInstance) error

func PrepareDir 

func PrepareDir(s GuestRuntimeInstance) error

func ReleaseCpuNumaPin 

func ReleaseCpuNumaPin(m *SGuestManager, cpuNumaPin []*desc.SCpuNumaPin)

func ReleaseGuestCpuset 

func ReleaseGuestCpuset(m *SGuestManager, s GuestRuntimeInstance)

func SaveDesc 

func SaveDesc(s GuestRuntimeInstance, guestDesc *desc.SGuestDesc) error

func SaveLiveDesc 

func SaveLiveDesc(s GuestRuntimeInstance, guestDesc *desc.SGuestDesc) error

func Stop 

func Stop()

func SyncGuestNicsTraffics 

func SyncGuestNicsTraffics(guestNicsTraffics map[string]map[string]compute.SNicTrafficRecord)

Types

type CPUDie 

type CPUDie struct {
	CpuFree           map[int]int
	LogicalProcessors cpuset.CPUSet
	VcpuCount         int
}

type CancelBlockReplication 

type CancelBlockReplication struct {
	SCancelBlockJobs
}

func NewCancelBlockReplicationTask 

func NewCancelBlockReplicationTask(ctx context.Context, guest *SKVMGuestInstance) *CancelBlockReplication

func (CancelBlockReplication) GetDesc 

func (s CancelBlockReplication) GetDesc() *desc.SGuestDesc

func (CancelBlockReplication) GetDescFilePath 

func (s CancelBlockReplication) GetDescFilePath() string

func (CancelBlockReplication) GetHypervisor 

func (s CancelBlockReplication) GetHypervisor() string

func (CancelBlockReplication) GetId 

func (s CancelBlockReplication) GetId() string

func (CancelBlockReplication) GetInitialId 

func (s CancelBlockReplication) GetInitialId() string

func (CancelBlockReplication) GetName 

func (s CancelBlockReplication) GetName() string

func (CancelBlockReplication) GetNicDescMatch 

func (s CancelBlockReplication) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (CancelBlockReplication) GetSourceDesc 

func (s CancelBlockReplication) GetSourceDesc() *desc.SGuestDesc

func (CancelBlockReplication) GetSourceDescFilePath 

func (s CancelBlockReplication) GetSourceDescFilePath() string

func (CancelBlockReplication) GetVpcNIC 

func (s CancelBlockReplication) GetVpcNIC() *desc.SGuestNetwork

func (CancelBlockReplication) HomeDir 

func (b CancelBlockReplication) HomeDir() string

func (CancelBlockReplication) IsDaemon 

func (s CancelBlockReplication) IsDaemon() bool

func (CancelBlockReplication) IsLoaded 

func (s CancelBlockReplication) IsLoaded() bool

func (CancelBlockReplication) IsValid 

func (s CancelBlockReplication) IsValid() bool

func (CancelBlockReplication) NicTrafficRecordPath 

func (s CancelBlockReplication) NicTrafficRecordPath() string

func (CancelBlockReplication) SetDesc 

func (s CancelBlockReplication) SetDesc(guestDesc *desc.SGuestDesc)

func (CancelBlockReplication) SetSourceDesc 

func (s CancelBlockReplication) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*CancelBlockReplication) Start 

func (task *CancelBlockReplication) Start()

type CpuSetCounter 

type CpuSetCounter struct {
	Nodes       []*NumaNode
	NumaEnabled bool
	Lock        sync.Mutex
}

func NewGuestCpuSetCounter 

func NewGuestCpuSetCounter(info *hostapi.HostTopology, reservedCpus *cpuset.CPUSet, numaAllocate bool, hugepageSizeKB, cpuCmtbound int) (*CpuSetCounter, error)

func (*CpuSetCounter) AllocCpuset 

func (pq *CpuSetCounter) AllocCpuset(vcpuCount int, memSizeKB int64, perferNumaNode int8) (map[int]SAllocNumaCpus, error)

func (*CpuSetCounter) AllocCpusetWithNodeCount 

func (pq *CpuSetCounter) AllocCpusetWithNodeCount(vcpuCount int, memSizeKB int64, nodeCount int) (map[int]SAllocNumaCpus, error)

func (*CpuSetCounter) AllocNumaNodes 

func (pq *CpuSetCounter) AllocNumaNodes(vcpuCount int, memSizeKB int64, perferNumaNode int8, res map[int]SAllocNumaCpus) error

func (*CpuSetCounter) IsNumaEnabled 

func (pq *CpuSetCounter) IsNumaEnabled() bool

func (CpuSetCounter) Len 

func (pq CpuSetCounter) Len() int

func (CpuSetCounter) Less 

func (pq CpuSetCounter) Less(i, j int) bool

func (*CpuSetCounter) LoadCpus 

func (pq *CpuSetCounter) LoadCpus(cpus []int, vcpuCpunt int)

func (*CpuSetCounter) LoadNumaCpus 

func (pq *CpuSetCounter) LoadNumaCpus(memSizeMb int64, hostNode int, cpus []int, vcpuCount int)

func (*CpuSetCounter) Pop 

func (pq *CpuSetCounter) Pop() interface{}

func (*CpuSetCounter) Push 

func (pq *CpuSetCounter) Push(item interface{})

func (*CpuSetCounter) ReleaseCpus 

func (pq *CpuSetCounter) ReleaseCpus(cpus []int, vcpuCount int)

func (*CpuSetCounter) ReleaseNumaCpus 

func (pq *CpuSetCounter) ReleaseNumaCpus(memSizeMb int64, hostNode int, cpus []int, vcpuCount int)

func (CpuSetCounter) Swap 

func (pq CpuSetCounter) Swap(i, j int)

type GuestRuntimeInstance 

type GuestRuntimeInstance interface {
	GetHypervisor() string
	GetName() string
	GetInitialId() string
	GetId() string
	IsValid() bool
	HomeDir() string
	GetDesc() *desc.SGuestDesc
	SetDesc(guestDesc *desc.SGuestDesc)
	GetSourceDesc() *desc.SGuestDesc
	SetSourceDesc(guestDesc *desc.SGuestDesc)
	GetDescFilePath() string
	NicTrafficRecordPath() string
	DeployFs(ctx context.Context, userCred mcclient.TokenCredential, deployInfo *deployapi.DeployInfo) (jsonutils.JSONObject, error)
	GetSourceDescFilePath() string
	IsRunning() bool
	IsStopped() bool
	IsSuspend() bool
	IsLoaded() bool
	GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork
	CleanGuest(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)
	CleanDirtyGuest(ctx context.Context) error
	ImportServer(pendingDelete bool)
	ExitCleanup(bool)

	HandleGuestStatus(ctx context.Context, status string, body *jsonutils.JSONDict) (jsonutils.JSONObject, error)
	HandleGuestStart(ctx context.Context, userCred mcclient.TokenCredential, body jsonutils.JSONObject) (jsonutils.JSONObject, error)

	HandleStop(ctx context.Context, timeout int64) error

	LoadDesc() error
	PostLoad(m *SGuestManager) error
	SyncConfig(ctx context.Context, guestDesc *desc.SGuestDesc, fwOnly bool) (jsonutils.JSONObject, error)
	DoSnapshot(ctx context.Context, params *SDiskSnapshot) (jsonutils.JSONObject, error)
	DeleteSnapshot(ctx context.Context, params *SDeleteDiskSnapshot) (jsonutils.JSONObject, error)
}

type GuestRuntimeManager 

type GuestRuntimeManager struct {
}

func NewGuestRuntimeManager 

func NewGuestRuntimeManager() *GuestRuntimeManager

func (*GuestRuntimeManager) CreateFromDesc 

func (f *GuestRuntimeManager) CreateFromDesc(s GuestRuntimeInstance, desc *desc.SGuestDesc) error

func (*GuestRuntimeManager) NewRuntimeInstance 

func (f *GuestRuntimeManager) NewRuntimeInstance(id string, manager *SGuestManager, hypervisor string) GuestRuntimeInstance

type IGuestBlockProgressTask 

type IGuestBlockProgressTask interface {
	OnGetBlockJobs(jobs []monitor.BlockJob)
	StreamingDiskCompletedCount() int
	StreamingDiskCount() int
}

type IGuestTasks 

type IGuestTasks interface {
	Start(func(...error))
}

type IPortMappingManager 

type IPortMappingManager interface {
	AllocateGuestPortMappings(ctx context.Context, userCred mcclient.TokenCredential, guest GuestRuntimeInstance) error
}

func NewPortMappingManager 

func NewPortMappingManager(manager *SGuestManager) IPortMappingManager

type NumaNode 

type NumaNode struct {
	CpuDies           SorttedCPUDie
	LogicalProcessors cpuset.CPUSet
	VcpuCount         int
	CpuCount          int

	NodeId                int
	NumaHugeMemSizeKB     int64
	NumaHugeFreeMemSizeKB int64
}

func NewNumaNode 

func NewNumaNode(nodeId int, numaAllocate bool, hugepageSizeKB int) (*NumaNode, error)

func (*NumaNode) AllocCpuset 

func (n *NumaNode) AllocCpuset(vcpuCount int) []int

func (*NumaNode) AllocCpuset1 

func (n *NumaNode) AllocCpuset1(vcpuCount int) []int

type PodInstance 

type PodInstance interface {
	GuestRuntimeInstance

	CreateContainer(ctx context.Context, userCred mcclient.TokenCredential, id string, input *hostapi.ContainerCreateInput) (jsonutils.JSONObject, error)
	StartContainer(ctx context.Context, userCred mcclient.TokenCredential, ctrId string, input *hostapi.ContainerCreateInput) (jsonutils.JSONObject, error)
	DeleteContainer(ctx context.Context, cred mcclient.TokenCredential, id string) (jsonutils.JSONObject, error)
	SyncContainerStatus(ctx context.Context, cred mcclient.TokenCredential, ctrId string) (jsonutils.JSONObject, error)
	StopContainer(ctx context.Context, userCred mcclient.TokenCredential, ctrId string, body jsonutils.JSONObject) (jsonutils.JSONObject, error)
	PullImage(ctx context.Context, userCred mcclient.TokenCredential, ctrId string, input *hostapi.ContainerPullImageInput) (jsonutils.JSONObject, error)
	SaveVolumeMountToImage(ctx context.Context, userCred mcclient.TokenCredential, input *hostapi.ContainerSaveVolumeMountToImageInput, ctrId string) (jsonutils.JSONObject, error)
	ExecContainer(ctx context.Context, userCred mcclient.TokenCredential, ctrId string, input *computeapi.ContainerExecInput) (*url.URL, error)
	ContainerExecSync(ctx context.Context, userCred mcclient.TokenCredential, ctrId string, input *computeapi.ContainerExecSyncInput) (jsonutils.JSONObject, error)
	SetContainerResourceLimit(ctrId string, limit *apis.ContainerResources) (jsonutils.JSONObject, error)

	ReadLogs(ctx context.Context, userCred mcclient.TokenCredential, ctrId string, input *computeapi.PodLogOptions, stdout, stderr io.Writer) error
}

type SAllocNumaCpus 

type SAllocNumaCpus struct {
	Cpuset    []int
	MemSizeKB int64

	Unregular bool
}

type SBackupDiskConfig 

type SBackupDiskConfig struct {
	compute.DiskConfig
	Name        string                        `json:"name"`
	BackupAsTar *compute.DiskBackupAsTarInput `json:"backup_as_tar"`
}

type SBaseParams 

type SBaseParams struct {
	Sid  string
	Body jsonutils.JSONObject
}

type SCancelBlockJobs 

type SCancelBlockJobs struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewCancelBlockJobsTask 

func NewCancelBlockJobsTask(ctx context.Context, guest *SKVMGuestInstance) *SCancelBlockJobs

func (SCancelBlockJobs) GetDesc 

func (s SCancelBlockJobs) GetDesc() *desc.SGuestDesc

func (SCancelBlockJobs) GetDescFilePath 

func (s SCancelBlockJobs) GetDescFilePath() string

func (SCancelBlockJobs) GetHypervisor 

func (s SCancelBlockJobs) GetHypervisor() string

func (SCancelBlockJobs) GetId 

func (s SCancelBlockJobs) GetId() string

func (SCancelBlockJobs) GetInitialId 

func (s SCancelBlockJobs) GetInitialId() string

func (SCancelBlockJobs) GetName 

func (s SCancelBlockJobs) GetName() string

func (SCancelBlockJobs) GetNicDescMatch 

func (s SCancelBlockJobs) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SCancelBlockJobs) GetSourceDesc 

func (s SCancelBlockJobs) GetSourceDesc() *desc.SGuestDesc

func (SCancelBlockJobs) GetSourceDescFilePath 

func (s SCancelBlockJobs) GetSourceDescFilePath() string

func (SCancelBlockJobs) GetVpcNIC 

func (s SCancelBlockJobs) GetVpcNIC() *desc.SGuestNetwork

func (SCancelBlockJobs) HomeDir 

func (b SCancelBlockJobs) HomeDir() string

func (SCancelBlockJobs) IsDaemon 

func (s SCancelBlockJobs) IsDaemon() bool

func (SCancelBlockJobs) IsLoaded 

func (s SCancelBlockJobs) IsLoaded() bool

func (SCancelBlockJobs) IsValid 

func (s SCancelBlockJobs) IsValid() bool

func (SCancelBlockJobs) NicTrafficRecordPath 

func (s SCancelBlockJobs) NicTrafficRecordPath() string

func (SCancelBlockJobs) SetDesc 

func (s SCancelBlockJobs) SetDesc(guestDesc *desc.SGuestDesc)

func (SCancelBlockJobs) SetSourceDesc 

func (s SCancelBlockJobs) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SCancelBlockJobs) Start 

func (task *SCancelBlockJobs) Start()

func (*SCancelBlockJobs) StartCancelBlockJobs 

func (task *SCancelBlockJobs) StartCancelBlockJobs(drivers []string)

type SCloudpodsAccessInfo 

type SCloudpodsAccessInfo struct {
	HostIp        string
	OriginDisksId []string
}

type SDeleteDiskSnapshot 

type SDeleteDiskSnapshot struct {
	Sid             string
	DeleteSnapshot  string
	Disk            storageman.IDisk
	ConvertSnapshot string
	BlockStream     bool
}

type SDestPrepareMigrate 

type SDestPrepareMigrate struct {
	Sid          string
	ServerUrl    string
	QemuVersion  string
	MigrateCerts map[string]string
	EnableTLS    bool
	SnapshotsUri string
	DisksUri     string
	// TargetStorageId string
	TargetStorageIds []string
	LiveMigrate      bool
	RebaseDisks      bool

	Desc               *desc.SGuestDesc
	SrcDesc            *desc.SGuestDesc
	DisksBackingFile   jsonutils.JSONObject
	DiskSnapsChain     jsonutils.JSONObject
	OutChainSnaps      jsonutils.JSONObject
	SysDiskHasTemplate bool

	MemorySnapshotsUri string
	SrcMemorySnapshots []string

	UserCred mcclient.TokenCredential
}

type SDiskBackup 

type SDiskBackup struct {
	Sid        string
	SnapshotId string
	BackupId   string
	Disk       storageman.IDisk
}

type SDiskSnapshot 

type SDiskSnapshot struct {
	UserCred         mcclient.TokenCredential
	Sid              string
	SnapshotId       string
	BackupDiskConfig *SBackupDiskConfig
	Disk             storageman.IDisk
}

type SDriveBackupTask 

type SDriveBackupTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewDriveBackupTask 

func NewDriveBackupTask(
	ctx context.Context, s *SKVMGuestInstance, nbdUri, syncMode string, onSucc func(),
) *SDriveBackupTask

func (SDriveBackupTask) GetDesc 

func (s SDriveBackupTask) GetDesc() *desc.SGuestDesc

func (SDriveBackupTask) GetDescFilePath 

func (s SDriveBackupTask) GetDescFilePath() string

func (SDriveBackupTask) GetHypervisor 

func (s SDriveBackupTask) GetHypervisor() string

func (SDriveBackupTask) GetId 

func (s SDriveBackupTask) GetId() string

func (SDriveBackupTask) GetInitialId 

func (s SDriveBackupTask) GetInitialId() string

func (SDriveBackupTask) GetName 

func (s SDriveBackupTask) GetName() string

func (SDriveBackupTask) GetNicDescMatch 

func (s SDriveBackupTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SDriveBackupTask) GetSourceDesc 

func (s SDriveBackupTask) GetSourceDesc() *desc.SGuestDesc

func (SDriveBackupTask) GetSourceDescFilePath 

func (s SDriveBackupTask) GetSourceDescFilePath() string

func (SDriveBackupTask) GetVpcNIC 

func (s SDriveBackupTask) GetVpcNIC() *desc.SGuestNetwork

func (SDriveBackupTask) HomeDir 

func (b SDriveBackupTask) HomeDir() string

func (SDriveBackupTask) IsDaemon 

func (s SDriveBackupTask) IsDaemon() bool

func (SDriveBackupTask) IsLoaded 

func (s SDriveBackupTask) IsLoaded() bool

func (SDriveBackupTask) IsValid 

func (s SDriveBackupTask) IsValid() bool

func (SDriveBackupTask) NicTrafficRecordPath 

func (s SDriveBackupTask) NicTrafficRecordPath() string

func (SDriveBackupTask) SetDesc 

func (s SDriveBackupTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SDriveBackupTask) SetSourceDesc 

func (s SDriveBackupTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SDriveBackupTask) Start 

func (s *SDriveBackupTask) Start()

type SDriveMirrorTask 

type SDriveMirrorTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewDriveMirrorTask 

func NewDriveMirrorTask(
	ctx context.Context, s *SKVMGuestInstance, nbdUri, syncMode string,
	blockReplication bool, onSucc func(),
) *SDriveMirrorTask

func (SDriveMirrorTask) GetDesc 

func (s SDriveMirrorTask) GetDesc() *desc.SGuestDesc

func (SDriveMirrorTask) GetDescFilePath 

func (s SDriveMirrorTask) GetDescFilePath() string

func (SDriveMirrorTask) GetHypervisor 

func (s SDriveMirrorTask) GetHypervisor() string

func (SDriveMirrorTask) GetId 

func (s SDriveMirrorTask) GetId() string

func (SDriveMirrorTask) GetInitialId 

func (s SDriveMirrorTask) GetInitialId() string

func (SDriveMirrorTask) GetName 

func (s SDriveMirrorTask) GetName() string

func (SDriveMirrorTask) GetNicDescMatch 

func (s SDriveMirrorTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SDriveMirrorTask) GetSourceDesc 

func (s SDriveMirrorTask) GetSourceDesc() *desc.SGuestDesc

func (SDriveMirrorTask) GetSourceDescFilePath 

func (s SDriveMirrorTask) GetSourceDescFilePath() string

func (SDriveMirrorTask) GetVpcNIC 

func (s SDriveMirrorTask) GetVpcNIC() *desc.SGuestNetwork

func (SDriveMirrorTask) HomeDir 

func (b SDriveMirrorTask) HomeDir() string

func (SDriveMirrorTask) IsDaemon 

func (s SDriveMirrorTask) IsDaemon() bool

func (SDriveMirrorTask) IsLoaded 

func (s SDriveMirrorTask) IsLoaded() bool

func (SDriveMirrorTask) IsValid 

func (s SDriveMirrorTask) IsValid() bool

func (SDriveMirrorTask) NicTrafficRecordPath 

func (s SDriveMirrorTask) NicTrafficRecordPath() string

func (SDriveMirrorTask) SetDesc 

func (s SDriveMirrorTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SDriveMirrorTask) SetSourceDesc 

func (s SDriveMirrorTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SDriveMirrorTask) Start 

func (s *SDriveMirrorTask) Start()

type SDriverMirror 

type SDriverMirror struct {
	Sid          string
	NbdServerUri string
	Desc         *desc.SGuestDesc
}

type SEsxiAccessInfo 

type SEsxiAccessInfo struct {
	Datastore  vcenter.SVCenterAccessInfo
	HostIp     string
	GuestExtId string
}

type SGuestBlockIoThrottleTask 

type SGuestBlockIoThrottleTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func (SGuestBlockIoThrottleTask) GetDesc 

func (s SGuestBlockIoThrottleTask) GetDesc() *desc.SGuestDesc

func (SGuestBlockIoThrottleTask) GetDescFilePath 

func (s SGuestBlockIoThrottleTask) GetDescFilePath() string

func (SGuestBlockIoThrottleTask) GetHypervisor 

func (s SGuestBlockIoThrottleTask) GetHypervisor() string

func (SGuestBlockIoThrottleTask) GetId 

func (s SGuestBlockIoThrottleTask) GetId() string

func (SGuestBlockIoThrottleTask) GetInitialId 

func (s SGuestBlockIoThrottleTask) GetInitialId() string

func (SGuestBlockIoThrottleTask) GetName 

func (s SGuestBlockIoThrottleTask) GetName() string

func (SGuestBlockIoThrottleTask) GetNicDescMatch 

func (s SGuestBlockIoThrottleTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestBlockIoThrottleTask) GetSourceDesc 

func (s SGuestBlockIoThrottleTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestBlockIoThrottleTask) GetSourceDescFilePath 

func (s SGuestBlockIoThrottleTask) GetSourceDescFilePath() string

func (SGuestBlockIoThrottleTask) GetVpcNIC 

func (s SGuestBlockIoThrottleTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestBlockIoThrottleTask) HomeDir 

func (b SGuestBlockIoThrottleTask) HomeDir() string

func (SGuestBlockIoThrottleTask) IsDaemon 

func (s SGuestBlockIoThrottleTask) IsDaemon() bool

func (SGuestBlockIoThrottleTask) IsLoaded 

func (s SGuestBlockIoThrottleTask) IsLoaded() bool

func (SGuestBlockIoThrottleTask) IsValid 

func (s SGuestBlockIoThrottleTask) IsValid() bool

func (SGuestBlockIoThrottleTask) NicTrafficRecordPath 

func (s SGuestBlockIoThrottleTask) NicTrafficRecordPath() string

func (SGuestBlockIoThrottleTask) SetDesc 

func (s SGuestBlockIoThrottleTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestBlockIoThrottleTask) SetSourceDesc 

func (s SGuestBlockIoThrottleTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestBlockIoThrottleTask) Start 

func (task *SGuestBlockIoThrottleTask) Start()

type SGuestBlockProgressBaseTask 

type SGuestBlockProgressBaseTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestBlockProgressBaseTask 

func NewGuestBlockProgressBaseTask(
	ctx context.Context, guest *SKVMGuestInstance, blkTask IGuestBlockProgressTask,
) *SGuestBlockProgressBaseTask

func (SGuestBlockProgressBaseTask) GetDesc 

func (s SGuestBlockProgressBaseTask) GetDesc() *desc.SGuestDesc

func (SGuestBlockProgressBaseTask) GetDescFilePath 

func (s SGuestBlockProgressBaseTask) GetDescFilePath() string

func (SGuestBlockProgressBaseTask) GetHypervisor 

func (s SGuestBlockProgressBaseTask) GetHypervisor() string

func (SGuestBlockProgressBaseTask) GetId 

func (s SGuestBlockProgressBaseTask) GetId() string

func (SGuestBlockProgressBaseTask) GetInitialId 

func (s SGuestBlockProgressBaseTask) GetInitialId() string

func (SGuestBlockProgressBaseTask) GetName 

func (s SGuestBlockProgressBaseTask) GetName() string

func (SGuestBlockProgressBaseTask) GetNicDescMatch 

func (s SGuestBlockProgressBaseTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestBlockProgressBaseTask) GetSourceDesc 

func (s SGuestBlockProgressBaseTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestBlockProgressBaseTask) GetSourceDescFilePath 

func (s SGuestBlockProgressBaseTask) GetSourceDescFilePath() string

func (SGuestBlockProgressBaseTask) GetVpcNIC 

func (s SGuestBlockProgressBaseTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestBlockProgressBaseTask) HomeDir 

func (b SGuestBlockProgressBaseTask) HomeDir() string

func (SGuestBlockProgressBaseTask) IsDaemon 

func (s SGuestBlockProgressBaseTask) IsDaemon() bool

func (SGuestBlockProgressBaseTask) IsLoaded 

func (s SGuestBlockProgressBaseTask) IsLoaded() bool

func (SGuestBlockProgressBaseTask) IsValid 

func (s SGuestBlockProgressBaseTask) IsValid() bool

func (SGuestBlockProgressBaseTask) NicTrafficRecordPath 

func (s SGuestBlockProgressBaseTask) NicTrafficRecordPath() string

func (SGuestBlockProgressBaseTask) SetDesc 

func (s SGuestBlockProgressBaseTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestBlockProgressBaseTask) SetSourceDesc 

func (s SGuestBlockProgressBaseTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

type SGuestBlockReplicationTask 

type SGuestBlockReplicationTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestBlockReplicationTask 

func NewGuestBlockReplicationTask(
	ctx context.Context, s *SKVMGuestInstance,
	nbdHost, nbdPort, syncMode string, onSucc func(), onFail func(string),
) *SGuestBlockReplicationTask

func (SGuestBlockReplicationTask) GetDesc 

func (s SGuestBlockReplicationTask) GetDesc() *desc.SGuestDesc

func (SGuestBlockReplicationTask) GetDescFilePath 

func (s SGuestBlockReplicationTask) GetDescFilePath() string

func (SGuestBlockReplicationTask) GetHypervisor 

func (s SGuestBlockReplicationTask) GetHypervisor() string

func (SGuestBlockReplicationTask) GetId 

func (s SGuestBlockReplicationTask) GetId() string

func (SGuestBlockReplicationTask) GetInitialId 

func (s SGuestBlockReplicationTask) GetInitialId() string

func (SGuestBlockReplicationTask) GetName 

func (s SGuestBlockReplicationTask) GetName() string

func (SGuestBlockReplicationTask) GetNicDescMatch 

func (s SGuestBlockReplicationTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestBlockReplicationTask) GetSourceDesc 

func (s SGuestBlockReplicationTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestBlockReplicationTask) GetSourceDescFilePath 

func (s SGuestBlockReplicationTask) GetSourceDescFilePath() string

func (SGuestBlockReplicationTask) GetVpcNIC 

func (s SGuestBlockReplicationTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestBlockReplicationTask) HomeDir 

func (b SGuestBlockReplicationTask) HomeDir() string

func (SGuestBlockReplicationTask) IsDaemon 

func (s SGuestBlockReplicationTask) IsDaemon() bool

func (SGuestBlockReplicationTask) IsLoaded 

func (s SGuestBlockReplicationTask) IsLoaded() bool

func (SGuestBlockReplicationTask) IsValid 

func (s SGuestBlockReplicationTask) IsValid() bool

func (SGuestBlockReplicationTask) NicTrafficRecordPath 

func (s SGuestBlockReplicationTask) NicTrafficRecordPath() string

func (SGuestBlockReplicationTask) SetDesc 

func (s SGuestBlockReplicationTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestBlockReplicationTask) SetSourceDesc 

func (s SGuestBlockReplicationTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestBlockReplicationTask) Start 

func (s *SGuestBlockReplicationTask) Start()

type SGuestCreateFromCloudpods 

type SGuestCreateFromCloudpods struct {
	Sid                 string
	GuestDesc           *desc.SGuestDesc
	CloudpodsAccessInfo SCloudpodsAccessInfo
}

type SGuestCreateFromEsxi 

type SGuestCreateFromEsxi struct {
	Sid            string
	GuestDesc      *desc.SGuestDesc
	EsxiAccessInfo SEsxiAccessInfo
}

type SGuestCreateFromLibvirt 

type SGuestCreateFromLibvirt struct {
	Sid         string
	MonitorPath string
	GuestDesc   *desc.SGuestDesc
	DisksPath   *jsonutils.JSONDict
}

type SGuestDeploy 

type SGuestDeploy struct {
	UserCred mcclient.TokenCredential

	Sid    string
	Body   jsonutils.JSONObject
	IsInit bool
}

type SGuestDiskSnapshotTask 

type SGuestDiskSnapshotTask struct {
	*SGuestReloadDiskTask
	// contains filtered or unexported fields
}

func NewGuestDiskSnapshotTask 

func NewGuestDiskSnapshotTask(
	ctx context.Context, s *SKVMGuestInstance, disk storageman.IDisk, snapshotId string,
) *SGuestDiskSnapshotTask

func (SGuestDiskSnapshotTask) GetDesc 

func (s SGuestDiskSnapshotTask) GetDesc() *desc.SGuestDesc

func (SGuestDiskSnapshotTask) GetDescFilePath 

func (s SGuestDiskSnapshotTask) GetDescFilePath() string

func (SGuestDiskSnapshotTask) GetHypervisor 

func (s SGuestDiskSnapshotTask) GetHypervisor() string

func (SGuestDiskSnapshotTask) GetId 

func (s SGuestDiskSnapshotTask) GetId() string

func (SGuestDiskSnapshotTask) GetInitialId 

func (s SGuestDiskSnapshotTask) GetInitialId() string

func (SGuestDiskSnapshotTask) GetName 

func (s SGuestDiskSnapshotTask) GetName() string

func (SGuestDiskSnapshotTask) GetNicDescMatch 

func (s SGuestDiskSnapshotTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestDiskSnapshotTask) GetSourceDesc 

func (s SGuestDiskSnapshotTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestDiskSnapshotTask) GetSourceDescFilePath 

func (s SGuestDiskSnapshotTask) GetSourceDescFilePath() string

func (SGuestDiskSnapshotTask) GetVpcNIC 

func (s SGuestDiskSnapshotTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestDiskSnapshotTask) HomeDir 

func (b SGuestDiskSnapshotTask) HomeDir() string

func (SGuestDiskSnapshotTask) IsDaemon 

func (s SGuestDiskSnapshotTask) IsDaemon() bool

func (SGuestDiskSnapshotTask) IsLoaded 

func (s SGuestDiskSnapshotTask) IsLoaded() bool

func (SGuestDiskSnapshotTask) IsValid 

func (s SGuestDiskSnapshotTask) IsValid() bool

func (SGuestDiskSnapshotTask) NicTrafficRecordPath 

func (s SGuestDiskSnapshotTask) NicTrafficRecordPath() string

func (SGuestDiskSnapshotTask) SetDesc 

func (s SGuestDiskSnapshotTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestDiskSnapshotTask) SetSourceDesc 

func (s SGuestDiskSnapshotTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestDiskSnapshotTask) Start 

func (s *SGuestDiskSnapshotTask) Start()

type SGuestDiskSyncTask 

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

func NewGuestDiskSyncTask 

func NewGuestDiskSyncTask(guest *SKVMGuestInstance, delDisks, addDisks []*desc.SGuestDisk, cdroms []*desc.SGuestCdrom, floppys []*desc.SGuestFloppy) *SGuestDiskSyncTask

func (*SGuestDiskSyncTask) OnChangeCdromContentSucc 

func (d *SGuestDiskSyncTask) OnChangeCdromContentSucc(cdrom *desc.SGuestCdrom)

func (*SGuestDiskSyncTask) OnChangeFloppyContentSucc 

func (d *SGuestDiskSyncTask) OnChangeFloppyContentSucc(floppy *desc.SGuestFloppy)

func (*SGuestDiskSyncTask) OnEjectCdromContentSucc 

func (d *SGuestDiskSyncTask) OnEjectCdromContentSucc(cdName string)

func (*SGuestDiskSyncTask) OnEjectFloppyContentSucc 

func (d *SGuestDiskSyncTask) OnEjectFloppyContentSucc(flName string)

func (*SGuestDiskSyncTask) Start 

func (d *SGuestDiskSyncTask) Start(callback func(...error))

type SGuestHotplugCpuMem 

type SGuestHotplugCpuMem struct {
	Sid         string
	AddCpuCount int64
	AddMemSize  int64

	CpuNumaPin []*desc.SCpuNumaPin
}

type SGuestHotplugCpuMemTask 

type SGuestHotplugCpuMemTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestHotplugCpuMemTask 

func NewGuestHotplugCpuMemTask(
	ctx context.Context, s *SKVMGuestInstance, addCpuCount, addMemSize int, cpuNumaPin []*desc.SCpuNumaPin,
) *SGuestHotplugCpuMemTask

func (SGuestHotplugCpuMemTask) GetDesc 

func (s SGuestHotplugCpuMemTask) GetDesc() *desc.SGuestDesc

func (SGuestHotplugCpuMemTask) GetDescFilePath 

func (s SGuestHotplugCpuMemTask) GetDescFilePath() string

func (SGuestHotplugCpuMemTask) GetHypervisor 

func (s SGuestHotplugCpuMemTask) GetHypervisor() string

func (SGuestHotplugCpuMemTask) GetId 

func (s SGuestHotplugCpuMemTask) GetId() string

func (SGuestHotplugCpuMemTask) GetInitialId 

func (s SGuestHotplugCpuMemTask) GetInitialId() string

func (SGuestHotplugCpuMemTask) GetName 

func (s SGuestHotplugCpuMemTask) GetName() string

func (SGuestHotplugCpuMemTask) GetNicDescMatch 

func (s SGuestHotplugCpuMemTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestHotplugCpuMemTask) GetSourceDesc 

func (s SGuestHotplugCpuMemTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestHotplugCpuMemTask) GetSourceDescFilePath 

func (s SGuestHotplugCpuMemTask) GetSourceDescFilePath() string

func (SGuestHotplugCpuMemTask) GetVpcNIC 

func (s SGuestHotplugCpuMemTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestHotplugCpuMemTask) HomeDir 

func (b SGuestHotplugCpuMemTask) HomeDir() string

func (SGuestHotplugCpuMemTask) IsDaemon 

func (s SGuestHotplugCpuMemTask) IsDaemon() bool

func (SGuestHotplugCpuMemTask) IsLoaded 

func (s SGuestHotplugCpuMemTask) IsLoaded() bool

func (SGuestHotplugCpuMemTask) IsValid 

func (s SGuestHotplugCpuMemTask) IsValid() bool

func (SGuestHotplugCpuMemTask) NicTrafficRecordPath 

func (s SGuestHotplugCpuMemTask) NicTrafficRecordPath() string

func (SGuestHotplugCpuMemTask) SetDesc 

func (s SGuestHotplugCpuMemTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestHotplugCpuMemTask) SetSourceDesc 

func (s SGuestHotplugCpuMemTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestHotplugCpuMemTask) Start 

func (task *SGuestHotplugCpuMemTask) Start()

First at all add cpu count, second add mem size

type SGuestIoThrottle 

type SGuestIoThrottle struct {
	Sid   string
	Input *compute.ServerSetDiskIoThrottleInput
}

type SGuestIsolatedDeviceSyncTask 

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

func NewGuestIsolatedDeviceSyncTask 

func NewGuestIsolatedDeviceSyncTask(guest *SKVMGuestInstance, delDevs, addDevs []*desc.SGuestIsolatedDevice) *SGuestIsolatedDeviceSyncTask

func (*SGuestIsolatedDeviceSyncTask) Start 

func (t *SGuestIsolatedDeviceSyncTask) Start(cb func(...error))

type SGuestLiveChangeDisk 

type SGuestLiveChangeDisk struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestLiveChangeDiskTask 

func NewGuestLiveChangeDiskTask(ctx context.Context, guest *SKVMGuestInstance, params *SStorageCloneDisk) (*SGuestLiveChangeDisk, error)

func (SGuestLiveChangeDisk) GetDesc 

func (s SGuestLiveChangeDisk) GetDesc() *desc.SGuestDesc

func (SGuestLiveChangeDisk) GetDescFilePath 

func (s SGuestLiveChangeDisk) GetDescFilePath() string

func (SGuestLiveChangeDisk) GetHypervisor 

func (s SGuestLiveChangeDisk) GetHypervisor() string

func (SGuestLiveChangeDisk) GetId 

func (s SGuestLiveChangeDisk) GetId() string

func (SGuestLiveChangeDisk) GetInitialId 

func (s SGuestLiveChangeDisk) GetInitialId() string

func (SGuestLiveChangeDisk) GetName 

func (s SGuestLiveChangeDisk) GetName() string

func (SGuestLiveChangeDisk) GetNicDescMatch 

func (s SGuestLiveChangeDisk) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestLiveChangeDisk) GetSourceDesc 

func (s SGuestLiveChangeDisk) GetSourceDesc() *desc.SGuestDesc

func (SGuestLiveChangeDisk) GetSourceDescFilePath 

func (s SGuestLiveChangeDisk) GetSourceDescFilePath() string

func (SGuestLiveChangeDisk) GetVpcNIC 

func (s SGuestLiveChangeDisk) GetVpcNIC() *desc.SGuestNetwork

func (SGuestLiveChangeDisk) HomeDir 

func (b SGuestLiveChangeDisk) HomeDir() string

func (SGuestLiveChangeDisk) IsDaemon 

func (s SGuestLiveChangeDisk) IsDaemon() bool

func (SGuestLiveChangeDisk) IsLoaded 

func (s SGuestLiveChangeDisk) IsLoaded() bool

func (SGuestLiveChangeDisk) IsValid 

func (s SGuestLiveChangeDisk) IsValid() bool

func (SGuestLiveChangeDisk) NicTrafficRecordPath 

func (s SGuestLiveChangeDisk) NicTrafficRecordPath() string

func (SGuestLiveChangeDisk) SetDesc 

func (s SGuestLiveChangeDisk) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestLiveChangeDisk) SetSourceDesc 

func (s SGuestLiveChangeDisk) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestLiveChangeDisk) Start 

func (t *SGuestLiveChangeDisk) Start()

type SGuestLiveMigrateTask 

type SGuestLiveMigrateTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestLiveMigrateTask 

func NewGuestLiveMigrateTask(
	ctx context.Context, guest *SKVMGuestInstance, params *SLiveMigrate,
) *SGuestLiveMigrateTask

func (SGuestLiveMigrateTask) GetDesc 

func (s SGuestLiveMigrateTask) GetDesc() *desc.SGuestDesc

func (SGuestLiveMigrateTask) GetDescFilePath 

func (s SGuestLiveMigrateTask) GetDescFilePath() string

func (SGuestLiveMigrateTask) GetHypervisor 

func (s SGuestLiveMigrateTask) GetHypervisor() string

func (SGuestLiveMigrateTask) GetId 

func (s SGuestLiveMigrateTask) GetId() string

func (SGuestLiveMigrateTask) GetInitialId 

func (s SGuestLiveMigrateTask) GetInitialId() string

func (SGuestLiveMigrateTask) GetName 

func (s SGuestLiveMigrateTask) GetName() string

func (SGuestLiveMigrateTask) GetNicDescMatch 

func (s SGuestLiveMigrateTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestLiveMigrateTask) GetSourceDesc 

func (s SGuestLiveMigrateTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestLiveMigrateTask) GetSourceDescFilePath 

func (s SGuestLiveMigrateTask) GetSourceDescFilePath() string

func (SGuestLiveMigrateTask) GetVpcNIC 

func (s SGuestLiveMigrateTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestLiveMigrateTask) HomeDir 

func (b SGuestLiveMigrateTask) HomeDir() string

func (SGuestLiveMigrateTask) IsDaemon 

func (s SGuestLiveMigrateTask) IsDaemon() bool

func (SGuestLiveMigrateTask) IsLoaded 

func (s SGuestLiveMigrateTask) IsLoaded() bool

func (SGuestLiveMigrateTask) IsValid 

func (s SGuestLiveMigrateTask) IsValid() bool

func (SGuestLiveMigrateTask) NicTrafficRecordPath 

func (s SGuestLiveMigrateTask) NicTrafficRecordPath() string

func (SGuestLiveMigrateTask) SetDesc 

func (s SGuestLiveMigrateTask) SetDesc(guestDesc *desc.SGuestDesc)

func (*SGuestLiveMigrateTask) SetLiveMigrateCancelled 

func (s *SGuestLiveMigrateTask) SetLiveMigrateCancelled()

func (SGuestLiveMigrateTask) SetSourceDesc 

func (s SGuestLiveMigrateTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestLiveMigrateTask) Start 

func (s *SGuestLiveMigrateTask) Start()

type SGuestManager 

type SGuestManager struct {
	ServersPath      string
	Servers          *sync.Map
	CandidateServers map[string]GuestRuntimeInstance
	UnknownServers   *sync.Map
	ServersLock      *sync.Mutex

	// guests nics traffics lock
	TrafficLock *sync.Mutex

	GuestStartWorker *appsrv.SWorkerManager
	// contains filtered or unexported fields
}

func GetGuestManager 

func GetGuestManager() *SGuestManager

func NewGuestManager 

func NewGuestManager(host hostutils.IHost, serversPath string, workerCnt int) (*SGuestManager, error)

func (*SGuestManager) Bootstrap 

func (m *SGuestManager) Bootstrap() (chan struct{}, error)

func (*SGuestManager) CPUSet 

func (m *SGuestManager) CPUSet(ctx context.Context, sid string, req *compute.ServerCPUSetInput) (*compute.ServerCPUSetResp, error)

func (*SGuestManager) CPUSetRemove 

func (m *SGuestManager) CPUSetRemove(ctx context.Context, sid string) error

func (*SGuestManager) CanMigrate 

func (m *SGuestManager) CanMigrate(sid string) bool

func (*SGuestManager) CancelBlockJobs 

func (m *SGuestManager) CancelBlockJobs(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) CancelBlockReplication 

func (m *SGuestManager) CancelBlockReplication(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) CleanServer 

func (m *SGuestManager) CleanServer(sid string)

func (*SGuestManager) ClenaupCpuset 

func (m *SGuestManager) ClenaupCpuset()

func (*SGuestManager) CloseForward 

func (m *SGuestManager) CloseForward(ctx context.Context, sid string, req *hostapi.GuestCloseForwardRequest) (*hostapi.GuestCloseForwardResponse, error)

func (*SGuestManager) CpusetBalance 

func (m *SGuestManager) CpusetBalance(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

delay cpuset balance

func (*SGuestManager) Delete 

func (m *SGuestManager) Delete(sid string) (GuestRuntimeInstance, error)

func (*SGuestManager) DeleteSnapshot 

func (m *SGuestManager) DeleteSnapshot(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) DestPrepareMigrate 

func (m *SGuestManager) DestPrepareMigrate(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) DoDeleteMemorySnapshot 

func (m *SGuestManager) DoDeleteMemorySnapshot(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) DoMemorySnapshot 

func (m *SGuestManager) DoMemorySnapshot(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) DoResetMemorySnapshot 

func (m *SGuestManager) DoResetMemorySnapshot(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) DoSnapshot 

func (m *SGuestManager) DoSnapshot(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) EnableDirtyRecoveryFeature 

func (m *SGuestManager) EnableDirtyRecoveryFeature() bool

func (*SGuestManager) ExitGuestCleanup 

func (m *SGuestManager) ExitGuestCleanup()

func (*SGuestManager) GenerateDescFromXml 

func (m *SGuestManager) GenerateDescFromXml(libvirtConfig *compute.SLibvirtHostConfig) (jsonutils.JSONObject, error)

func (*SGuestManager) GetCRI 

func (m *SGuestManager) GetCRI() pod.CRI

func (*SGuestManager) GetContainerCPUMap 

func (m *SGuestManager) GetContainerCPUMap() *pod.HostContainerCPUMap

func (*SGuestManager) GetContainerProbeManager 

func (m *SGuestManager) GetContainerProbeManager() prober.Manager

func (*SGuestManager) GetFreePortByBase 

func (m *SGuestManager) GetFreePortByBase(basePort int) int

func (*SGuestManager) GetFreeVncPort 

func (m *SGuestManager) GetFreeVncPort() int

func (*SGuestManager) GetGuestNicDesc 

func (m *SGuestManager) GetGuestNicDesc(
	mac, ip, port, bridge string, isCandidate bool,
) (*desc.SGuestDesc, *desc.SGuestNetwork)

func (*SGuestManager) GetGuestStatus 

func (m *SGuestManager) GetGuestStatus(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) GetGuestTrafficRecord 

func (m *SGuestManager) GetGuestTrafficRecord(sid string) (map[string]compute.SNicTrafficRecord, error)

func (*SGuestManager) GetHost 

func (m *SGuestManager) GetHost() hostutils.IHost

func (*SGuestManager) GetKVMServer 

func (m *SGuestManager) GetKVMServer(sid string) (*SKVMGuestInstance, bool)

临时解决方案，后面应该统一 SKVMInstance 和 SPodInstance 使用 GuestRuntimeInstance 接口

func (*SGuestManager) GetLiveMigrateFreePort 

func (m *SGuestManager) GetLiveMigrateFreePort() int

func (*SGuestManager) GetNBDServerFreePort 

func (m *SGuestManager) GetNBDServerFreePort() int

func (*SGuestManager) GetQgaRunningGuests 

func (m *SGuestManager) GetQgaRunningGuests() []string

func (*SGuestManager) GetServer 

func (m *SGuestManager) GetServer(sid string) (GuestRuntimeInstance, bool)

func (*SGuestManager) GetServerDesc 

func (m *SGuestManager) GetServerDesc(sid string) (*desc.SGuestDesc, error)

func (*SGuestManager) GetServerDescFilePath 

func (m *SGuestManager) GetServerDescFilePath(sid string) string

func (*SGuestManager) GetUnknownServer 

func (m *SGuestManager) GetUnknownServer(sid string) (GuestRuntimeInstance, bool)

func (*SGuestManager) GuestCreate 

func (m *SGuestManager) GuestCreate(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) GuestCreateFromCloudpods 

func (m *SGuestManager) GuestCreateFromCloudpods(
	ctx context.Context, params interface{},
) (jsonutils.JSONObject, error)

func (*SGuestManager) GuestCreateFromEsxi 

func (m *SGuestManager) GuestCreateFromEsxi(
	ctx context.Context, params interface{},
) (jsonutils.JSONObject, error)

func (*SGuestManager) GuestCreateFromLibvirt 

func (m *SGuestManager) GuestCreateFromLibvirt(
	ctx context.Context, params interface{},
) (jsonutils.JSONObject, error)

func (*SGuestManager) GuestDeploy 

func (m *SGuestManager) GuestDeploy(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

Delay process

func (*SGuestManager) GuestIoThrottle 

func (m *SGuestManager) GuestIoThrottle(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) GuestStart 

func (m *SGuestManager) GuestStart(ctx context.Context, userCred mcclient.TokenCredential, sid string, body jsonutils.JSONObject) (jsonutils.JSONObject, error)

func (*SGuestManager) GuestStartRescue 

func (m *SGuestManager) GuestStartRescue(ctx context.Context, userCred mcclient.TokenCredential, sid string, body jsonutils.JSONObject) (jsonutils.JSONObject, error)

func (*SGuestManager) GuestStop 

func (m *SGuestManager) GuestStop(ctx context.Context, sid string, timeout int64) error

func (*SGuestManager) GuestSuspend 

func (m *SGuestManager) GuestSuspend(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) GuestSync 

func (m *SGuestManager) GuestSync(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) HotplugCpuMem 

func (m *SGuestManager) HotplugCpuMem(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) InitPythonPath 

func (m *SGuestManager) InitPythonPath() error

func (*SGuestManager) InitQemuMaxCpus 

func (m *SGuestManager) InitQemuMaxCpus(machineCaps []monitor.MachineInfo, kvmMaxCpus uint)

func (*SGuestManager) InitQemuMaxMems 

func (m *SGuestManager) InitQemuMaxMems(maxMems uint)

func (*SGuestManager) IsGuestDir 

func (m *SGuestManager) IsGuestDir(f os.FileInfo) bool

func (*SGuestManager) IsGuestExist 

func (m *SGuestManager) IsGuestExist(sid string) bool

func (*SGuestManager) LibvirtDomainDiskToDiskConfig 

func (m *SGuestManager) LibvirtDomainDiskToDiskConfig(
	domainDisks []libvirtxml.DomainDisk) ([]compute.SImportDisk, error)

func (*SGuestManager) LibvirtDomainInterfaceToNicConfig 

func (m *SGuestManager) LibvirtDomainInterfaceToNicConfig(
	domainInterfaces []libvirtxml.DomainInterface) ([]compute.SImportNic, error)

func (*SGuestManager) LibvirtDomainToGuestDesc 

func (m *SGuestManager) LibvirtDomainToGuestDesc(domain *libvirtxml.Domain) (*compute.SImportGuestDesc, error)

Read key infomation from domain xml

func (*SGuestManager) ListForward 

func (m *SGuestManager) ListForward(ctx context.Context, sid string, req *hostapi.GuestListForwardRequest) (*hostapi.GuestListForwardResponse, error)

func (*SGuestManager) LiveChangeDisk 

func (m *SGuestManager) LiveChangeDisk(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) LiveMigrate 

func (m *SGuestManager) LiveMigrate(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) LoadExistingGuests 

func (m *SGuestManager) LoadExistingGuests()

func (*SGuestManager) LoadServer 

func (m *SGuestManager) LoadServer(sid string)

func (*SGuestManager) Monitor 

func (m *SGuestManager) Monitor(sid, cmd string, qmp bool, callback func(string)) error

func (*SGuestManager) OnLoadExistingGuestsComplete 

func (m *SGuestManager) OnLoadExistingGuestsComplete()

func (*SGuestManager) OnVerifyExistingGuestsFail 

func (m *SGuestManager) OnVerifyExistingGuestsFail(err error, pendingDelete bool)

func (*SGuestManager) OnVerifyExistingGuestsSucc 

func (m *SGuestManager) OnVerifyExistingGuestsSucc(servers []jsonutils.JSONObject, pendingDelete bool)

func (*SGuestManager) OnlineResizeDisk 

func (m *SGuestManager) OnlineResizeDisk(ctx context.Context, sid string, disk storageman.IDisk, sizeMb int64) (jsonutils.JSONObject, error)

func (*SGuestManager) OpenForward 

func (m *SGuestManager) OpenForward(ctx context.Context, sid string, req *hostapi.GuestOpenForwardRequest) (*hostapi.GuestOpenForwardResponse, error)

func (*SGuestManager) PrepareCreate 

func (m *SGuestManager) PrepareCreate(sid string) error

func (*SGuestManager) PrepareDeploy 

func (m *SGuestManager) PrepareDeploy(sid string) error

func (*SGuestManager) PrepareImportFromLibvirt 

func (m *SGuestManager) PrepareImportFromLibvirt(
	ctx context.Context, params interface{},
) (jsonutils.JSONObject, error)

func (*SGuestManager) QemuLogDir 

func (m *SGuestManager) QemuLogDir() string

func (*SGuestManager) QgaCommand 

func (m *SGuestManager) QgaCommand(cmd *monitor.Command, sid string, execTimeout int) (string, error)

func (*SGuestManager) QgaGetNetwork 

func (m *SGuestManager) QgaGetNetwork(sid string) (string, error)

func (*SGuestManager) QgaGetOsInfo 

func (m *SGuestManager) QgaGetOsInfo(sid string) (jsonutils.JSONObject, error)

func (*SGuestManager) QgaGuestInfoTask 

func (m *SGuestManager) QgaGuestInfoTask(sid string) (string, error)

func (*SGuestManager) QgaGuestPing 

func (m *SGuestManager) QgaGuestPing(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) QgaGuestSetPassword 

func (m *SGuestManager) QgaGuestSetPassword(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) QgaSetNetwork 

func (m *SGuestManager) QgaSetNetwork(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) ReloadDiskSnapshot 

func (m *SGuestManager) ReloadDiskSnapshot(
	ctx context.Context, params interface{},
) (jsonutils.JSONObject, error)

func (*SGuestManager) RemoveCandidateServer 

func (m *SGuestManager) RemoveCandidateServer(server GuestRuntimeInstance)

func (*SGuestManager) RequestVerifyDirtyServer 

func (m *SGuestManager) RequestVerifyDirtyServer(s GuestRuntimeInstance)

func (*SGuestManager) ResetGuestNicTrafficLimit 

func (m *SGuestManager) ResetGuestNicTrafficLimit(guestId string, input []compute.ServerNicTrafficLimit) error

func (*SGuestManager) Resume 

func (m *SGuestManager) Resume(ctx context.Context, sid string, isLiveMigrate bool, cleanTLS bool) (jsonutils.JSONObject, error)

func (*SGuestManager) SaveGuestTrafficRecord 

func (m *SGuestManager) SaveGuestTrafficRecord(sid string, record map[string]compute.SNicTrafficRecord) error

func (*SGuestManager) SaveServer 

func (m *SGuestManager) SaveServer(sid string, s GuestRuntimeInstance)

func (*SGuestManager) SetGuestNicTrafficLimit 

func (m *SGuestManager) SetGuestNicTrafficLimit(guestId string, input []compute.ServerNicTrafficLimit) error

func (*SGuestManager) ShutdownServers 

func (m *SGuestManager) ShutdownServers()

func (*SGuestManager) SrcPrepareMigrate 

func (m *SGuestManager) SrcPrepareMigrate(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) StartBlockReplication 

func (m *SGuestManager) StartBlockReplication(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) StartCpusetBalancer 

func (m *SGuestManager) StartCpusetBalancer()

func (*SGuestManager) Status 

func (m *SGuestManager) Status(sid string) string

func (*SGuestManager) StorageCloneDisk 

func (m *SGuestManager) StorageCloneDisk(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SGuestManager) VerifyExistingGuests 

func (m *SGuestManager) VerifyExistingGuests(pendingDelete bool)

type SGuestNetworkSyncTask 

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

func NewGuestNetworkSyncTask 

func NewGuestNetworkSyncTask(
	guest *SKVMGuestInstance, delNics, addNics []*desc.SGuestNetwork,
) *SGuestNetworkSyncTask

func (*SGuestNetworkSyncTask) Start 

func (n *SGuestNetworkSyncTask) Start(callback func(...error))

type SGuestOnlineResizeDiskTask 

type SGuestOnlineResizeDiskTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestOnlineResizeDiskTask 

func NewGuestOnlineResizeDiskTask(
	ctx context.Context, s *SKVMGuestInstance, disk storageman.IDisk, sizeMB int64,
) *SGuestOnlineResizeDiskTask

func (SGuestOnlineResizeDiskTask) GetDesc 

func (s SGuestOnlineResizeDiskTask) GetDesc() *desc.SGuestDesc

func (SGuestOnlineResizeDiskTask) GetDescFilePath 

func (s SGuestOnlineResizeDiskTask) GetDescFilePath() string

func (SGuestOnlineResizeDiskTask) GetHypervisor 

func (s SGuestOnlineResizeDiskTask) GetHypervisor() string

func (SGuestOnlineResizeDiskTask) GetId 

func (s SGuestOnlineResizeDiskTask) GetId() string

func (SGuestOnlineResizeDiskTask) GetInitialId 

func (s SGuestOnlineResizeDiskTask) GetInitialId() string

func (SGuestOnlineResizeDiskTask) GetName 

func (s SGuestOnlineResizeDiskTask) GetName() string

func (SGuestOnlineResizeDiskTask) GetNicDescMatch 

func (s SGuestOnlineResizeDiskTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestOnlineResizeDiskTask) GetSourceDesc 

func (s SGuestOnlineResizeDiskTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestOnlineResizeDiskTask) GetSourceDescFilePath 

func (s SGuestOnlineResizeDiskTask) GetSourceDescFilePath() string

func (SGuestOnlineResizeDiskTask) GetVpcNIC 

func (s SGuestOnlineResizeDiskTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestOnlineResizeDiskTask) HomeDir 

func (b SGuestOnlineResizeDiskTask) HomeDir() string

func (SGuestOnlineResizeDiskTask) IsDaemon 

func (s SGuestOnlineResizeDiskTask) IsDaemon() bool

func (SGuestOnlineResizeDiskTask) IsLoaded 

func (s SGuestOnlineResizeDiskTask) IsLoaded() bool

func (SGuestOnlineResizeDiskTask) IsValid 

func (s SGuestOnlineResizeDiskTask) IsValid() bool

func (SGuestOnlineResizeDiskTask) NicTrafficRecordPath 

func (s SGuestOnlineResizeDiskTask) NicTrafficRecordPath() string

func (*SGuestOnlineResizeDiskTask) OnGetBlocksSucc 

func (task *SGuestOnlineResizeDiskTask) OnGetBlocksSucc(blocks []monitor.QemuBlock)

func (*SGuestOnlineResizeDiskTask) OnResizeSucc 

func (task *SGuestOnlineResizeDiskTask) OnResizeSucc(err string)

func (SGuestOnlineResizeDiskTask) SetDesc 

func (s SGuestOnlineResizeDiskTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestOnlineResizeDiskTask) SetSourceDesc 

func (s SGuestOnlineResizeDiskTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestOnlineResizeDiskTask) Start 

func (task *SGuestOnlineResizeDiskTask) Start()

type SGuestReloadDiskTask 

type SGuestReloadDiskTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestReloadDiskTask 

func NewGuestReloadDiskTask(
	ctx context.Context, s *SKVMGuestInstance, disk storageman.IDisk,
) *SGuestReloadDiskTask

func (SGuestReloadDiskTask) GetDesc 

func (s SGuestReloadDiskTask) GetDesc() *desc.SGuestDesc

func (SGuestReloadDiskTask) GetDescFilePath 

func (s SGuestReloadDiskTask) GetDescFilePath() string

func (SGuestReloadDiskTask) GetHypervisor 

func (s SGuestReloadDiskTask) GetHypervisor() string

func (SGuestReloadDiskTask) GetId 

func (s SGuestReloadDiskTask) GetId() string

func (SGuestReloadDiskTask) GetInitialId 

func (s SGuestReloadDiskTask) GetInitialId() string

func (SGuestReloadDiskTask) GetName 

func (s SGuestReloadDiskTask) GetName() string

func (SGuestReloadDiskTask) GetNicDescMatch 

func (s SGuestReloadDiskTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestReloadDiskTask) GetSourceDesc 

func (s SGuestReloadDiskTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestReloadDiskTask) GetSourceDescFilePath 

func (s SGuestReloadDiskTask) GetSourceDescFilePath() string

func (SGuestReloadDiskTask) GetVpcNIC 

func (s SGuestReloadDiskTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestReloadDiskTask) HomeDir 

func (b SGuestReloadDiskTask) HomeDir() string

func (SGuestReloadDiskTask) IsDaemon 

func (s SGuestReloadDiskTask) IsDaemon() bool

func (SGuestReloadDiskTask) IsLoaded 

func (s SGuestReloadDiskTask) IsLoaded() bool

func (SGuestReloadDiskTask) IsValid 

func (s SGuestReloadDiskTask) IsValid() bool

func (SGuestReloadDiskTask) NicTrafficRecordPath 

func (s SGuestReloadDiskTask) NicTrafficRecordPath() string

func (SGuestReloadDiskTask) SetDesc 

func (s SGuestReloadDiskTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestReloadDiskTask) SetSourceDesc 

func (s SGuestReloadDiskTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestReloadDiskTask) Start 

func (s *SGuestReloadDiskTask) Start()

func (*SGuestReloadDiskTask) WaitSnapshotReplaced 

func (s *SGuestReloadDiskTask) WaitSnapshotReplaced(callback func()) error

type SGuestResumeTask 

type SGuestResumeTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestResumeTask 

func NewGuestResumeTask(ctx context.Context, s *SKVMGuestInstance, isTimeout bool, cleanTLS bool) *SGuestResumeTask

func (SGuestResumeTask) GetDesc 

func (s SGuestResumeTask) GetDesc() *desc.SGuestDesc

func (SGuestResumeTask) GetDescFilePath 

func (s SGuestResumeTask) GetDescFilePath() string

func (SGuestResumeTask) GetHypervisor 

func (s SGuestResumeTask) GetHypervisor() string

func (SGuestResumeTask) GetId 

func (s SGuestResumeTask) GetId() string

func (SGuestResumeTask) GetInitialId 

func (s SGuestResumeTask) GetInitialId() string

func (SGuestResumeTask) GetName 

func (s SGuestResumeTask) GetName() string

func (SGuestResumeTask) GetNicDescMatch 

func (s SGuestResumeTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestResumeTask) GetSourceDesc 

func (s SGuestResumeTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestResumeTask) GetSourceDescFilePath 

func (s SGuestResumeTask) GetSourceDescFilePath() string

func (*SGuestResumeTask) GetStateFilePath 

func (s *SGuestResumeTask) GetStateFilePath() string

func (SGuestResumeTask) GetVpcNIC 

func (s SGuestResumeTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestResumeTask) HomeDir 

func (b SGuestResumeTask) HomeDir() string

func (SGuestResumeTask) IsDaemon 

func (s SGuestResumeTask) IsDaemon() bool

func (SGuestResumeTask) IsLoaded 

func (s SGuestResumeTask) IsLoaded() bool

func (SGuestResumeTask) IsValid 

func (s SGuestResumeTask) IsValid() bool

func (SGuestResumeTask) NicTrafficRecordPath 

func (s SGuestResumeTask) NicTrafficRecordPath() string

func (SGuestResumeTask) SetDesc 

func (s SGuestResumeTask) SetDesc(guestDesc *desc.SGuestDesc)

func (*SGuestResumeTask) SetGetTaskData 

func (s *SGuestResumeTask) SetGetTaskData(f func() (jsonutils.JSONObject, error))

func (SGuestResumeTask) SetSourceDesc 

func (s SGuestResumeTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestResumeTask) Start 

func (s *SGuestResumeTask) Start()

func (*SGuestResumeTask) Stop 

func (s *SGuestResumeTask) Stop()

type SGuestSnapshotDeleteTask 

type SGuestSnapshotDeleteTask struct {
	*SGuestReloadDiskTask
	// contains filtered or unexported fields
}

func NewGuestSnapshotDeleteTask 

func NewGuestSnapshotDeleteTask(
	ctx context.Context, s *SKVMGuestInstance, disk storageman.IDisk,
	deleteSnapshot, convertSnapshot string, blockStream bool,
) *SGuestSnapshotDeleteTask

func (SGuestSnapshotDeleteTask) GetDesc 

func (s SGuestSnapshotDeleteTask) GetDesc() *desc.SGuestDesc

func (SGuestSnapshotDeleteTask) GetDescFilePath 

func (s SGuestSnapshotDeleteTask) GetDescFilePath() string

func (SGuestSnapshotDeleteTask) GetHypervisor 

func (s SGuestSnapshotDeleteTask) GetHypervisor() string

func (SGuestSnapshotDeleteTask) GetId 

func (s SGuestSnapshotDeleteTask) GetId() string

func (SGuestSnapshotDeleteTask) GetInitialId 

func (s SGuestSnapshotDeleteTask) GetInitialId() string

func (SGuestSnapshotDeleteTask) GetName 

func (s SGuestSnapshotDeleteTask) GetName() string

func (SGuestSnapshotDeleteTask) GetNicDescMatch 

func (s SGuestSnapshotDeleteTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestSnapshotDeleteTask) GetSourceDesc 

func (s SGuestSnapshotDeleteTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestSnapshotDeleteTask) GetSourceDescFilePath 

func (s SGuestSnapshotDeleteTask) GetSourceDescFilePath() string

func (SGuestSnapshotDeleteTask) GetVpcNIC 

func (s SGuestSnapshotDeleteTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestSnapshotDeleteTask) HomeDir 

func (b SGuestSnapshotDeleteTask) HomeDir() string

func (SGuestSnapshotDeleteTask) IsDaemon 

func (s SGuestSnapshotDeleteTask) IsDaemon() bool

func (SGuestSnapshotDeleteTask) IsLoaded 

func (s SGuestSnapshotDeleteTask) IsLoaded() bool

func (SGuestSnapshotDeleteTask) IsValid 

func (s SGuestSnapshotDeleteTask) IsValid() bool

func (SGuestSnapshotDeleteTask) NicTrafficRecordPath 

func (s SGuestSnapshotDeleteTask) NicTrafficRecordPath() string

func (SGuestSnapshotDeleteTask) SetDesc 

func (s SGuestSnapshotDeleteTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestSnapshotDeleteTask) SetSourceDesc 

func (s SGuestSnapshotDeleteTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestSnapshotDeleteTask) Start 

func (s *SGuestSnapshotDeleteTask) Start()

type SGuestStopTask 

type SGuestStopTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestStopTask 

func NewGuestStopTask(guest *SKVMGuestInstance, ctx context.Context, timeout int64) *SGuestStopTask

func (*SGuestStopTask) CheckGuestRunningLater 

func (s *SGuestStopTask) CheckGuestRunningLater()

func (SGuestStopTask) GetDesc 

func (s SGuestStopTask) GetDesc() *desc.SGuestDesc

func (SGuestStopTask) GetDescFilePath 

func (s SGuestStopTask) GetDescFilePath() string

func (SGuestStopTask) GetHypervisor 

func (s SGuestStopTask) GetHypervisor() string

func (SGuestStopTask) GetId 

func (s SGuestStopTask) GetId() string

func (SGuestStopTask) GetInitialId 

func (s SGuestStopTask) GetInitialId() string

func (SGuestStopTask) GetName 

func (s SGuestStopTask) GetName() string

func (SGuestStopTask) GetNicDescMatch 

func (s SGuestStopTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestStopTask) GetSourceDesc 

func (s SGuestStopTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestStopTask) GetSourceDescFilePath 

func (s SGuestStopTask) GetSourceDescFilePath() string

func (SGuestStopTask) GetVpcNIC 

func (s SGuestStopTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestStopTask) HomeDir 

func (b SGuestStopTask) HomeDir() string

func (SGuestStopTask) IsDaemon 

func (s SGuestStopTask) IsDaemon() bool

func (SGuestStopTask) IsLoaded 

func (s SGuestStopTask) IsLoaded() bool

func (SGuestStopTask) IsValid 

func (s SGuestStopTask) IsValid() bool

func (SGuestStopTask) NicTrafficRecordPath 

func (s SGuestStopTask) NicTrafficRecordPath() string

func (SGuestStopTask) SetDesc 

func (s SGuestStopTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestStopTask) SetSourceDesc 

func (s SGuestStopTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestStopTask) Start 

func (s *SGuestStopTask) Start()

type SGuestStorageCloneDiskTask 

type SGuestStorageCloneDiskTask struct {
	*SGuestBlockProgressBaseTask
	// contains filtered or unexported fields
}

func NewGuestStorageCloneDiskTask 

func NewGuestStorageCloneDiskTask(ctx context.Context, guest *SKVMGuestInstance, params *SStorageCloneDisk) *SGuestStorageCloneDiskTask

func (SGuestStorageCloneDiskTask) GetDesc 

func (s SGuestStorageCloneDiskTask) GetDesc() *desc.SGuestDesc

func (SGuestStorageCloneDiskTask) GetDescFilePath 

func (s SGuestStorageCloneDiskTask) GetDescFilePath() string

func (SGuestStorageCloneDiskTask) GetHypervisor 

func (s SGuestStorageCloneDiskTask) GetHypervisor() string

func (SGuestStorageCloneDiskTask) GetId 

func (s SGuestStorageCloneDiskTask) GetId() string

func (SGuestStorageCloneDiskTask) GetInitialId 

func (s SGuestStorageCloneDiskTask) GetInitialId() string

func (SGuestStorageCloneDiskTask) GetName 

func (s SGuestStorageCloneDiskTask) GetName() string

func (SGuestStorageCloneDiskTask) GetNicDescMatch 

func (s SGuestStorageCloneDiskTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestStorageCloneDiskTask) GetSourceDesc 

func (s SGuestStorageCloneDiskTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestStorageCloneDiskTask) GetSourceDescFilePath 

func (s SGuestStorageCloneDiskTask) GetSourceDescFilePath() string

func (SGuestStorageCloneDiskTask) GetVpcNIC 

func (s SGuestStorageCloneDiskTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestStorageCloneDiskTask) HomeDir 

func (b SGuestStorageCloneDiskTask) HomeDir() string

func (SGuestStorageCloneDiskTask) IsDaemon 

func (s SGuestStorageCloneDiskTask) IsDaemon() bool

func (SGuestStorageCloneDiskTask) IsLoaded 

func (s SGuestStorageCloneDiskTask) IsLoaded() bool

func (SGuestStorageCloneDiskTask) IsValid 

func (s SGuestStorageCloneDiskTask) IsValid() bool

func (SGuestStorageCloneDiskTask) NicTrafficRecordPath 

func (s SGuestStorageCloneDiskTask) NicTrafficRecordPath() string

func (*SGuestStorageCloneDiskTask) OnGetBlockJobs 

func (t *SGuestStorageCloneDiskTask) OnGetBlockJobs(jobs []monitor.BlockJob)

func (SGuestStorageCloneDiskTask) SetDesc 

func (s SGuestStorageCloneDiskTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestStorageCloneDiskTask) SetSourceDesc 

func (s SGuestStorageCloneDiskTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestStorageCloneDiskTask) Start 

func (t *SGuestStorageCloneDiskTask) Start(guestRunning bool)

func (*SGuestStorageCloneDiskTask) StreamingDiskCompletedCount 

func (t *SGuestStorageCloneDiskTask) StreamingDiskCompletedCount() int

func (*SGuestStorageCloneDiskTask) StreamingDiskCount 

func (t *SGuestStorageCloneDiskTask) StreamingDiskCount() int

type SGuestStreamDisksTask 

type SGuestStreamDisksTask struct {
	*SGuestBlockProgressBaseTask
	// contains filtered or unexported fields
}

func NewGuestStreamDisksTask 

func NewGuestStreamDisksTask(ctx context.Context, guest *SKVMGuestInstance, callback func(), disksIdx []int) *SGuestStreamDisksTask

func (SGuestStreamDisksTask) GetDesc 

func (s SGuestStreamDisksTask) GetDesc() *desc.SGuestDesc

func (SGuestStreamDisksTask) GetDescFilePath 

func (s SGuestStreamDisksTask) GetDescFilePath() string

func (SGuestStreamDisksTask) GetHypervisor 

func (s SGuestStreamDisksTask) GetHypervisor() string

func (SGuestStreamDisksTask) GetId 

func (s SGuestStreamDisksTask) GetId() string

func (SGuestStreamDisksTask) GetInitialId 

func (s SGuestStreamDisksTask) GetInitialId() string

func (SGuestStreamDisksTask) GetName 

func (s SGuestStreamDisksTask) GetName() string

func (SGuestStreamDisksTask) GetNicDescMatch 

func (s SGuestStreamDisksTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestStreamDisksTask) GetSourceDesc 

func (s SGuestStreamDisksTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestStreamDisksTask) GetSourceDescFilePath 

func (s SGuestStreamDisksTask) GetSourceDescFilePath() string

func (SGuestStreamDisksTask) GetVpcNIC 

func (s SGuestStreamDisksTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestStreamDisksTask) HomeDir 

func (b SGuestStreamDisksTask) HomeDir() string

func (SGuestStreamDisksTask) IsDaemon 

func (s SGuestStreamDisksTask) IsDaemon() bool

func (SGuestStreamDisksTask) IsLoaded 

func (s SGuestStreamDisksTask) IsLoaded() bool

func (SGuestStreamDisksTask) IsValid 

func (s SGuestStreamDisksTask) IsValid() bool

func (SGuestStreamDisksTask) NicTrafficRecordPath 

func (s SGuestStreamDisksTask) NicTrafficRecordPath() string

func (*SGuestStreamDisksTask) OnGetBlockJobs 

func (s *SGuestStreamDisksTask) OnGetBlockJobs(jobs []monitor.BlockJob)

func (SGuestStreamDisksTask) SetDesc 

func (s SGuestStreamDisksTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestStreamDisksTask) SetSourceDesc 

func (s SGuestStreamDisksTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestStreamDisksTask) Start 

func (s *SGuestStreamDisksTask) Start()

func (*SGuestStreamDisksTask) StreamingDiskCompletedCount 

func (s *SGuestStreamDisksTask) StreamingDiskCompletedCount() int

func (*SGuestStreamDisksTask) StreamingDiskCount 

func (s *SGuestStreamDisksTask) StreamingDiskCount() int

type SGuestSuspendTask 

type SGuestSuspendTask struct {
	*SKVMGuestInstance
	// contains filtered or unexported fields
}

func NewGuestSuspendTask 

func NewGuestSuspendTask(
	guest *SKVMGuestInstance,
	ctx context.Context,
	onFinishCallback func(*SGuestSuspendTask, string),
) *SGuestSuspendTask

func (SGuestSuspendTask) GetDesc 

func (s SGuestSuspendTask) GetDesc() *desc.SGuestDesc

func (SGuestSuspendTask) GetDescFilePath 

func (s SGuestSuspendTask) GetDescFilePath() string

func (SGuestSuspendTask) GetHypervisor 

func (s SGuestSuspendTask) GetHypervisor() string

func (SGuestSuspendTask) GetId 

func (s SGuestSuspendTask) GetId() string

func (SGuestSuspendTask) GetInitialId 

func (s SGuestSuspendTask) GetInitialId() string

func (SGuestSuspendTask) GetName 

func (s SGuestSuspendTask) GetName() string

func (SGuestSuspendTask) GetNicDescMatch 

func (s SGuestSuspendTask) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (SGuestSuspendTask) GetSourceDesc 

func (s SGuestSuspendTask) GetSourceDesc() *desc.SGuestDesc

func (SGuestSuspendTask) GetSourceDescFilePath 

func (s SGuestSuspendTask) GetSourceDescFilePath() string

func (*SGuestSuspendTask) GetStateFilePath 

func (s *SGuestSuspendTask) GetStateFilePath() string

func (SGuestSuspendTask) GetVpcNIC 

func (s SGuestSuspendTask) GetVpcNIC() *desc.SGuestNetwork

func (SGuestSuspendTask) HomeDir 

func (b SGuestSuspendTask) HomeDir() string

func (SGuestSuspendTask) IsDaemon 

func (s SGuestSuspendTask) IsDaemon() bool

func (SGuestSuspendTask) IsLoaded 

func (s SGuestSuspendTask) IsLoaded() bool

func (SGuestSuspendTask) IsValid 

func (s SGuestSuspendTask) IsValid() bool

func (SGuestSuspendTask) NicTrafficRecordPath 

func (s SGuestSuspendTask) NicTrafficRecordPath() string

func (SGuestSuspendTask) SetDesc 

func (s SGuestSuspendTask) SetDesc(guestDesc *desc.SGuestDesc)

func (SGuestSuspendTask) SetSourceDesc 

func (s SGuestSuspendTask) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SGuestSuspendTask) Start 

func (s *SGuestSuspendTask) Start()

type SGuestSyncConfigTaskExecutor 

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

func NewGuestSyncConfigTaskExecutor 

func NewGuestSyncConfigTaskExecutor(ctx context.Context, guest *SKVMGuestInstance, tasks []IGuestTasks, callback func([]error)) *SGuestSyncConfigTaskExecutor

func (*SGuestSyncConfigTaskExecutor) Start 

func (t *SGuestSyncConfigTaskExecutor) Start(delay int)

type SKVMGuestInstance 

type SKVMGuestInstance struct {
	SKVMInstanceRuntime

	Monitor monitor.Monitor
	// contains filtered or unexported fields
}

func NewKVMGuestInstance 

func NewKVMGuestInstance(id string, manager *SGuestManager) *SKVMGuestInstance

func (*SKVMGuestInstance) BlockIoThrottle 

func (s *SKVMGuestInstance) BlockIoThrottle(ctx context.Context)

func (*SKVMGuestInstance) BlockJobsCount 

func (s *SKVMGuestInstance) BlockJobsCount() int

func (*SKVMGuestInstance) CPUSet 

func (s *SKVMGuestInstance) CPUSet(ctx context.Context, input []int) (*api.ServerCPUSetResp, error)

func (*SKVMGuestInstance) CPUSetRemove 

func (s *SKVMGuestInstance) CPUSetRemove(ctx context.Context) error

func (*SKVMGuestInstance) CheckBlockOrRunning 

func (s *SKVMGuestInstance) CheckBlockOrRunning(jobs int)

func (*SKVMGuestInstance) CleanDirtyGuest 

func (s *SKVMGuestInstance) CleanDirtyGuest(ctx context.Context) error

func (*SKVMGuestInstance) CleanGuest 

func (s *SKVMGuestInstance) CleanGuest(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

Delay process

func (*SKVMGuestInstance) CleanImportMetadata 

func (s *SKVMGuestInstance) CleanImportMetadata() *jsonutils.JSONDict

func (*SKVMGuestInstance) CleanStartupTask 

func (s *SKVMGuestInstance) CleanStartupTask()

func (*SKVMGuestInstance) CleanStatefiles 

func (s *SKVMGuestInstance) CleanStatefiles()

func (*SKVMGuestInstance) CleanupCpuset 

func (s *SKVMGuestInstance) CleanupCpuset()

func (*SKVMGuestInstance) CpuMax 

func (s *SKVMGuestInstance) CpuMax() (uint, error)

func (*SKVMGuestInstance) Delete 

func (s *SKVMGuestInstance) Delete(ctx context.Context, migrated, recycle bool) error

func (*SKVMGuestInstance) DeleteSnapshot 

func (s *SKVMGuestInstance) DeleteSnapshot(ctx context.Context, delParams *SDeleteDiskSnapshot) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) DeployFs 

func (s *SKVMGuestInstance) DeployFs(ctx context.Context, userCred mcclient.TokenCredential, deployInfo *deployapi.DeployInfo) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) DirtyServerRequestStart 

func (s *SKVMGuestInstance) DirtyServerRequestStart()

func (*SKVMGuestInstance) DiskCount 

func (s *SKVMGuestInstance) DiskCount() int

func (*SKVMGuestInstance) DoResumeTask 

func (s *SKVMGuestInstance) DoResumeTask(ctx context.Context, isTimeout bool, cleanTls bool)

func (*SKVMGuestInstance) DoSnapshot 

func (s *SKVMGuestInstance) DoSnapshot(ctx context.Context, snapshotParams *SDiskSnapshot) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) ExecDeleteSnapshotTask 

func (s *SKVMGuestInstance) ExecDeleteSnapshotTask(
	ctx context.Context, disk storageman.IDisk,
	deleteSnapshot string, convertSnapshot string, blockStream bool,
) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) ExecDiskSnapshotTask 

func (s *SKVMGuestInstance) ExecDiskSnapshotTask(
	ctx context.Context, userCred mcclient.TokenCredential, disk storageman.IDisk, snapshotId string,
) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) ExecMemorySnapshotResetTask 

func (s *SKVMGuestInstance) ExecMemorySnapshotResetTask(ctx context.Context, input *hostapi.GuestMemorySnapshotResetRequest) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) ExecMemorySnapshotTask 

func (s *SKVMGuestInstance) ExecMemorySnapshotTask(ctx context.Context, input *hostapi.GuestMemorySnapshotRequest) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) ExecReloadDiskTask 

func (s *SKVMGuestInstance) ExecReloadDiskTask(ctx context.Context, disk storageman.IDisk) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) ExecStopTask 

func (s *SKVMGuestInstance) ExecStopTask(ctx context.Context, params interface{}) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) ExecSuspendTask 

func (s *SKVMGuestInstance) ExecSuspendTask(ctx context.Context)

func (*SKVMGuestInstance) ExitCleanup 

func (s *SKVMGuestInstance) ExitCleanup(clear bool)

func (*SKVMGuestInstance) ForceStop 

func (s *SKVMGuestInstance) ForceStop() bool

func (*SKVMGuestInstance) GetCgroupName 

func (s *SKVMGuestInstance) GetCgroupName() string

func (*SKVMGuestInstance) GetCleanFiles 

func (s *SKVMGuestInstance) GetCleanFiles() []string

func (SKVMGuestInstance) GetDesc 

func (s SKVMGuestInstance) GetDesc() *desc.SGuestDesc

func (SKVMGuestInstance) GetDescFilePath 

func (s SKVMGuestInstance) GetDescFilePath() string

func (*SKVMGuestInstance) GetFuseTmpPath 

func (s *SKVMGuestInstance) GetFuseTmpPath() string

func (*SKVMGuestInstance) GetHmpMonitorPort 

func (s *SKVMGuestInstance) GetHmpMonitorPort(vncPort int) int

func (SKVMGuestInstance) GetHypervisor 

func (s SKVMGuestInstance) GetHypervisor() string

func (SKVMGuestInstance) GetId 

func (s SKVMGuestInstance) GetId() string

func (SKVMGuestInstance) GetInitialId 

func (s SKVMGuestInstance) GetInitialId() string

func (*SKVMGuestInstance) GetKernelVersion 

func (s *SKVMGuestInstance) GetKernelVersion() string

func (*SKVMGuestInstance) GetMonitorPath 

func (s *SKVMGuestInstance) GetMonitorPath() string

func (SKVMGuestInstance) GetName 

func (s SKVMGuestInstance) GetName() string

func (*SKVMGuestInstance) GetNeedMergeBackingFileDiskIndexs 

func (s *SKVMGuestInstance) GetNeedMergeBackingFileDiskIndexs() []int

func (SKVMGuestInstance) GetNicDescMatch 

func (s SKVMGuestInstance) GetNicDescMatch(mac, ip, port, bridge string) *desc.SGuestNetwork

func (*SKVMGuestInstance) GetOsName 

func (s *SKVMGuestInstance) GetOsName() string

func (*SKVMGuestInstance) GetPciBus 

func (s *SKVMGuestInstance) GetPciBus() string

func (*SKVMGuestInstance) GetPid 

func (s *SKVMGuestInstance) GetPid() int

func (*SKVMGuestInstance) GetPidFilePath 

func (s *SKVMGuestInstance) GetPidFilePath() string

func (*SKVMGuestInstance) GetQemuVersionStr 

func (s *SKVMGuestInstance) GetQemuVersionStr() string

func (*SKVMGuestInstance) GetQmpMonitorPort 

func (s *SKVMGuestInstance) GetQmpMonitorPort(vncPort int) int

func (*SKVMGuestInstance) GetRescueDirPath 

func (s *SKVMGuestInstance) GetRescueDirPath() string

func (SKVMGuestInstance) GetSourceDesc 

func (s SKVMGuestInstance) GetSourceDesc() *desc.SGuestDesc

func (SKVMGuestInstance) GetSourceDescFilePath 

func (s SKVMGuestInstance) GetSourceDescFilePath() string

func (*SKVMGuestInstance) GetSriovDeviceByNetworkIndex 

func (s *SKVMGuestInstance) GetSriovDeviceByNetworkIndex(networkIndex int) (isolated_device.IDevice, error)

func (*SKVMGuestInstance) GetStartScriptPath 

func (s *SKVMGuestInstance) GetStartScriptPath() string

func (*SKVMGuestInstance) GetStateFilePath 

func (s *SKVMGuestInstance) GetStateFilePath(version string) string

func (*SKVMGuestInstance) GetStopScriptPath 

func (s *SKVMGuestInstance) GetStopScriptPath() string

func (*SKVMGuestInstance) GetVdiProtocol 

func (s *SKVMGuestInstance) GetVdiProtocol() string

func (*SKVMGuestInstance) GetVncFilePath 

func (s *SKVMGuestInstance) GetVncFilePath() string

func (*SKVMGuestInstance) GetVncPort 

func (s *SKVMGuestInstance) GetVncPort() int

func (SKVMGuestInstance) GetVpcNIC 

func (s SKVMGuestInstance) GetVpcNIC() *desc.SGuestNetwork

func (*SKVMGuestInstance) GuestPrelaunchSetCgroup 

func (s *SKVMGuestInstance) GuestPrelaunchSetCgroup()

func (*SKVMGuestInstance) HandleGuestStart 

func (s *SKVMGuestInstance) HandleGuestStart(ctx context.Context, userCred mcclient.TokenCredential, body jsonutils.JSONObject) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) HandleGuestStatus 

func (s *SKVMGuestInstance) HandleGuestStatus(ctx context.Context, status string, body *jsonutils.JSONDict) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) HandleStop 

func (s *SKVMGuestInstance) HandleStop(ctx context.Context, timeout int64) error

func (*SKVMGuestInstance) HideHypervisor 

func (s *SKVMGuestInstance) HideHypervisor() bool

func (*SKVMGuestInstance) HideKVM 

func (s *SKVMGuestInstance) HideKVM() bool

func (SKVMGuestInstance) HomeDir 

func (b SKVMGuestInstance) HomeDir() string

func (*SKVMGuestInstance) ImportServer 

func (s *SKVMGuestInstance) ImportServer(pendingDelete bool)

func (*SKVMGuestInstance) InitQga 

func (s *SKVMGuestInstance) InitQga() error

func (SKVMGuestInstance) IsDaemon 

func (s SKVMGuestInstance) IsDaemon() bool

func (*SKVMGuestInstance) IsDirtyShotdown 

func (s *SKVMGuestInstance) IsDirtyShotdown() bool

func (*SKVMGuestInstance) IsKvmSupport 

func (s *SKVMGuestInstance) IsKvmSupport() bool

func (SKVMGuestInstance) IsLoaded 

func (s SKVMGuestInstance) IsLoaded() bool

func (*SKVMGuestInstance) IsMaster 

func (s *SKVMGuestInstance) IsMaster() bool

func (*SKVMGuestInstance) IsMigratingDestGuest 

func (s *SKVMGuestInstance) IsMigratingDestGuest() bool

func (*SKVMGuestInstance) IsMonitorAlive 

func (s *SKVMGuestInstance) IsMonitorAlive() bool

func (*SKVMGuestInstance) IsNestedVirt 

func (s *SKVMGuestInstance) IsNestedVirt() bool

func (*SKVMGuestInstance) IsOldWindows 

func (s *SKVMGuestInstance) IsOldWindows() bool

is windows prioer to windows server 2003

func (*SKVMGuestInstance) IsRunning 

func (s *SKVMGuestInstance) IsRunning() bool

func (*SKVMGuestInstance) IsSharedStorage 

func (s *SKVMGuestInstance) IsSharedStorage() bool

func (*SKVMGuestInstance) IsSlave 

func (s *SKVMGuestInstance) IsSlave() bool

func (*SKVMGuestInstance) IsStopped 

func (s *SKVMGuestInstance) IsStopped() bool

func (*SKVMGuestInstance) IsStopping 

func (s *SKVMGuestInstance) IsStopping() bool

func (*SKVMGuestInstance) IsSuspend 

func (s *SKVMGuestInstance) IsSuspend() bool

func (SKVMGuestInstance) IsValid 

func (s SKVMGuestInstance) IsValid() bool

func (*SKVMGuestInstance) IsVdiSpice 

func (s *SKVMGuestInstance) IsVdiSpice() bool

func (*SKVMGuestInstance) ListStateFilePaths 

func (s *SKVMGuestInstance) ListStateFilePaths() []string

func (*SKVMGuestInstance) LoadDesc 

func (s *SKVMGuestInstance) LoadDesc() error

func (*SKVMGuestInstance) LogFilePath 

func (s *SKVMGuestInstance) LogFilePath() string

func (SKVMGuestInstance) NicTrafficRecordPath 

func (s SKVMGuestInstance) NicTrafficRecordPath() string

func (*SKVMGuestInstance) OnResumeSyncMetadataInfo 

func (s *SKVMGuestInstance) OnResumeSyncMetadataInfo()

func (*SKVMGuestInstance) PostLoad 

func (s *SKVMGuestInstance) PostLoad(m *SGuestManager) error

func (*SKVMGuestInstance) PrepareDisksMigrate 

func (s *SKVMGuestInstance) PrepareDisksMigrate(liveMigrate bool) (*jsonutils.JSONDict, *jsonutils.JSONDict, bool, error)

func (*SKVMGuestInstance) PrepareMigrateCerts 

func (s *SKVMGuestInstance) PrepareMigrateCerts() (map[string]string, error)

func (*SKVMGuestInstance) QgaPath 

func (s *SKVMGuestInstance) QgaPath() string

func (*SKVMGuestInstance) RecycleDir 

func (s *SKVMGuestInstance) RecycleDir() string

func (SKVMGuestInstance) SetDesc 

func (s SKVMGuestInstance) SetDesc(guestDesc *desc.SGuestDesc)

func (*SKVMGuestInstance) SetNicDown 

func (s *SKVMGuestInstance) SetNicDown(index int) error

func (*SKVMGuestInstance) SetNicUp 

func (s *SKVMGuestInstance) SetNicUp(nic *desc.SGuestNetwork) error

func (SKVMGuestInstance) SetSourceDesc 

func (s SKVMGuestInstance) SetSourceDesc(guestDesc *desc.SGuestDesc)

func (*SKVMGuestInstance) SetVncPassword 

func (s *SKVMGuestInstance) SetVncPassword()

func (*SKVMGuestInstance) SlaveDisksBlockStream 

func (s *SKVMGuestInstance) SlaveDisksBlockStream() error

func (*SKVMGuestInstance) StartDelete 

func (s *SKVMGuestInstance) StartDelete(ctx context.Context, migrated bool) error

func (*SKVMGuestInstance) StartGuest 

func (s *SKVMGuestInstance) StartGuest(ctx context.Context, userCred mcclient.TokenCredential, params *jsonutils.JSONDict) error

func (*SKVMGuestInstance) StartMonitor 

func (s *SKVMGuestInstance) StartMonitor(ctx context.Context, cb func(), isScriptStart bool) error

func (*SKVMGuestInstance) StartMonitorWithImportGuestSocketFile 

func (s *SKVMGuestInstance) StartMonitorWithImportGuestSocketFile(ctx context.Context, socketFile string, cb func()) error

func (*SKVMGuestInstance) StartPresendArp 

func (s *SKVMGuestInstance) StartPresendArp()

func (*SKVMGuestInstance) StaticSaveSnapshot 

func (s *SKVMGuestInstance) StaticSaveSnapshot(
	ctx context.Context, disk storageman.IDisk, snapshotId string,
	encryptKey string, encFormat qemuimg.TEncryptFormat, encAlg seclib2.TSymEncAlg,
) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) Stop 

func (s *SKVMGuestInstance) Stop() bool

func (*SKVMGuestInstance) StreamDisks 

func (s *SKVMGuestInstance) StreamDisks(ctx context.Context, callback func(), disksIdx []int)

func (*SKVMGuestInstance) SyncConfig 

func (s *SKVMGuestInstance) SyncConfig(
	ctx context.Context, guestDesc *desc.SGuestDesc, fwOnly bool,
) (jsonutils.JSONObject, error)

func (*SKVMGuestInstance) SyncMetadata 

func (s *SKVMGuestInstance) SyncMetadata(meta *jsonutils.JSONDict) error

func (*SKVMGuestInstance) SyncMirrorJobFailed 

func (s *SKVMGuestInstance) SyncMirrorJobFailed(reason string)

func (*SKVMGuestInstance) SyncQemuCmdline 

func (s *SKVMGuestInstance) SyncQemuCmdline(cmdline string)

func (*SKVMGuestInstance) SyncStatus 

func (s *SKVMGuestInstance) SyncStatus(reason string)

func (*SKVMGuestInstance) WriteMigrateCerts 

func (s *SKVMGuestInstance) WriteMigrateCerts(certs map[string]string) error

type SKVMInstanceRuntime 

type SKVMInstanceRuntime struct {
	QemuVersion string
	VncPassword string

	LiveMigrateDestPort *int64
	LiveMigrateUseTls   bool

	StartupTask *SGuestResumeTask
	MigrateTask *SGuestLiveMigrateTask
	// contains filtered or unexported fields
}

type SLibvirtDomainImportConfig 

type SLibvirtDomainImportConfig struct {
	LibvritDomainXmlDir string
	Servers             []SLibvirtServer
}

type SLibvirtServer 

type SLibvirtServer struct {
	Uuid  string
	MacIp map[string]string
}

type SLiveMigrate 

type SLiveMigrate struct {
	Sid            string
	DestPort       int
	NbdServerPort  int
	DestIp         string
	IsLocal        bool
	EnableTLS      bool
	MaxBandwidthMB *int64
	QuicklyFinish  bool
}

type SMemorySnapshot 

type SMemorySnapshot struct {
	*hostapi.GuestMemorySnapshotRequest
	Sid string
}

type SMemorySnapshotDelete 

type SMemorySnapshotDelete struct {
	*hostapi.GuestMemorySnapshotDeleteRequest
}

type SMemorySnapshotReset 

type SMemorySnapshotReset struct {
	*hostapi.GuestMemorySnapshotResetRequest
	Sid string
}

type SQgaGuestSetNetwork 

type SQgaGuestSetNetwork struct {
	Timeout int
	Sid     string
	Device  string
	Ipmask  string
	Gateway string
}

type SQgaGuestSetPassword 

type SQgaGuestSetPassword struct {
	*hostapi.GuestSetPasswordRequest
	Sid string
}

type SReloadDisk 

type SReloadDisk struct {
	Sid  string
	Disk storageman.IDisk
}

type SSrcPrepareMigrate 

type SSrcPrepareMigrate struct {
	Sid               string
	LiveMigrate       bool
	LiveMigrateUseTLS bool
}

type SStorageCloneDisk 

type SStorageCloneDisk struct {
	ServerId       string
	SourceStorage  storageman.IStorage
	SourceDisk     storageman.IDisk
	TargetStorage  storageman.IStorage
	TargetDiskId   string
	DiskFormat     string
	TargetDiskDesc *compute.GuestdiskJsonDesc

	// clone progress
	CompletedDiskCount int
	CloneDiskCount     int
}

type SorttedCPUDie 

type SorttedCPUDie []*CPUDie

func (SorttedCPUDie) Len 

func (pq SorttedCPUDie) Len() int

func (SorttedCPUDie) Less 

func (pq SorttedCPUDie) Less(i, j int) bool

func (*SorttedCPUDie) LoadCpus 

func (pq *SorttedCPUDie) LoadCpus(cpus []int, vcpuCount int)

func (*SorttedCPUDie) Pop 

func (pq *SorttedCPUDie) Pop() interface{}

func (*SorttedCPUDie) Push 

func (pq *SorttedCPUDie) Push(item interface{})

func (*SorttedCPUDie) ReleaseCpus 

func (pq *SorttedCPUDie) ReleaseCpus(cpus []int, vcpuCount int)

func (SorttedCPUDie) Swap 

func (pq SorttedCPUDie) Swap(i, j int)

Source Files

View all Source files

Directories

Path Synopsis
api
certs

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.