monitor

package
v0.3.9-2 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2022 License: Apache-2.0 Imports: 18 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockJob 

type BlockJob struct {
	Busy bool
	// commit|
	Type   string
	Len    int64
	Paused bool
	Ready  bool
	// running|ready
	Status string
	// ok|
	IoStatus string `json:"io-status"`
	Offset   int64
	Device   string
	Speed    int64
	// contains filtered or unexported fields
}

func (*BlockJob) PreOffset 

func (self *BlockJob) PreOffset(preOffset int64)

type Command 

type Command struct {
	Execute string      `json:"execute"`
	Args    interface{} `json:"arguments,omitempty"`
}

type Error 

type Error struct {
	Class string `json:"class"`
	Desc  string `json:"desc"`
}

func (*Error) Error 

func (e *Error) Error() string

type Event 

type Event struct {
	Event     string                 `json:"event"`
	Data      map[string]interface{} `json:"data"`
	Timestamp *Timestamp             `json:"timestamp"`
}

func (*Event) String 

func (e *Event) String() string

type HmpMonitor 

type HmpMonitor struct {
	SBaseMonitor
	// contains filtered or unexported fields
}

func NewHmpMonitor 

func NewHmpMonitor(server, sid string, OnMonitorDisConnect, OnMonitorTimeout MonitorErrorFunc, OnMonitorConnected MonitorSuccFunc) *HmpMonitor

func (*HmpMonitor) AddCpu 

func (m *HmpMonitor) AddCpu(cpuIndex int, callback StringCallback)

func (*HmpMonitor) BlockIoThrottle 

func (m *HmpMonitor) BlockIoThrottle(driveName string, bps, iops int64, callback StringCallback)

func (*HmpMonitor) BlockJobComplete 

func (m *HmpMonitor) BlockJobComplete(drive string, callback StringCallback)

func (*HmpMonitor) BlockReopenImage 

func (m *HmpMonitor) BlockReopenImage(drive, newImagePath, format string, cb StringCallback)

func (*HmpMonitor) BlockStream 

func (m *HmpMonitor) BlockStream(drive string, _, _ int, callback StringCallback)

func (*HmpMonitor) CancelBlockJob 

func (m *HmpMonitor) CancelBlockJob(driveName string, force bool, callback StringCallback)

func (*HmpMonitor) ChangeCdrom 

func (m *HmpMonitor) ChangeCdrom(dev string, path string, callback StringCallback)

func (*HmpMonitor) Connect 

func (m *HmpMonitor) Connect(host string, port int) error

func (*HmpMonitor) ConnectWithSocket 

func (m *HmpMonitor) ConnectWithSocket(address string) error

func (*HmpMonitor) DeviceAdd 

func (m *HmpMonitor) DeviceAdd(dev string, params map[string]interface{}, callback StringCallback)

func (*HmpMonitor) DeviceDel 

func (m *HmpMonitor) DeviceDel(idstr string, callback StringCallback)

func (*HmpMonitor) DriveAdd 

func (m *HmpMonitor) DriveAdd(bus string, params map[string]string, callback StringCallback)

func (*HmpMonitor) DriveDel 

func (m *HmpMonitor) DriveDel(idstr string, callback StringCallback)

func (*HmpMonitor) DriveMirror 

func (m *HmpMonitor) DriveMirror(callback StringCallback, drive, target, syncMode, format string, unmap, blockReplication bool)

func (*HmpMonitor) EjectCdrom 

func (m *HmpMonitor) EjectCdrom(dev string, callback StringCallback)

func (*HmpMonitor) GeMemtSlotIndex 

func (m *HmpMonitor) GeMemtSlotIndex(callback func(index int))

func (*HmpMonitor) GetBlockJobCounts 

func (m *HmpMonitor) GetBlockJobCounts(callback func(jobs int))

func (*HmpMonitor) GetBlockJobs 

func (m *HmpMonitor) GetBlockJobs(callback func([]BlockJob))

