Package ClusterShell :: Package Worker :: Module Ssh :: Class WorkerSsh

Class WorkerSsh

ClusterShell ssh-based worker Class.

Remote Shell (ssh) usage example:

>>> worker = WorkerSsh(nodeset, handler=MyEventHandler(),
...                    timeout=30, command="/bin/hostname")
>>> task.schedule(worker)      # schedule worker for execution
>>> task.resume()              # run

Remote Copy (scp) usage example:

>>> worker = WorkerSsh(nodeset, handler=MyEventHandler(),
...                    timeout=30, source="/etc/my.conf",
...                    dest="/etc/my.conf")
>>> task.schedule(worker)      # schedule worker for execution
>>> task.resume()              # run

Nested Classes

[hide private]

SHELL_CLASS
Ssh EngineClient.

COPY_CLASS
Scp EngineClient.

Instance Methods

[hide private]

Inherited from Exec.ExecWorker: __init__, abort, set_write_eof, write

Inherited from Exec.ExecWorker (private): _add_client, _check_fini, _create_clients, _engine_clients, _on_node_timeout

Inherited from Worker.DistantWorker: iter_buffers, iter_errors, iter_keys_timeout, iter_node_buffers, iter_node_errors, iter_node_retcodes, iter_retcodes, last_error, last_node, last_read, last_retcode, node_buffer, node_error, node_error_buffer, node_rc, node_retcode, num_timeout

Inherited from Worker.DistantWorker (private): _on_node_msgline, _on_node_rc

Inherited from Worker.Worker: did_timeout, flush_buffers, flush_errors, read

Inherited from Worker.Worker (private): _on_rc, _on_start, _on_written, _set_task, _task_bound_check

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Class Variables

[hide private]

Inherited from Worker.Worker: SNAME_STDERR, SNAME_STDIN, SNAME_STDOUT

Instance Variables

[hide private]

Inherited from Worker.Worker: current_errmsg, current_msg, current_node, current_rc, current_sname, eh, started, task

Properties

[hide private]

Inherited from object: __class__