ganeti.hypervisor.hv_kvm.monitor.QemuMonitorSocket

class documentation

class QemuMonitorSocket(UnixFileSocketConnection):

Known subclasses: ganeti.hypervisor.hv_kvm.monitor.QmpConnection

Constructor: QemuMonitorSocket(socket_path, timeout)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method execute_qmp Undocumented
Method get_qmp_response Undocumented
Method recv_qmp Undocumented
Method send_qmp Undocumented
Method wait_for_qmp_event Waits for one of the specified events and returns it. If the timeout is reached, returns None.
Method _read_buffer Undocumented
Constant _ARGUMENTS_KEY Undocumented
Constant _ERROR_CLASS_KEY Undocumented
Constant _ERROR_DESC_KEY Undocumented
Constant _ERROR_KEY Undocumented
Constant _EVENT_KEY Undocumented
Constant _EXECUTE_KEY Undocumented
Constant _MESSAGE_END_TOKEN Undocumented
Constant _RETURN_KEY Undocumented
Constant _SEND_END_TOKEN Undocumented
Instance Variable _buffer Undocumented

Inherited from UnixFileSocketConnection:

Method __enter__ Undocumented
Method __exit__ Undocumented
Method close Undocumented
Method connect Undocumented
Method is_connected Undocumented
Method recv Undocumented
Method reset_timeout Reset the timeout to self.timeout
Method send Undocumented
Instance Variable sock Undocumented
Instance Variable socket_path Undocumented
Instance Variable timeout Undocumented
Instance Variable _connected Undocumented
def __init__(self, socket_path: str, timeout):
overrides ganeti.hypervisor.hv_kvm.monitor.UnixFileSocketConnection.__init__
overridden in ganeti.hypervisor.hv_kvm.monitor.QmpConnection

Undocumented

def execute_qmp(self, command: str, arguments: dict = None) -> QmpMessage:
overridden in ganeti.hypervisor.hv_kvm.monitor.QmpConnection

Undocumented

def get_qmp_response(self, command) -> dict:

Undocumented

def recv_qmp(self) -> QmpMessage:

Undocumented

def send_qmp(self, message: QmpMessage):

Undocumented

def wait_for_qmp_event(self, event_types: list[str], timeout: int | float) -> QmpEvent | None:

Waits for one of the specified events and returns it. If the timeout is reached, returns None.

def _read_buffer(self) -> QmpMessage:

Undocumented

_ARGUMENTS_KEY: str =

Undocumented

Value
'arguments'
_ERROR_CLASS_KEY: str =

Undocumented

Value
'class'
_ERROR_DESC_KEY: str =

Undocumented

Value
'desc'
_ERROR_KEY: str =

Undocumented

Value
'error'
_EVENT_KEY: str =

Undocumented

Value
'event'
_EXECUTE_KEY: str =

Undocumented

Value
'execute'
_MESSAGE_END_TOKEN: bytes =
overridden in ganeti.hypervisor.hv_kvm.monitor.QmpConnection

Undocumented

Value
b'''\r
'''
_RETURN_KEY: str =
overridden in ganeti.hypervisor.hv_kvm.monitor.QmpConnection

Undocumented

Value
'return'
_SEND_END_TOKEN: bytes =

Undocumented

Value
b'''
'''
_buffer =
overridden in ganeti.hypervisor.hv_kvm.monitor.QmpConnection

Undocumented