cli

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2017 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const ConnectionInterval = 10 * time.Second
View Source 
const ConnectionTimeout = 15 * time.Second

Variables

This section is empty.

Functions

func IsDown added in v0.0.3 

func IsDown(domState libvirt.DomainState) bool

func IsPaused added in v0.0.3 

func IsPaused(domState libvirt.DomainState) bool

Types

type Connection 

type Connection interface {
	LookupDomainByName(name string) (VirDomain, error)
	DomainDefineXML(xml string) (VirDomain, error)
	Close() (int, error)
	DomainEventLifecycleRegister(callback libvirt.DomainEventLifecycleCallback) error
	ListAllDomains(flags libvirt.ConnectListAllDomainsFlags) ([]VirDomain, error)
	NewStream(flags libvirt.StreamFlags) (Stream, error)
	LookupSecretByUsage(usageType libvirt.SecretUsageType, usageID string) (VirSecret, error)
	SecretDefineXML(xml string) (VirSecret, error)
	ListSecrets() ([]string, error)
	LookupSecretByUUIDString(uuid string) (VirSecret, error)
	ListAllSecrets(flags libvirt.ConnectListAllSecretsFlags) ([]VirSecret, error)
}

TODO: Should we handle libvirt connection errors transparent or panic?

func NewConnection 

func NewConnection(uri string, user string, pass string, checkInterval time.Duration) (Connection, error)

type LibvirtConnection 

type LibvirtConnection struct {
	Connect *libvirt.Connect
	// contains filtered or unexported fields
}

func (*LibvirtConnection) Close 

func (l *LibvirtConnection) Close() (int, error)

func (*LibvirtConnection) DomainDefineXML 

func (l *LibvirtConnection) DomainDefineXML(xml string) (dom VirDomain, err error)

func (*LibvirtConnection) DomainEventLifecycleRegister 

func (l *LibvirtConnection) DomainEventLifecycleRegister(callback libvirt.DomainEventLifecycleCallback) (err error)

func (*LibvirtConnection) ListAllDomains 

func (l *LibvirtConnection) ListAllDomains(flags libvirt.ConnectListAllDomainsFlags) ([]VirDomain, error)

func (*LibvirtConnection) ListAllSecrets 

func (l *LibvirtConnection) ListAllSecrets(flags libvirt.ConnectListAllSecretsFlags) ([]VirSecret, error)

func (*LibvirtConnection) ListSecrets 

func (l *LibvirtConnection) ListSecrets() (secrets []string, err error)

func (*LibvirtConnection) LookupDomainByName 

func (l *LibvirtConnection) LookupDomainByName(name string) (dom VirDomain, err error)

func (*LibvirtConnection) LookupSecretByUUIDString 

func (l *LibvirtConnection) LookupSecretByUUIDString(uuid string) (secret VirSecret, err error)

func (*LibvirtConnection) LookupSecretByUsage 

func (l *LibvirtConnection) LookupSecretByUsage(usageType libvirt.SecretUsageType, usageID string) (secret VirSecret, err error)

func (*LibvirtConnection) NewStream 

func (l *LibvirtConnection) NewStream(flags libvirt.StreamFlags) (Stream, error)

func (*LibvirtConnection) SecretDefineXML 

func (l *LibvirtConnection) SecretDefineXML(xml string) (secret VirSecret, err error)

type MockConnection 

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

Mock of Connection interface

func NewMockConnection 

func NewMockConnection(ctrl *gomock.Controller) *MockConnection

func (*MockConnection) Close 

func (_m *MockConnection) Close() (int, error)

func (*MockConnection) DomainDefineXML 

func (_m *MockConnection) DomainDefineXML(xml string) (VirDomain, error)

func (*MockConnection) DomainEventLifecycleRegister 

func (_m *MockConnection) DomainEventLifecycleRegister(callback libvirt_go.DomainEventLifecycleCallback) error

func (*MockConnection) EXPECT 

func (_m *MockConnection) EXPECT() *_MockConnectionRecorder

func (*MockConnection) ListAllDomains 

func (_m *MockConnection) ListAllDomains(flags libvirt_go.ConnectListAllDomainsFlags) ([]VirDomain, error)

func (*MockConnection) ListAllSecrets 

func (_m *MockConnection) ListAllSecrets(flags libvirt_go.ConnectListAllSecretsFlags) ([]VirSecret, error)

func (*MockConnection) ListSecrets 

func (_m *MockConnection) ListSecrets() ([]string, error)

func (*MockConnection) LookupDomainByName 

func (_m *MockConnection) LookupDomainByName(name string) (VirDomain, error)

func (*MockConnection) LookupSecretByUUIDString 

func (_m *MockConnection) LookupSecretByUUIDString(uuid string) (VirSecret, error)

func (*MockConnection) LookupSecretByUsage 