func (*HmpMonitor) GetBlocks 

func (m *HmpMonitor) GetBlocks(callback func([]QemuBlock))

func (*HmpMonitor) GetCpuCount 

func (m *HmpMonitor) GetCpuCount(callback func(count int))

func (*HmpMonitor) GetMigrateStatus 

func (m *HmpMonitor) GetMigrateStatus(callback StringCallback)

func (*HmpMonitor) GetVersion 

func (m *HmpMonitor) GetVersion(callback StringCallback)

func (*HmpMonitor) HumanMonitorCommand 

func (m *HmpMonitor) HumanMonitorCommand(cmd string, callback StringCallback)

func (*HmpMonitor) Migrate 

func (m *HmpMonitor) Migrate(
	destStr string, copyIncremental, copyFull bool, callback StringCallback,
)

func (*HmpMonitor) MigrateIncoming 

func (m *HmpMonitor) MigrateIncoming(address string, callback StringCallback)

func (*HmpMonitor) MigrateSetCapability 

func (m *HmpMonitor) MigrateSetCapability(capability, state string, callback StringCallback)

func (*HmpMonitor) MigrateSetDowntime 

func (m *HmpMonitor) MigrateSetDowntime(dtSec float32, callback StringCallback)

func (*HmpMonitor) MigrateSetParameter 

func (m *HmpMonitor) MigrateSetParameter(key string, val interface{}, callback StringCallback)

func (*HmpMonitor) MigrateStartPostcopy 

func (m *HmpMonitor) MigrateStartPostcopy(callback StringCallback)

func (*HmpMonitor) NetdevAdd 

func (m *HmpMonitor) NetdevAdd(id, netType string, params map[string]string, callback StringCallback)

func (*HmpMonitor) NetdevDel 

func (m *HmpMonitor) NetdevDel(id string, callback StringCallback)

func (*HmpMonitor) ObjectAdd 

func (m *HmpMonitor) ObjectAdd(objectType string, params map[string]string, callback StringCallback)

func (*HmpMonitor) ObjectDel 

func (m *HmpMonitor) ObjectDel(idstr string, callback StringCallback)

func (*HmpMonitor) Query 

func (m *HmpMonitor) Query(cmd string, cb StringCallback)

func (*HmpMonitor) QueryStatus 

func (m *HmpMonitor) QueryStatus(callback StringCallback)

func (*HmpMonitor) ReloadDiskBlkdev 

func (m *HmpMonitor) ReloadDiskBlkdev(device, path string, callback StringCallback)

func (*HmpMonitor) ResizeDisk 

func (m *HmpMonitor) ResizeDisk(driveName string, sizeMB int64, callback StringCallback)

func (*HmpMonitor) SaveState 

func (m *HmpMonitor) SaveState(stateFilePath string, callback StringCallback)

func (*HmpMonitor) SetVncPassword 

func (m *HmpMonitor) SetVncPassword(proto, password string, callback StringCallback)

func (*HmpMonitor) SimpleCommand 

func (m *HmpMonitor) SimpleCommand(cmd string, callback StringCallback)

func (*HmpMonitor) SnapshotBlkdev 

func (m *HmpMonitor) SnapshotBlkdev(drive, newImagePath, format string, reuse bool, cb StringCallback)

func (*HmpMonitor) StartNbdServer 

func (m *HmpMonitor) StartNbdServer(port int, exportAllDevice, writable bool, callback StringCallback)

type Monitor 

