ganeti.masterd.instance.DiskExport

class documentation

class DiskExport(_DiskImportExportBase):

Undocumented

Method	`__init__`	Initializes this class.
Method	`CheckListening`	Checks whether the daemon is listening.
Constant	`MODE_TEXT`	Undocumented
Method	`_GetConnectedCheckEpoch`	Returns the time since the daemon started.
Method	`_StartDaemon`	Starts the export daemon.
Instance Variable	`_dest_host`	Undocumented
Instance Variable	`_dest_port`	Undocumented
Instance Variable	`_source`	Undocumented
Instance Variable	`_source_args`	Undocumented

Inherited from _DiskImportExportBase:

Method	`Abort`	Sends SIGTERM to import/export daemon (if still active).
Method	`CheckConnected`	Checks whether the daemon is connected.
Method	`CheckDaemon`	Checks whether daemon has been started and if not, starts it.
Method	`CheckFinished`	Checks whether the daemon exited.
Method	`Finalize`	Finalizes this import/export.
Method	`GetDaemonName`	Returns the daemon name.
Method	`SetDaemonData`	Updates daemon status data.
Method	`SetLoop`	Sets the parent loop.
Instance Variable	`final_message`	Undocumented
Instance Variable	`node_name`	Undocumented
Instance Variable	`node_uuid`	Undocumented
Instance Variable	`success`	Undocumented
Property	`active`	Determines whether this transport is still active.
Property	`loop`	Returns parent loop.
Property	`magic`	Returns the magic value for this import/export.
Property	`progress`	Returns transfer progress information.
Property	`recent_output`	Returns the most recent output from the daemon.
Method	`_CheckProgress`	Checks whether a progress update should be reported.
Method	`_Finalize`	Makes the RPC call to finalize this import/export.
Method	`_ReportFinished`	Transfer is finished or daemon exited.
Method	`_SetDaemonData`	Internal function for updating status daemon data.
Instance Variable	`_cbs`	Undocumented
Instance Variable	`_component`	Undocumented
Instance Variable	`_daemon`	Undocumented
Instance Variable	`_daemon_name`	Undocumented
Instance Variable	`_instance`	Undocumented
Instance Variable	`_loop`	Undocumented
Instance Variable	`_lu`	Undocumented
Instance Variable	`_opts`	Undocumented
Instance Variable	`_private`	Undocumented
Instance Variable	`_timeouts`	Undocumented
Instance Variable	`_ts_begin`	Undocumented
Instance Variable	`_ts_cleanup`	Undocumented
Instance Variable	`_ts_connected`	Undocumented
Instance Variable	`_ts_finished`	Undocumented
Instance Variable	`_ts_last_error`	Undocumented
Instance Variable	`_ts_last_progress`	Undocumented

def __init__(self, lu, node_uuid, opts, dest_host, dest_port, instance, component, source, source_args, timeouts, cbs, private=None): ¶

overrides ganeti.masterd.instance._DiskImportExportBase.__init__

Initializes this class.

Parameters
lu	Logical unit instance
node_uuid:string	Node UUID for import
opts:`objects.ImportExportOptions`	Import/export daemon options
dest_host:string	Destination host name or IP address
dest_port:number	Destination port number
instance:`objects.Instance`	Instance object
component:string	which part of the instance is being imported
source	I/O source
source_args	I/O source
timeouts:`ImportExportTimeouts`	Timeouts for this import
cbs:`ImportExportCbBase`	Callbacks
private	Private data for callback functions

def CheckListening(self): ¶

overrides ganeti.masterd.instance._DiskImportExportBase.CheckListening

Checks whether the daemon is listening.

MODE_TEXT: str = ¶

overrides ganeti.masterd.instance._DiskImportExportBase.MODE_TEXT

Undocumented

Value

'export'

def _GetConnectedCheckEpoch(self): ¶

overrides ganeti.masterd.instance._DiskImportExportBase._GetConnectedCheckEpoch

Returns the time since the daemon started.

def _StartDaemon(self): ¶

overrides ganeti.masterd.instance._DiskImportExportBase._StartDaemon

Starts the export daemon.

_dest_host = ¶

Undocumented

_dest_port = ¶

Undocumented

_source = ¶

Undocumented

_source_args = ¶

Undocumented