util

Documentation

Index

• Variables
• func ConvReason(status libvirt.DomainState, reason int) api.StateChangeReason
• func ConvState(status libvirt.DomainState) api.LifeCycle
• func DomainFromNamespaceName(namespace, name string) string
• func GetDomainSpec(status libvirt.DomainState, dom cli.VirDomain) (*api.DomainSpec, error)
• func GetDomainSpecWithFlags(dom cli.VirDomain, flags libvirt.DomainXMLFlags) (*api.DomainSpec, error)
• func GetDomainSpecWithRuntimeInfo(status libvirt.DomainState, dom cli.VirDomain) (*api.DomainSpec, error)
• func GetPodCPUSet() ([]int, error)
• func NewDomain(dom cli.VirDomain) (*api.Domain, error)
• func NewDomainFromName(name string, vmiUID types.UID) *api.Domain
• func SetDomainSpecStr(virConn cli.Connection, vmi *v1.VirtualMachineInstance, wantedSpec string) (cli.VirDomain, error)
• func SetupLibvirt() error
• func SplitVMINamespaceKey(domainName string) (namespace, name string)
• func StartLibvirt(stopChan chan struct{})
• func StartVirtlog(stopChan chan struct{})
• func VMINamespaceKeyFunc(vmi *v1.VirtualMachineInstance) string

Variables

var CrashedReasonTranslationMap = map[libvirt.DomainCrashedReason]api.StateChangeReason{
	libvirt.DOMAIN_CRASHED_UNKNOWN:  api.ReasonUnknown,
	libvirt.DOMAIN_CRASHED_PANICKED: api.ReasonPanicked,
}

var LifeCycleTranslationMap = map[libvirt.DomainState]api.LifeCycle{
	libvirt.DOMAIN_NOSTATE:     api.NoState,
	libvirt.DOMAIN_RUNNING:     api.Running,
	libvirt.DOMAIN_BLOCKED:     api.Blocked,
	libvirt.DOMAIN_PAUSED:      api.Paused,
	libvirt.DOMAIN_SHUTDOWN:    api.Shutdown,
	libvirt.DOMAIN_SHUTOFF:     api.Shutoff,
	libvirt.DOMAIN_CRASHED:     api.Crashed,
	libvirt.DOMAIN_PMSUSPENDED: api.PMSuspended,
}

var PausedReasonTranslationMap = map[libvirt.DomainPausedReason]api.StateChangeReason{
	libvirt.DOMAIN_PAUSED_UNKNOWN:         api.ReasonPausedUnknown,
	libvirt.DOMAIN_PAUSED_USER:            api.ReasonPausedUser,
	libvirt.DOMAIN_PAUSED_MIGRATION:       api.ReasonPausedMigration,
	libvirt.DOMAIN_PAUSED_SAVE:            api.ReasonPausedSave,
	libvirt.DOMAIN_PAUSED_DUMP:            api.ReasonPausedDump,
	libvirt.DOMAIN_PAUSED_IOERROR:         api.ReasonPausedIOError,
	libvirt.DOMAIN_PAUSED_WATCHDOG:        api.ReasonPausedWatchdog,
	libvirt.DOMAIN_PAUSED_FROM_SNAPSHOT:   api.ReasonPausedFromSnapshot,
	libvirt.DOMAIN_PAUSED_SHUTTING_DOWN:   api.ReasonPausedShuttingDown,
	libvirt.DOMAIN_PAUSED_SNAPSHOT:        api.ReasonPausedSnapshot,
	libvirt.DOMAIN_PAUSED_CRASHED:         api.ReasonPausedCrashed,
	libvirt.DOMAIN_PAUSED_STARTING_UP:     api.ReasonPausedStartingUp,
	libvirt.DOMAIN_PAUSED_POSTCOPY:        api.ReasonPausedPostcopy,
	libvirt.DOMAIN_PAUSED_POSTCOPY_FAILED: api.ReasonPausedPostcopyFailed,
}

var ShutdownReasonTranslationMap = map[libvirt.DomainShutdownReason]api.StateChangeReason{
	libvirt.DOMAIN_SHUTDOWN_UNKNOWN: api.ReasonUnknown,
	libvirt.DOMAIN_SHUTDOWN_USER:    api.ReasonUser,
}

var ShutoffReasonTranslationMap = map[libvirt.DomainShutoffReason]api.StateChangeReason{
	libvirt.DOMAIN_SHUTOFF_UNKNOWN:       api.ReasonUnknown,
	libvirt.DOMAIN_SHUTOFF_SHUTDOWN:      api.ReasonShutdown,
	libvirt.DOMAIN_SHUTOFF_DESTROYED:     api.ReasonDestroyed,
	libvirt.DOMAIN_SHUTOFF_CRASHED:       api.ReasonCrashed,
	libvirt.DOMAIN_SHUTOFF_MIGRATED:      api.ReasonMigrated,
	libvirt.DOMAIN_SHUTOFF_SAVED:         api.ReasonSaved,
	libvirt.DOMAIN_SHUTOFF_FAILED:        api.ReasonFailed,
	libvirt.DOMAIN_SHUTOFF_FROM_SNAPSHOT: api.ReasonFromSnapshot,
}

Functions

func ConvReason

func ConvReason(status libvirt.DomainState, reason int) api.StateChangeReason

func ConvState

func ConvState(status libvirt.DomainState) api.LifeCycle

func DomainFromNamespaceName

func DomainFromNamespaceName(namespace, name string) string

func GetDomainSpec

func GetDomainSpec(status libvirt.DomainState, dom cli.VirDomain) (*api.DomainSpec, error)

GetDomainSpec return the domain XML without runtime information. The result XML is merged from inactive XML and migratable XML.

func GetDomainSpecWithFlags

func GetDomainSpecWithFlags(dom cli.VirDomain, flags libvirt.DomainXMLFlags) (*api.DomainSpec, error)

func GetDomainSpecWithRuntimeInfo

func GetDomainSpecWithRuntimeInfo(status libvirt.DomainState, dom cli.VirDomain) (*api.DomainSpec, error)

GetDomainSpecWithRuntimeInfo return the active domain XML with runtime information embedded

func GetPodCPUSet

func GetPodCPUSet() ([]int, error)

func NewDomain

func NewDomain(dom cli.VirDomain) (*api.Domain, error)

func NewDomainFromName

func NewDomainFromName(name string, vmiUID types.UID) *api.Domain

func SetDomainSpecStr

func SetDomainSpecStr(virConn cli.Connection, vmi *v1.VirtualMachineInstance, wantedSpec string) (cli.VirDomain, error)

func SetupLibvirt

func SetupLibvirt() error

func SplitVMINamespaceKey

func SplitVMINamespaceKey(domainName string) (namespace, name string)

returns the namespace and name that is encoded in the domain name.

func StartLibvirt

func StartLibvirt(stopChan chan struct{})

func StartVirtlog

func StartVirtlog(stopChan chan struct{})

func VMINamespaceKeyFunc

func VMINamespaceKeyFunc(vmi *v1.VirtualMachineInstance) string

VMINamespaceKeyFunc constructs the domain name with a namespace prefix i.g. namespace_name.