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(vm *v10.VirtualMachine) error
  • func (_m *MockLauncherClient) Ping() error
  • func (_m *MockLauncherClient) ShutdownVirtualMachine(vm *v10.VirtualMachine) error
  • func (_m *MockLauncherClient) SyncSecret(vm *v10.VirtualMachine, usageType string, usageID string, secretValue string) error
  • func (_m *MockLauncherClient) SyncVirtualMachine(vm *v10.VirtualMachine, secrets map[string]*v1.Secret) error
• type Reply
• type VirtLauncherClient
  • func (c *VirtLauncherClient) Close()
  • func (c *VirtLauncherClient) GetDomain() (*api.Domain, bool, error)
  • func (c *VirtLauncherClient) KillVirtualMachine(vm *v1.VirtualMachine) error
  • func (c *VirtLauncherClient) Ping() error
  • func (c *VirtLauncherClient) ShutdownVirtualMachine(vm *v1.VirtualMachine) error
  • func (c *VirtLauncherClient) SyncSecret(vm *v1.VirtualMachine, usageType string, usageID string, secretValue string) error
  • func (c *VirtLauncherClient) SyncVirtualMachine(vm *v1.VirtualMachine, secrets map[string]*k8sv1.Secret) 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
	VM        *v1.VirtualMachine
	K8Secrets map[string]*k8sv1.Secret

	// used for syncing secrets
	SecretUsageType string
	SecretUsageID   string
	SecretValue     string
}

type LauncherClient

type LauncherClient interface {
	SyncVirtualMachine(vm *v1.VirtualMachine, secrets map[string]*k8sv1.Secret) error
	ShutdownVirtualMachine(vm *v1.VirtualMachine) error
	KillVirtualMachine(vm *v1.VirtualMachine) error
	SyncSecret(vm *v1.VirtualMachine, usageType string, usageID string, secretValue string) 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(vm *v10.VirtualMachine) error

func (*MockLauncherClient) Ping

func (_m *MockLauncherClient) Ping() error

func (*MockLauncherClient) ShutdownVirtualMachine

func (_m *MockLauncherClient) ShutdownVirtualMachine(vm *v10.VirtualMachine) error

func (*MockLauncherClient) SyncSecret

func (_m *MockLauncherClient) SyncSecret(vm *v10.VirtualMachine, usageType string, usageID string, secretValue string) error

func (*MockLauncherClient) SyncVirtualMachine

func (_m *MockLauncherClient) SyncVirtualMachine(vm *v10.VirtualMachine, secrets map[string]*v1.Secret) 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(vm *v1.VirtualMachine) error

func (*VirtLauncherClient) Ping

func (c *VirtLauncherClient) Ping() error

func (*VirtLauncherClient) ShutdownVirtualMachine

func (c *VirtLauncherClient) ShutdownVirtualMachine(vm *v1.VirtualMachine) error

func (*VirtLauncherClient) SyncSecret

func (c *VirtLauncherClient) SyncSecret(vm *v1.VirtualMachine, usageType string, usageID string, secretValue string) error

func (*VirtLauncherClient) SyncVirtualMachine

func (c *VirtLauncherClient) SyncVirtualMachine(vm *v1.VirtualMachine, secrets map[string]*k8sv1.Secret) error