cmdclient

Documentation

Index

• func DomainFromSocketPath(socketPath string) (*api.Domain, error)
• func IsDisconnected(err error) bool
• func ListAllSockets(baseDir string) ([]string, error)
• func SocketFromNamespaceName(baseDir string, namespace string, name string) string
• func SocketsDirectory(baseDir string) string
• type Args
• type LauncherClient
  • func GetClient(socketPath string) (LauncherClient, error)
• type MockLauncherClient
  • func NewMockLauncherClient(ctrl *gomock.Controller) *MockLauncherClient
  • func (_m *MockLauncherClient) Close()
  • func (_m *MockLauncherClient) EXPECT() *_MockLauncherClientRecorder
  • func (_m *MockLauncherClient) GetDomain() (*api.Domain, bool, error)
  • func (_m *MockLauncherClient) KillVirtualMachine(vmi *v1.VirtualMachineInstance) error
  • func (_m *MockLauncherClient) Ping() error
  • func (_m *MockLauncherClient) ShutdownVirtualMachine(vmi *v1.VirtualMachineInstance) error
  • func (_m *MockLauncherClient) SyncVirtualMachine(vmi *v1.VirtualMachineInstance) error
• type Reply
• type VirtLauncherClient
  • func (c *VirtLauncherClient) Close()
  • func (c *VirtLauncherClient) GetDomain() (*api.Domain, bool, error)
  • func (c *VirtLauncherClient) KillVirtualMachine(vmi *v1.VirtualMachineInstance) error
  • func (c *VirtLauncherClient) Ping() error
  • func (c *VirtLauncherClient) ShutdownVirtualMachine(vmi *v1.VirtualMachineInstance) error
  • func (c *VirtLauncherClient) SyncVirtualMachine(vmi *v1.VirtualMachineInstance) error

Functions

func DomainFromSocketPath

func DomainFromSocketPath(socketPath string) (*api.Domain, error)

func IsDisconnected

func IsDisconnected(err error) bool

func ListAllSockets

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

func SocketFromNamespaceName

func SocketFromNamespaceName(baseDir string, namespace string, name string) string

func SocketsDirectory

func SocketsDirectory(baseDir string) string

Types

type Args

type Args struct {
	// used for domain management
	VMI *v1.VirtualMachineInstance
}

type LauncherClient

type LauncherClient interface {
	SyncVirtualMachine(vmi *v1.VirtualMachineInstance) error
	ShutdownVirtualMachine(vmi *v1.VirtualMachineInstance) error
	KillVirtualMachine(vmi *v1.VirtualMachineInstance) error
	GetDomain() (*api.Domain, bool, error)
	Ping() error
	Close()
}

func GetClient

func GetClient(socketPath string) (LauncherClient, error)

type MockLauncherClient

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

Mock of LauncherClient interface

func NewMockLauncherClient

func NewMockLauncherClient(ctrl *gomock.Controller) *MockLauncherClient

func (*MockLauncherClient) Close

func (_m *MockLauncherClient) Close()

func (*MockLauncherClient) EXPECT

func (_m *MockLauncherClient) EXPECT() *_MockLauncherClientRecorder

func (*MockLauncherClient) GetDomain

func (_m *MockLauncherClient) GetDomain() (*api.Domain, bool, error)

func (*MockLauncherClient) KillVirtualMachine

func (_m *MockLauncherClient) KillVirtualMachine(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) SyncVirtualMachine

func (_m *MockLauncherClient) SyncVirtualMachine(vmi *v1.VirtualMachineInstance) error

type Reply

type Reply struct {
	Success bool
	Message string
	Domain  *api.Domain
}

type VirtLauncherClient

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

func (*VirtLauncherClient) Close

func (c *VirtLauncherClient) Close()

func (*VirtLauncherClient) GetDomain

func (c *VirtLauncherClient) GetDomain() (*api.Domain, bool, error)

func (*VirtLauncherClient) KillVirtualMachine

func (c *VirtLauncherClient) KillVirtualMachine(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) SyncVirtualMachine

func (c *VirtLauncherClient) SyncVirtualMachine(vmi *v1.VirtualMachineInstance) error