cmdclient

package
v0.20.5 Latest Latest
Warning

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

Go to latest
Published: Sep 5, 2019 License: Apache-2.0 Imports: 25 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsDisconnected

func IsDisconnected(err error) bool

func ListAllSockets

func ListAllSockets(baseDir string) ([]string, error)

func SocketFromUID added in v0.8.0

func SocketFromUID(baseDir string, uid string) string

func SocketsDirectory

func SocketsDirectory(baseDir string) string

Types

type LauncherClient

type LauncherClient interface {
	SyncVirtualMachine(vmi *v1.VirtualMachineInstance) error
	SyncMigrationTarget(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
	DeleteDomain(vmi *v1.VirtualMachineInstance) error
	GetDomain() (*api.Domain, bool, error)
	GetDomainStats() (*stats.DomainStats, bool, 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 MigrationOptions struct {
	Bandwidth               resource.Quantity
	ProgressTimeout         int64
	CompletionTimeoutPerGiB int64
	UnsafeMigration         bool
	AllowAutoConverge       bool
}

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) 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) 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) Ping

func (_m *MockLauncherClient) Ping() error

func (*MockLauncherClient) ShutdownVirtualMachine

func (_m *MockLauncherClient) ShutdownVirtualMachine(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) 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) 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) 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) Ping

func (c *VirtLauncherClient) Ping() error

func (*VirtLauncherClient) ShutdownVirtualMachine

func (c *VirtLauncherClient) ShutdownVirtualMachine(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) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL