ganeti.jqueue

package documentation

Module implementing the job queue handling.

Module exec Module implementing executing of a job as a separate process

From __init__.py:

Class JobQueue Queue used to manage the jobs.
Exception CancelJob Special exception to cancel a job.
Function TimeStampNow Returns the current timestamp.
Class _JobDependencyManager Keeps track of job dependencies.
Class _JobProcessor No class docstring; 0/4 instance variable, 0/3 constant, 3/3 methods, 3/3 static methods documented
Class _OpExecCallbacks No class docstring; 0/3 instance variable, 8/8 methods documented
Class _OpExecContext No class docstring; 0/7 instance variable, 4/4 methods documented
Class _QueuedJob In-memory job representation.
Class _QueuedOpCode Encapsulates an opcode object.
Class _TimeoutStrategyWrapper No class docstring; 0/2 instance variable, 4/4 methods documented
Function _CallJqUpdate Updates job queue file after virtualizing filename.
Function _EncodeOpError Encodes an error which occurred while processing an opcode.
Variable _GetIdAttr Undocumented
_GetIdAttr =

Undocumented

def TimeStampNow():

Returns the current timestamp.

Returns
tuplethe current time in the (seconds, microseconds) format
def _CallJqUpdate(runner, names, file_name, content):

Updates job queue file after virtualizing filename.

def _EncodeOpError(err):

Encodes an error which occurred while processing an opcode.