ganeti.luxi

Module luxi

Module for the unix socket protocol

This module implements the local unix socket protocol. You only need this module and the opcodes module in the client program in order to communicate with the master.

The module is also used by the master daemon.

Classes

[hide private]

ProtocolError
Denotes an error in the LUXI protocol.

ConnectionClosedError
Connection closed error.

TimeoutError
Operation timeout error.

RequestError
Error on request.

NoMasterError
The master cannot be reached.

PermissionError
Permission denied while connecting to the master socket.

Transport
Low-level transport class.

Client
High-level client implementation.

Functions

[hide private]

ParseRequest(msg)
Parses a LUXI request message.

source code

ParseResponse(msg)
Parses a LUXI response message.

source code

FormatResponse(success, result, version=None)
Formats a LUXI response message.

source code

FormatRequest(method, args, version=None)
Formats a LUXI request message.

source code

CallLuxiMethod(transport_cb, method, args, version=None)
Send a LUXI request via a transport and return the response.

source code

Variables

[hide private]

KEY_METHOD = "method"

KEY_ARGS = "args"

KEY_SUCCESS = "success"

KEY_RESULT = "result"

KEY_VERSION = "version"

REQ_SUBMIT_JOB = "SubmitJob"

REQ_SUBMIT_MANY_JOBS = "SubmitManyJobs"

REQ_WAIT_FOR_JOB_CHANGE = "WaitForJobChange"

REQ_CANCEL_JOB = "CancelJob"

REQ_ARCHIVE_JOB = "ArchiveJob"

REQ_CHANGE_JOB_PRIORITY = "ChangeJobPriority"

REQ_AUTO_ARCHIVE_JOBS = "AutoArchiveJobs"

REQ_QUERY = "Query"

REQ_QUERY_FIELDS = "QueryFields"

REQ_QUERY_JOBS = "QueryJobs"

REQ_QUERY_INSTANCES = "QueryInstances"

REQ_QUERY_NODES = "QueryNodes"

REQ_QUERY_GROUPS = "QueryGroups"

REQ_QUERY_NETWORKS = "QueryNetworks"

REQ_QUERY_EXPORTS = "QueryExports"

REQ_QUERY_CONFIG_VALUES = "QueryConfigValues"

REQ_QUERY_CLUSTER_INFO = "QueryClusterInfo"

REQ_QUERY_TAGS = "QueryTags"

REQ_SET_DRAIN_FLAG = "SetDrainFlag"

REQ_SET_WATCHER_PAUSE = "SetWatcherPause"

REQ_ALL = compat.UniqueFrozenset([REQ_ARCHIVE_JOB, REQ_AUTO_AR...
List of all LUXI requests

DEF_CTMO = 10

DEF_RWTO = 60

WFJC_TIMEOUT = DEF_RWTO-1/ 2

Variables Details

[hide private]

REQ_ALL

List of all LUXI requests

Value:

compat.UniqueFrozenset([REQ_ARCHIVE_JOB, REQ_AUTO_ARCHIVE_JOBS, REQ_CA
NCEL_JOB, REQ_CHANGE_JOB_PRIORITY, REQ_QUERY, REQ_QUERY_CLUSTER_INFO, 
REQ_QUERY_CONFIG_VALUES, REQ_QUERY_EXPORTS, REQ_QUERY_FIELDS, REQ_QUER
Y_GROUPS, REQ_QUERY_INSTANCES, REQ_QUERY_JOBS, REQ_QUERY_NODES, REQ_QU
ERY_NETWORKS, REQ_QUERY_TAGS, REQ_SET_DRAIN_FLAG, REQ_SET_WATCHER_PAUS
E, REQ_SUBMIT_JOB, REQ_SUBMIT_MANY_JOBS, REQ_WAIT_FOR_JOB_CHANGE,])