monitor

Documentation

Index

• type Pool
  • func NewPool(mondir string) *Pool
  • func (p *Pool) CloseMonitor(vmname string)
  • func (p *Pool) Exists(vmname string) bool
  • func (p *Pool) FindBlockJobCompletedEvent(vmname, device string, after uint64) (*qmp.Event, bool, error)
  • func (p *Pool) FindBlockJobErrorEvent(vmname, device string, after uint64) (*qmp.Event, bool, error)
  • func (p *Pool) FindEvents(vmname string, t string, after uint64) ([]qmp.Event, bool, error)
  • func (p *Pool) Get(vmname string) (*qmp.Monitor, bool)
  • func (p *Pool) GetEvents(vmname string, ctx context.Context, t string, after uint64) ([]qmp.Event, error)
  • func (p *Pool) NewMonitor(vmname string) (*qmp.Monitor, error)
  • func (p *Pool) Run(vmname string, cmd interface{}, res interface{}) error
  • func (p *Pool) RunTransaction(vmname string, cmds []qmp.Command, res interface{}) error
  • func (p *Pool) WaitDeviceDeletedEvent(vmname string, ctx context.Context, device string, after uint64) (*qmp.Event, error)
  • func (p *Pool) WaitJobStatusChangeEvent(vmname string, ctx context.Context, jobID, status string, after uint64) (*qmp.Event, error)
  • func (p *Pool) WaitMachineResumeStateEvent(vmname string, ctx context.Context, after uint64) (*qmp.Event, error)

Types

type Pool

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

Pool represents a pool of QMPConn objects accessed by virtual machine name

func NewPool

func NewPool(mondir string) *Pool

func (*Pool) CloseMonitor

func (p *Pool) CloseMonitor(vmname string)

func (*Pool) Exists

func (p *Pool) Exists(vmname string) bool

func (*Pool) FindBlockJobCompletedEvent

func (p *Pool) FindBlockJobCompletedEvent(vmname, device string, after uint64) (*qmp.Event, bool, error)

func (*Pool) FindBlockJobErrorEvent

func (p *Pool) FindBlockJobErrorEvent(vmname, device string, after uint64) (*qmp.Event, bool, error)

func (*Pool) FindEvents

func (p *Pool) FindEvents(vmname string, t string, after uint64) ([]qmp.Event, bool, error)

func (*Pool) Get

func (p *Pool) Get(vmname string) (*qmp.Monitor, bool)

func (*Pool) GetEvents

func (p *Pool) GetEvents(vmname string, ctx context.Context, t string, after uint64) ([]qmp.Event, error)

func (*Pool) NewMonitor

func (p *Pool) NewMonitor(vmname string) (*qmp.Monitor, error)

func (*Pool) Run

func (p *Pool) Run(vmname string, cmd interface{}, res interface{}) error

func (*Pool) RunTransaction

func (p *Pool) RunTransaction(vmname string, cmds []qmp.Command, res interface{}) error

func (*Pool) WaitDeviceDeletedEvent

func (p *Pool) WaitDeviceDeletedEvent(vmname string, ctx context.Context, device string, after uint64) (*qmp.Event, error)

func (*Pool) WaitJobStatusChangeEvent

func (p *Pool) WaitJobStatusChangeEvent(vmname string, ctx context.Context, jobID, status string, after uint64) (*qmp.Event, error)

func (*Pool) WaitMachineResumeStateEvent

func (p *Pool) WaitMachineResumeStateEvent(vmname string, ctx context.Context, after uint64) (*qmp.Event, error)