eventsclient

Documentation

Index

• type Notifier
  • func NewNotifier(virtShareDir string) *Notifier
  • func (n *Notifier) Close()
  • func (n *Notifier) SendDomainEvent(event watch.Event) error
  • func (n *Notifier) SendK8sEvent(vmi *v1.VirtualMachineInstance, severity string, reason string, message string) error
  • func (n *Notifier) SetCustomTimeouts(interval, send, total time.Duration)
  • func (n *Notifier) StartDomainNotifier(domainConn cli.Connection, deleteNotificationSent chan watch.Event, ...) error

Types

type Notifier

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

func NewNotifier

func NewNotifier(virtShareDir string) *Notifier

func (*Notifier) Close

func (n *Notifier) Close()

func (*Notifier) SendDomainEvent

func (n *Notifier) SendDomainEvent(event watch.Event) error

func (*Notifier) SendK8sEvent

func (n *Notifier) SendK8sEvent(vmi *v1.VirtualMachineInstance, severity string, reason string, message string) error

func (*Notifier) SetCustomTimeouts

func (n *Notifier) SetCustomTimeouts(interval, send, total time.Duration)

used by unit tests

func (*Notifier) StartDomainNotifier

func (n *Notifier) StartDomainNotifier(
	domainConn cli.Connection,
	deleteNotificationSent chan watch.Event,
	vmi *v1.VirtualMachineInstance,
	domainName string,
	agentStore *agentpoller.AsyncAgentStore,
	qemuAgentSysInterval time.Duration,
	qemuAgentFileInterval time.Duration,
	qemuAgentUserInterval time.Duration,
	qemuAgentVersionInterval time.Duration,
	qemuAgentFSFreezeStatusInterval time.Duration,
	metadataCache *metadata.Cache,
) error