type Monitor interface {
	Connect(host string, port int) error
	ConnectWithSocket(address string) error
	Disconnect()
	IsConnected() bool

	// The callback function will be called in another goroutine
	SimpleCommand(cmd string, callback StringCallback)
	HumanMonitorCommand(cmd string, callback StringCallback)

	QueryStatus(StringCallback)
	GetVersion(StringCallback)
	GetBlockJobCounts(func(jobs int))
	GetBlockJobs(func([]BlockJob))

	GetCpuCount(func(count int))
	AddCpu(cpuIndex int, callback StringCallback)
	GeMemtSlotIndex(func(index int))

	GetBlocks(callback func([]QemuBlock))
	EjectCdrom(dev string, callback StringCallback)
	ChangeCdrom(dev string, path string, callback StringCallback)

	DriveDel(idstr string, callback StringCallback)
	DeviceDel(idstr string, callback StringCallback)
	ObjectDel(idstr string, callback StringCallback)

	ObjectAdd(objectType string, params map[string]string, callback StringCallback)
	DriveAdd(bus string, params map[string]string, callback StringCallback)
	DeviceAdd(dev string, params map[string]interface{}, callback StringCallback)

	BlockStream(drive string, idx, blkCnt int, callback StringCallback)
	DriveMirror(callback StringCallback, drive, target, syncMode, format string, unmap, blockReplication bool)
	BlockJobComplete(drive string, cb StringCallback)
	BlockReopenImage(drive, newImagePath, format string, cb StringCallback)
	SnapshotBlkdev(drive, newImagePath, format string, reuse bool, cb StringCallback)

	MigrateSetDowntime(dtSec float32, callback StringCallback)
	MigrateSetCapability(capability, state string, callback StringCallback)
	MigrateSetParameter(key string, val interface{}, callback StringCallback)
	MigrateIncoming(address string, callback StringCallback)
	Migrate(destStr string, copyIncremental, copyFull bool, callback StringCallback)
	GetMigrateStatus(callback StringCallback)
	MigrateStartPostcopy(callback StringCallback)

	ReloadDiskBlkdev(device, path string, callback StringCallback)
	SetVncPassword(proto, password string, callback StringCallback)
	StartNbdServer(port int, exportAllDevice, writable bool, callback StringCallback)

	ResizeDisk(driveName string, sizeMB int64, callback StringCallback)
	BlockIoThrottle(driveName string, bps, iops int64, callback StringCallback)
	CancelBlockJob(driveName string, force bool, callback StringCallback)

	NetdevAdd(id, netType string, params map[string]string, callback StringCallback)
	NetdevDel(id string, callback StringCallback)

	SaveState(statFilePath string, callback StringCallback)
}

type MonitorErrorFunc 

type MonitorErrorFunc func(error)

type MonitorSuccFunc 

type MonitorSuccFunc func()

type QemuBlock 

type QemuBlock struct {
	IoStatus  string `json:"io-status"`
	Device    string
	Locked    bool
	Removable bool
	Qdev      string
	TrayOpen  bool
	Type      string
	Inserted  struct {
		Ro               bool
		Drv              string
		Encrypted        bool
		File             string
		BackingFile      string
		BackingFileDepth int
		Bps              int64
		BpsRd            int64
		BpsWr            int
		Iops             int64
		IopsRd           int
		IopsWr           int
		BpsMax           int64
		BpsRdMax         int64
		BpsWrMax         int64
		IopsMax          int
		IopsRdMax        int
		IopsWrMax        int
		IopsSize         int64
		DetectZeroes     string
		WriteThreshold   int
		Image            struct {
			Filename              string
			Format                string
			VirtualSize           int64 `json:"virtual-size"`
			BackingFile           string
			FullBackingFilename   string `json:"full-backing-filename"`
			BackingFilenameFormat string `json:"backing-filename-format"`
			Snapshots             []struct {
				Id          string
				Name        string
				VmStateSize int   `json:"vm-state-size"`
				DateSec     int64 `json:"date-sec"`
				DateNsec    int   `json:"date-nsec"`
				VmClockSec  int   `json:"vm-clock-sec"`
				VmClockNsec int   `json:"vm-clock-nsec"`
			}
			BackingImage struct {
				VirtualSize int64 `json:"virtual-size"`
				// contains filtered or unexported fields
			} `json:"backing-image"`
		}
	}
}

type QmpMonitor 

type QmpMonitor struct {
	SBaseMonitor
	// contains filtered or unexported fields
}

