|
def | __init__ (self) |
|
def | activate_host (self, host_params) |
|
def | clear_host (self) |
|
def | process (self, command, timeout=3000, ttl=300000) |
|
def | timeout_hook (self, connection_timeout, command, timeout) |
|
def | transport_err_hook (self, transport_internal_err, command, timeout) |
|
def | executor_err_hook (self, command_executor_err, command, timeout) |
|
Definition at line 29 of file DRCEManager.py.
◆ __init__()
def drce.DRCEManager.DRCEManager.__init__ |
( |
|
self | ) |
|
Constructor
Definition at line 33 of file DRCEManager.py.
40 self.connection =
None 44 self.connect_params =
None 45 self.connect_manager = ConnectionManager()
46 self.cmd_executor = CommandExecutor(self.connection, CommandConvertor())
def __init__(self)
constructor
◆ activate_host()
def drce.DRCEManager.DRCEManager.activate_host |
( |
|
self, |
|
|
|
host_params |
|
) |
| |
Definition at line 53 of file DRCEManager.py.
53 def activate_host(self, host_params):
55 self.connection = self.connect_manager.create_connection(con_params)
56 self.connect_params = con_params
57 self.cmd_executor.replace_connection(self.connection)
◆ clear_host()
def drce.DRCEManager.DRCEManager.clear_host |
( |
|
self | ) |
|
Definition at line 63 of file DRCEManager.py.
64 self.connect_manager.destroy_connection(self.connection)
65 self.connection =
None 66 self.connect_params =
None 67 self.cmd_executor.replace_connection(self.connection)
◆ executor_err_hook()
def drce.DRCEManager.DRCEManager.executor_err_hook |
( |
|
self, |
|
|
|
command_executor_err, |
|
|
|
command, |
|
|
|
timeout |
|
) |
| |
Definition at line 116 of file DRCEManager.py.
116 def executor_err_hook(self, command_executor_err, command, timeout):
118 raise command_executor_err
◆ process()
def drce.DRCEManager.DRCEManager.process |
( |
|
self, |
|
|
|
command, |
|
|
|
timeout = 3000 , |
|
|
|
ttl = 300000 |
|
) |
| |
Definition at line 77 of file DRCEManager.py.
77 def process(self, command, timeout=3000, ttl=300000):
79 return self.cmd_executor.
execute(command, timeout, ttl)
80 except ConnectionTimeout
as err:
81 self.timeout_hook(err, command, timeout)
82 except TransportInternalErr
as err:
83 self.transport_err_hook(err, command, timeout)
84 except CommandExecutorErr
as err:
85 self.executor_err_hook(err, command, timeout)
def execute(self, commands, nodes)
execute method execute incoming commands on nodes, keepts reult in responses and responsesDicts field...
◆ timeout_hook()
def drce.DRCEManager.DRCEManager.timeout_hook |
( |
|
self, |
|
|
|
connection_timeout, |
|
|
|
command, |
|
|
|
timeout |
|
) |
| |
Definition at line 94 of file DRCEManager.py.
94 def timeout_hook(self, connection_timeout, command, timeout):
96 raise connection_timeout
◆ transport_err_hook()
def drce.DRCEManager.DRCEManager.transport_err_hook |
( |
|
self, |
|
|
|
transport_internal_err, |
|
|
|
command, |
|
|
|
timeout |
|
) |
| |
Definition at line 105 of file DRCEManager.py.
105 def transport_err_hook(self, transport_internal_err, command, timeout):
107 raise transport_internal_err
◆ cmd_executor
drce.DRCEManager.DRCEManager.cmd_executor |
◆ connect_manager
drce.DRCEManager.DRCEManager.connect_manager |
◆ connect_params
drce.DRCEManager.DRCEManager.connect_params |
◆ connection
drce.DRCEManager.DRCEManager.connection |
The documentation for this class was generated from the following file: