cmdclient

package
v0.23.1 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 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, options *cmdv1.VirtualMachineOptions) 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, options *v10.VirtualMachineOptions) 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, options *cmdv1.VirtualMachineOptions) error

Source Files

View all Source files

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.