func NewQmpMonitor 

func NewQmpMonitor(server, sid string, OnMonitorDisConnect, OnMonitorTimeout MonitorErrorFunc,
	OnMonitorConnected MonitorSuccFunc, qmpEventFunc qmpEventCallback) *QmpMonitor

func (*QmpMonitor) AddCpu 

func (m *QmpMonitor) AddCpu(cpuIndex int, callback StringCallback)

func (*QmpMonitor) BlockIoThrottle 

func (m *QmpMonitor) BlockIoThrottle(driveName string, bps, iops int64, callback StringCallback)

func (*QmpMonitor) BlockJobComplete 

func (m *QmpMonitor) BlockJobComplete(drive string, callback StringCallback)

func (*QmpMonitor) BlockReopenImage 

func (m *QmpMonitor) BlockReopenImage(drive, newImagePath, format string, callback StringCallback)

func (*QmpMonitor) BlockStream 

func (m *QmpMonitor) BlockStream(drive string, idx, blkCnt int, callback StringCallback)

func (*QmpMonitor) CancelBlockJob 

func (m *QmpMonitor) CancelBlockJob(driveName string, force bool, callback StringCallback)

func (*QmpMonitor) ChangeCdrom 

func (m *QmpMonitor) ChangeCdrom(dev string, path string, callback StringCallback)

func (*QmpMonitor) Connect 

func (m *QmpMonitor) Connect(host string, port int) error

func (*QmpMonitor) ConnectWithSocket 

func (m *QmpMonitor) ConnectWithSocket(address string) error

func (*QmpMonitor) DeviceAdd 

func (m *QmpMonitor) DeviceAdd(dev string, params map[string]interface{}, callback StringCallback)

func (*QmpMonitor) DeviceDel 

func (m *QmpMonitor) DeviceDel(idstr string, callback StringCallback)

func (*QmpMonitor) DriveAdd 

func (m *QmpMonitor) DriveAdd(bus string, params map[string]string, callback StringCallback)

func (*QmpMonitor) DriveDel 

func (m *QmpMonitor) DriveDel(idstr string, callback StringCallback)

func (*QmpMonitor) DriveMirror 

func (m *QmpMonitor) DriveMirror(callback StringCallback, drive, target, syncMode, format string, unmap, blockReplication bool)

func (*QmpMonitor) EjectCdrom 

func (m *QmpMonitor) EjectCdrom(dev string, callback StringCallback)

func (*QmpMonitor) GeMemtSlotIndex 

func (m *QmpMonitor) GeMemtSlotIndex(callback func(index int))

func (*QmpMonitor) GetBlockJobCounts 

func (m *QmpMonitor) GetBlockJobCounts(callback func(jobs int))

func (*QmpMonitor) GetBlockJobs 

func (m *QmpMonitor) GetBlockJobs(callback func([]BlockJob))

func (*QmpMonitor) GetBlocks 

func (m *QmpMonitor) GetBlocks(callback func([]QemuBlock))

func (*QmpMonitor) GetCpuCount 

func (m *QmpMonitor) GetCpuCount(callback func(count int))

func (*QmpMonitor) GetMigrateStatus 

func (m *QmpMonitor) GetMigrateStatus(callback StringCallback)

func (*QmpMonitor) GetVersion 

func (m *QmpMonitor) GetVersion(callback StringCallback)

If get version error, callback with empty string

func (*QmpMonitor) HumanMonitorCommand 

func (m *QmpMonitor) HumanMonitorCommand(cmd string, callback StringCallback)

func (*QmpMonitor) Migrate 

func (m *QmpMonitor) Migrate(
	destStr string, copyIncremental, copyFull bool, callback StringCallback,
)

func (*QmpMonitor) MigrateIncoming 

func (m *QmpMonitor) MigrateIncoming(address string, callback StringCallback)

func (*QmpMonitor) MigrateSetCapability 

