Package ganeti :: Package jqueue
[hide private]
[frames] | no frames]

Package jqueue

source code

Module implementing the job queue handling.

Submodules [hide private]

Classes [hide private]
  CancelJob
Special exception to cancel a job.
  _QueuedOpCode
Encapsulates an opcode object.
  _QueuedJob
In-memory job representation.
  _OpExecCallbacks
  _TimeoutStrategyWrapper
  _OpExecContext
  _JobProcessor
  _JobDependencyManager
Keeps track of job dependencies.
  JobQueue
Queue used to manage the jobs.
Functions [hide private]
tuple
TimeStampNow()
Returns the current timestamp.
source code
 
_CallJqUpdate(runner, names, file_name, content)
Updates job queue file after virtualizing filename.
source code
 
_EncodeOpError(err)
Encodes an error which occurred while processing an opcode.
source code
Variables [hide private]
  _GetIdAttr = operator.attrgetter("id")
Retrieves "id" attribute

Imports: logging, errno, time, weakref, threading, itertools, operator, os, pyinotify, asyncnotifier, constants, serializer, locking, luxi, opcodes, opcodes_base, errors, mcpu, utils, jstore, rpc, runtime, netutils, compat, ht, query, qlang, pathutils, vcluster, cluster


Function Details [hide private]

TimeStampNow()

source code 

Returns the current timestamp.

Returns: tuple
the current time in the (seconds, microseconds) format