Documentation ¶
Index ¶
- Constants
- func FindPodDirOnHost(vmi *v1.VirtualMachineInstance) (string, error)
- func FindSocketOnHost(vmi *v1.VirtualMachineInstance) (string, error)
- func IsDisconnected(err error) bool
- func IsLegacySocket(socket string) bool
- func IsSocketUnresponsive(socket string) bool
- func LegacySocketsDirectory() string
- func ListAllSockets() ([]string, error)
- func MarkSocketUnresponsive(socket string) error
- func SetLegacyBaseDir(baseDir string)
- func SetPodsBaseDir(baseDir string)
- func SocketDirectoryOnHost(podUID string) string
- func SocketFilePathOnHost(podUID string) string
- func SocketMonitoringEnabled(socket string) bool
- func SocketOnGuest() string
- func UninitializedSocketOnGuest() string
- type LauncherClient
- type MigrationOptions
- type MockLauncherClient
- func (_m *MockLauncherClient) CancelVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error
- func (_m *MockLauncherClient) Close()
- func (_m *MockLauncherClient) DeleteDomain(vmi *v1.VirtualMachineInstance) error
- func (_m *MockLauncherClient) EXPECT() *_MockLauncherClientRecorder
- func (_m *MockLauncherClient) FinalizeVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error
- func (_m *MockLauncherClient) GetDomain() (*api.Domain, bool, error)
- func (_m *MockLauncherClient) GetDomainStats() (*stats.DomainStats, bool, error)
- func (_m *MockLauncherClient) GetFilesystems() (v1.VirtualMachineInstanceFileSystemList, error)
- func (_m *MockLauncherClient) GetGuestInfo() (*v1.VirtualMachineInstanceGuestAgentInfo, error)
- func (_m *MockLauncherClient) GetUsers() (v1.VirtualMachineInstanceGuestOSUserList, error)
- func (_m *MockLauncherClient) KillVirtualMachine(vmi *v1.VirtualMachineInstance) error
- func (_m *MockLauncherClient) MigrateVirtualMachine(vmi *v1.VirtualMachineInstance, options *MigrationOptions) error
- func (_m *MockLauncherClient) PauseVirtualMachine(vmi *v1.VirtualMachineInstance) error
- func (_m *MockLauncherClient) Ping() error
- func (_m *MockLauncherClient) ShutdownVirtualMachine(vmi *v1.VirtualMachineInstance) error
- func (_m *MockLauncherClient) SignalTargetPodCleanup(vmi *v1.VirtualMachineInstance) error
- func (_m *MockLauncherClient) SyncMigrationTarget(vmi *v1.VirtualMachineInstance) error
- func (_m *MockLauncherClient) SyncVirtualMachine(vmi *v1.VirtualMachineInstance, options *v10.VirtualMachineOptions) error
- func (_m *MockLauncherClient) UnpauseVirtualMachine(vmi *v1.VirtualMachineInstance) error
- type VirtLauncherClient
- func (c *VirtLauncherClient) CancelVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error
- func (c *VirtLauncherClient) Close()
- func (c *VirtLauncherClient) DeleteDomain(vmi *v1.VirtualMachineInstance) error
- func (c *VirtLauncherClient) FinalizeVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error
- func (c *VirtLauncherClient) GetDomain() (*api.Domain, bool, error)
- func (c *VirtLauncherClient) GetDomainStats() (*stats.DomainStats, bool, error)
- func (c *VirtLauncherClient) GetFilesystems() (v1.VirtualMachineInstanceFileSystemList, error)
- func (c *VirtLauncherClient) GetGuestInfo() (*v1.VirtualMachineInstanceGuestAgentInfo, error)
- func (c *VirtLauncherClient) GetUsers() (v1.VirtualMachineInstanceGuestOSUserList, error)
- func (c *VirtLauncherClient) KillVirtualMachine(vmi *v1.VirtualMachineInstance) error
- func (c *VirtLauncherClient) MigrateVirtualMachine(vmi *v1.VirtualMachineInstance, options *MigrationOptions) error
- func (c *VirtLauncherClient) PauseVirtualMachine(vmi *v1.VirtualMachineInstance) error
- func (c *VirtLauncherClient) Ping() error
- func (c *VirtLauncherClient) ShutdownVirtualMachine(vmi *v1.VirtualMachineInstance) error
- func (c *VirtLauncherClient) SignalTargetPodCleanup(vmi *v1.VirtualMachineInstance) error
- func (c *VirtLauncherClient) SyncMigrationTarget(vmi *v1.VirtualMachineInstance) error
- func (c *VirtLauncherClient) SyncVirtualMachine(vmi *v1.VirtualMachineInstance, options *cmdv1.VirtualMachineOptions) error
- func (c *VirtLauncherClient) UnpauseVirtualMachine(vmi *v1.VirtualMachineInstance) error
Constants ¶
View Source
const StandardInitLauncherSocketFileName = "launcher-init-sock"
View Source
const StandardLauncherSocketFileName = "launcher-sock"
View Source
const StandardLauncherUnresponsiveFileName = "launcher-unresponsive"
Variables ¶
This section is empty.
Functions ¶
func FindPodDirOnHost ¶ added in v0.30.6
func FindPodDirOnHost(vmi *v1.VirtualMachineInstance) (string, error)
gets the cmd socket for a VMI
func FindSocketOnHost ¶ added in v0.29.0
func FindSocketOnHost(vmi *v1.VirtualMachineInstance) (string, error)
gets the cmd socket for a VMI
func IsDisconnected ¶
func IsLegacySocket ¶ added in v0.29.0
func IsSocketUnresponsive ¶ added in v0.29.0
func LegacySocketsDirectory ¶ added in v0.29.0
func LegacySocketsDirectory() string
func ListAllSockets ¶
func MarkSocketUnresponsive ¶ added in v0.29.0
func SetLegacyBaseDir ¶ added in v0.29.0
func SetLegacyBaseDir(baseDir string)
func SetPodsBaseDir ¶ added in v0.29.0
func SetPodsBaseDir(baseDir string)
func SocketDirectoryOnHost ¶ added in v0.29.0
func SocketFilePathOnHost ¶ added in v0.29.0
func SocketMonitoringEnabled ¶ added in v0.29.0
func SocketOnGuest ¶ added in v0.29.0
func SocketOnGuest() string
func UninitializedSocketOnGuest ¶ added in v0.30.6
func UninitializedSocketOnGuest() string
Types ¶
type LauncherClient ¶
type LauncherClient interface { SyncVirtualMachine(vmi *v1.VirtualMachineInstance, options *cmdv1.VirtualMachineOptions) error PauseVirtualMachine(vmi *v1.VirtualMachineInstance) error UnpauseVirtualMachine(vmi *v1.VirtualMachineInstance) error SyncMigrationTarget(vmi *v1.VirtualMachineInstance) error SignalTargetPodCleanup(vmi *v1.VirtualMachineInstance) error ShutdownVirtualMachine(vmi *v1.VirtualMachineInstance) error KillVirtualMachine(vmi *v1.VirtualMachineInstance) error MigrateVirtualMachine(vmi *v1.VirtualMachineInstance, options *MigrationOptions) error CancelVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error FinalizeVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error DeleteDomain(vmi *v1.VirtualMachineInstance) error GetDomain() (*api.Domain, bool, error) GetDomainStats() (*stats.DomainStats, bool, error) GetGuestInfo() (*v1.VirtualMachineInstanceGuestAgentInfo, error) GetUsers() (v1.VirtualMachineInstanceGuestOSUserList, error) GetFilesystems() (v1.VirtualMachineInstanceFileSystemList, error) Ping() error Close() }
func NewClient ¶ added in v0.17.0
func NewClient(socketPath string) (LauncherClient, error)
func NewClientWithInfoClient ¶ added in v0.17.0
func NewClientWithInfoClient(infoClient info.CmdInfoClient, conn *grpc.ClientConn) (LauncherClient, error)
type MigrationOptions ¶ added in v0.16.0
type MockLauncherClient ¶
type MockLauncherClient struct {
// contains filtered or unexported fields
}
Mock of LauncherClient interface
func NewMockLauncherClient ¶
func NewMockLauncherClient(ctrl *gomock.Controller) *MockLauncherClient
func (*MockLauncherClient) CancelVirtualMachineMigration ¶ added in v0.16.0
func (_m *MockLauncherClient) CancelVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error
func (*MockLauncherClient) Close ¶
func (_m *MockLauncherClient) Close()
func (*MockLauncherClient) DeleteDomain ¶ added in v0.8.0
func (_m *MockLauncherClient) DeleteDomain(vmi *v1.VirtualMachineInstance) error
func (*MockLauncherClient) EXPECT ¶
func (_m *MockLauncherClient) EXPECT() *_MockLauncherClientRecorder
func (*MockLauncherClient) FinalizeVirtualMachineMigration ¶ added in v0.40.0
func (_m *MockLauncherClient) FinalizeVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error
func (*MockLauncherClient) GetDomain ¶
func (_m *MockLauncherClient) GetDomain() (*api.Domain, bool, error)
func (*MockLauncherClient) GetDomainStats ¶ added in v0.15.0
func (_m *MockLauncherClient) GetDomainStats() (*stats.DomainStats, bool, error)
func (*MockLauncherClient) GetFilesystems ¶ added in v0.28.0
func (_m *MockLauncherClient) GetFilesystems() (v1.VirtualMachineInstanceFileSystemList, error)
func (*MockLauncherClient) GetGuestInfo ¶ added in v0.27.0
func (_m *MockLauncherClient) GetGuestInfo() (*v1.VirtualMachineInstanceGuestAgentInfo, error)
func (*MockLauncherClient) GetUsers ¶ added in v0.28.0
func (_m *MockLauncherClient) GetUsers() (v1.VirtualMachineInstanceGuestOSUserList, error)
func (*MockLauncherClient) KillVirtualMachine ¶
func (_m *MockLauncherClient) KillVirtualMachine(vmi *v1.VirtualMachineInstance) error
func (*MockLauncherClient) MigrateVirtualMachine ¶ added in v0.9.2
func (_m *MockLauncherClient) MigrateVirtualMachine(vmi *v1.VirtualMachineInstance, options *MigrationOptions) error
func (*MockLauncherClient) PauseVirtualMachine ¶ added in v0.24.0
func (_m *MockLauncherClient) PauseVirtualMachine(vmi *v1.VirtualMachineInstance) error
func (*MockLauncherClient) Ping ¶
func (_m *MockLauncherClient) Ping() error
func (*MockLauncherClient) ShutdownVirtualMachine ¶
func (_m *MockLauncherClient) ShutdownVirtualMachine(vmi *v1.VirtualMachineInstance) error
func (*MockLauncherClient) SignalTargetPodCleanup ¶ added in v0.36.3
func (_m *MockLauncherClient) SignalTargetPodCleanup(vmi *v1.VirtualMachineInstance) error
func (*MockLauncherClient) SyncMigrationTarget ¶ added in v0.9.2
func (_m *MockLauncherClient) SyncMigrationTarget(vmi *v1.VirtualMachineInstance) error
func (*MockLauncherClient) SyncVirtualMachine ¶
func (_m *MockLauncherClient) SyncVirtualMachine(vmi *v1.VirtualMachineInstance, options *v10.VirtualMachineOptions) error
func (*MockLauncherClient) UnpauseVirtualMachine ¶ added in v0.24.0
func (_m *MockLauncherClient) UnpauseVirtualMachine(vmi *v1.VirtualMachineInstance) error
type VirtLauncherClient ¶
type VirtLauncherClient struct {
// contains filtered or unexported fields
}
func (*VirtLauncherClient) CancelVirtualMachineMigration ¶ added in v0.16.0
func (c *VirtLauncherClient) CancelVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error
func (*VirtLauncherClient) Close ¶
func (c *VirtLauncherClient) Close()
func (*VirtLauncherClient) DeleteDomain ¶ added in v0.8.0
func (c *VirtLauncherClient) DeleteDomain(vmi *v1.VirtualMachineInstance) error
func (*VirtLauncherClient) FinalizeVirtualMachineMigration ¶ added in v0.40.0
func (c *VirtLauncherClient) FinalizeVirtualMachineMigration(vmi *v1.VirtualMachineInstance) error
func (*VirtLauncherClient) GetDomain ¶
func (c *VirtLauncherClient) GetDomain() (*api.Domain, bool, error)
func (*VirtLauncherClient) GetDomainStats ¶ added in v0.15.0
func (c *VirtLauncherClient) GetDomainStats() (*stats.DomainStats, bool, error)
func (*VirtLauncherClient) GetFilesystems ¶ added in v0.28.0
func (c *VirtLauncherClient) GetFilesystems() (v1.VirtualMachineInstanceFileSystemList, error)
GetFilesystems returns the list of active filesystems on the guest machine
func (*VirtLauncherClient) GetGuestInfo ¶ added in v0.27.0
func (c *VirtLauncherClient) GetGuestInfo() (*v1.VirtualMachineInstanceGuestAgentInfo, error)
GetGuestInfo is a counterpart for virt-launcher call to gather guest agent data
func (*VirtLauncherClient) GetUsers ¶ added in v0.28.0
func (c *VirtLauncherClient) GetUsers() (v1.VirtualMachineInstanceGuestOSUserList, error)
GetUsers returns the list of the active users on the guest machine
func (*VirtLauncherClient) KillVirtualMachine ¶
func (c *VirtLauncherClient) KillVirtualMachine(vmi *v1.VirtualMachineInstance) error
func (*VirtLauncherClient) MigrateVirtualMachine ¶ added in v0.9.2
func (c *VirtLauncherClient) MigrateVirtualMachine(vmi *v1.VirtualMachineInstance, options *MigrationOptions) error
func (*VirtLauncherClient) PauseVirtualMachine ¶ added in v0.24.0
func (c *VirtLauncherClient) PauseVirtualMachine(vmi *v1.VirtualMachineInstance) error
func (*VirtLauncherClient) Ping ¶
func (c *VirtLauncherClient) Ping() error
func (*VirtLauncherClient) ShutdownVirtualMachine ¶
func (c *VirtLauncherClient) ShutdownVirtualMachine(vmi *v1.VirtualMachineInstance) error
func (*VirtLauncherClient) SignalTargetPodCleanup ¶ added in v0.36.3
func (c *VirtLauncherClient) SignalTargetPodCleanup(vmi *v1.VirtualMachineInstance) error
func (*VirtLauncherClient) SyncMigrationTarget ¶ added in v0.9.2
func (c *VirtLauncherClient) SyncMigrationTarget(vmi *v1.VirtualMachineInstance) error
func (*VirtLauncherClient) SyncVirtualMachine ¶
func (c *VirtLauncherClient) SyncVirtualMachine(vmi *v1.VirtualMachineInstance, options *cmdv1.VirtualMachineOptions) error
func (*VirtLauncherClient) UnpauseVirtualMachine ¶ added in v0.24.0
func (c *VirtLauncherClient) UnpauseVirtualMachine(vmi *v1.VirtualMachineInstance) error
Click to show internal directories.
Click to hide internal directories.