func (m *QmpMonitor) MigrateSetCapability(capability, state string, callback StringCallback)

func (*QmpMonitor) MigrateSetDowntime 

func (m *QmpMonitor) MigrateSetDowntime(dtSec float32, callback StringCallback)

func (*QmpMonitor) MigrateSetParameter 

func (m *QmpMonitor) MigrateSetParameter(key string, val interface{}, callback StringCallback)

func (*QmpMonitor) MigrateStartPostcopy 

func (m *QmpMonitor) MigrateStartPostcopy(callback StringCallback)

func (*QmpMonitor) NetdevAdd 

func (m *QmpMonitor) NetdevAdd(id, netType string, params map[string]string, callback StringCallback)

func (*QmpMonitor) NetdevDel 

func (m *QmpMonitor) NetdevDel(id string, callback StringCallback)

func (*QmpMonitor) ObjectAdd 

func (m *QmpMonitor) ObjectAdd(objectType string, params map[string]string, callback StringCallback)

func (*QmpMonitor) ObjectDel 

func (m *QmpMonitor) ObjectDel(idstr string, callback StringCallback)

func (*QmpMonitor) Query 

func (m *QmpMonitor) Query(cmd *Command, cb qmpMonitorCallBack)

func (*QmpMonitor) QueryStatus 

func (m *QmpMonitor) QueryStatus(callback StringCallback)

func (*QmpMonitor) ReloadDiskBlkdev 

func (m *QmpMonitor) ReloadDiskBlkdev(device, path string, callback StringCallback)

func (*QmpMonitor) ResizeDisk 

func (m *QmpMonitor) ResizeDisk(driveName string, sizeMB int64, callback StringCallback)

func (*QmpMonitor) SaveState 

func (m *QmpMonitor) SaveState(stateFilePath string, callback StringCallback)

func (*QmpMonitor) SetVncPassword 

func (m *QmpMonitor) SetVncPassword(proto, password string, callback StringCallback)

func (*QmpMonitor) SimpleCommand 

func (m *QmpMonitor) SimpleCommand(cmd string, callback StringCallback)

func (*QmpMonitor) SnapshotBlkdev 

func (m *QmpMonitor) SnapshotBlkdev(drive, newImagePath, format string, reuse bool, callback StringCallback)

func (*QmpMonitor) StartNbdServer 

func (m *QmpMonitor) StartNbdServer(port int, exportAllDevice, writable bool, callback StringCallback)

type Response 

type Response struct {
	Return   []byte
	ErrorVal *Error
	Id       string
}

type SBaseMonitor 

type SBaseMonitor struct {
	OnMonitorDisConnect MonitorErrorFunc
	OnMonitorConnected  MonitorSuccFunc
	OnMonitorTimeout    MonitorErrorFunc

	QemuVersion string
	// contains filtered or unexported fields
}

func NewBaseMonitor 

func NewBaseMonitor(server, sid string, OnMonitorConnected MonitorSuccFunc, OnMonitorDisConnect, OnMonitorTimeout MonitorErrorFunc) *SBaseMonitor

func (*SBaseMonitor) Connect 

func (m *SBaseMonitor) Connect(host string, port int) error

func (*SBaseMonitor) ConnectWithSocket 

func (m *SBaseMonitor) ConnectWithSocket(address string) error

func (*SBaseMonitor) Disconnect 

func (m *SBaseMonitor) Disconnect()

func (*SBaseMonitor) IsConnected 

func (m *SBaseMonitor) IsConnected() bool

type StringCallback 

type StringCallback func(string)

type Timestamp 

type Timestamp struct {
	Seconds       int64 `json:"seconds"`
	Microsenconds int64 `json:"microsenconds"`
}

type Version 

type Version struct {
	Package string `json:"package"`
	QEMU    struct {
		Major int `json:"major"`
		Micro int `json:"micro"`
		Minor int `json:"minor"`
	} `json:"qemu"`
}

func (*Version) String 

func (v *Version) String() string

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.