func (_m *MockConnection) LookupSecretByUsage(usageType libvirt_go.SecretUsageType, usageID string) (VirSecret, error)

func (*MockConnection) NewStream 

func (_m *MockConnection) NewStream(flags libvirt_go.StreamFlags) (Stream, error)

func (*MockConnection) SecretDefineXML 

func (_m *MockConnection) SecretDefineXML(xml string) (VirSecret, error)

type MockStream 

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

Mock of Stream interface

func NewMockStream 

func NewMockStream(ctrl *gomock.Controller) *MockStream

func (*MockStream) Close 

func (_m *MockStream) Close() error

func (*MockStream) EXPECT 

func (_m *MockStream) EXPECT() *_MockStreamRecorder

func (*MockStream) Read 

func (_m *MockStream) Read(p []byte) (int, error)

func (*MockStream) UnderlyingStream 

func (_m *MockStream) UnderlyingStream() *libvirt_go.Stream

func (*MockStream) Write 

func (_m *MockStream) Write(p []byte) (int, error)

type MockVirDomain 

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

Mock of VirDomain interface

func NewMockVirDomain 

func NewMockVirDomain(ctrl *gomock.Controller) *MockVirDomain

func (*MockVirDomain) Create 

func (_m *MockVirDomain) Create() error

func (*MockVirDomain) Destroy 

func (_m *MockVirDomain) Destroy() error

func (*MockVirDomain) EXPECT 

func (_m *MockVirDomain) EXPECT() *_MockVirDomainRecorder

func (*MockVirDomain) Free 

func (_m *MockVirDomain) Free() error

func (*MockVirDomain) GetName 

func (_m *MockVirDomain) GetName() (string, error)

func (*MockVirDomain) GetState 

func (_m *MockVirDomain) GetState() (libvirt_go.DomainState, int, error)

func (*MockVirDomain) GetUUIDString 

func (_m *MockVirDomain) GetUUIDString() (string, error)

func (*MockVirDomain) GetXMLDesc 

func (_m *MockVirDomain) GetXMLDesc(flags libvirt_go.DomainXMLFlags) (string, error)

func (*MockVirDomain) OpenConsole 

func (_m *MockVirDomain) OpenConsole(devname string, stream *libvirt_go.Stream, flags libvirt_go.DomainConsoleFlags) error

func (*MockVirDomain) Resume 

func (_m *MockVirDomain) Resume() error

func (*MockVirDomain) Undefine 

func (_m *MockVirDomain) Undefine() error

type MockVirSecret 

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

Mock of VirSecret interface

func NewMockVirSecret 

func NewMockVirSecret(ctrl *gomock.Controller) *MockVirSecret

func (*MockVirSecret) EXPECT 

func (_m *MockVirSecret) EXPECT() *_MockVirSecretRecorder

func (*MockVirSecret) Free 

func (_m *MockVirSecret) Free() error

func (*MockVirSecret) GetUUIDString 

func (_m *MockVirSecret) GetUUIDString() (string, error)

func (*MockVirSecret) GetUsageID 

func (_m *MockVirSecret) GetUsageID() (string, error)

func (*MockVirSecret) GetXMLDesc 

func (_m *MockVirSecret) GetXMLDesc(flags uint32) (string, error)

func (*MockVirSecret) SetValue 

func (_m *MockVirSecret) SetValue(value []byte, flags uint32) error

func (*MockVirSecret) Undefine 

func (_m *MockVirSecret) Undefine() error

type Stream 

type Stream interface {
	io.ReadWriteCloser
	UnderlyingStream() *libvirt.Stream
}

type VirDomain 

type VirDomain interface {
	GetState() (libvirt.DomainState, int, error)
	Create() error
	Resume() error
	Destroy() error
	GetName() (string, error)
	GetUUIDString() (string, error)
	GetXMLDesc(flags libvirt.DomainXMLFlags) (string, error)
	Undefine() error
	OpenConsole(devname string, stream *libvirt.Stream, flags libvirt.DomainConsoleFlags) error
	Free() error
}

type VirSecret 

type VirSecret interface {
	SetValue(value []byte, flags uint32) error
	Undefine() error
	GetUsageID() (string, error)
	GetUUIDString() (string, error)
	GetXMLDesc(flags uint32) (string, error)
	Free() error
}

type VirStream 

type VirStream struct {
	*libvirt.Stream
}

func (*VirStream) Close 

func (s *VirStream) Close() (e error)

Close the stream and free its resources. Since closing a stream involves multiple calls with errors, the first error occurred will be returned. The stream will always be freed.

func (*VirStream) Read 

func (s *VirStream) Read(p []byte) (n int, err error)

func (*VirStream) UnderlyingStream 

func (s *VirStream) UnderlyingStream() *libvirt.Stream

func (*VirStream) Write 

func (s *VirStream) Write(p []byte) (n int, err 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.