Index

_

__eq__() (cumin.transports.Command method) __getattr__() (cumin.transports.State method) __init__ (cumin.transports.NoProgress attribute) __init__() (cumin.backends.BaseQuery method) (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.openstack.OpenStackQuery method) (cumin.backends.puppetdb.ParsedString method) (cumin.backends.puppetdb.PuppetDBQuery method) (cumin.query.Query method) (cumin.transports.BaseWorker method) (cumin.transports.Command method) (cumin.transports.ProgressBars method) (cumin.transports.State method) (cumin.transports.Target method) (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.ClusterShellWorker method) (cumin.transports.clustershell.Node method) (cumin.transports.clustershell.SyncEventHandler method) __ne__() (cumin.transports.Command method) __new__() (cumin.Config static method) __repr__() (cumin.transports.Command method) (cumin.transports.State method) __str__() (cumin.transports.Command method) (cumin.transports.State method) __version__ (in module cumin) _add_bool() (cumin.backends.puppetdb.PuppetDBQuery method) _add_category() (cumin.backends.puppetdb.PuppetDBQuery method) _add_hosts() (cumin.backends.puppetdb.PuppetDBQuery method) _aggregate_hosts() (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.query.Query method) _api_call() (cumin.backends.puppetdb.PuppetDBQuery method) _build() (cumin.backends.BaseQuery method) (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.openstack.OpenStackQuery method) (cumin.backends.puppetdb.PuppetDBQuery method) (cumin.query.Query method) _close_subgroup() (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.puppetdb.PuppetDBQuery method) (cumin.query.Query method) _cmp() (cumin.transports.State method) _commands_output_report() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) _compute_batch_size() (cumin.transports.Target method) _compute_batch_sleep() (cumin.transports.Target static method) _ev_routing() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method)

_execute() (cumin.backends.BaseQuery method) (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.openstack.OpenStackQuery method) (cumin.backends.puppetdb.PuppetDBQuery method) (cumin.query.Query method) _failed_commands_report() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) _get_default_search_params() (cumin.backends.openstack.OpenStackQuery method) _get_grouped_tokens() (cumin.backends.puppetdb.PuppetDBQuery static method) _get_keystone_session() (in module cumin.backends.openstack) _get_log_message() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) _get_nova_client() (in module cumin.backends.openstack) _get_project_hosts() (cumin.backends.openstack.OpenStackQuery method) _get_projects() (cumin.backends.openstack.OpenStackQuery method) _get_query_string() (cumin.backends.puppetdb.PuppetDBQuery method) _get_resource_query() (cumin.backends.puppetdb.PuppetDBQuery method) _get_short_command() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) _get_special_resource_query() (cumin.backends.puppetdb.PuppetDBQuery method) _get_stack_element() (cumin.backends.BaseQueryAggregator static method) (cumin.backends.direct.DirectQuery static method) (cumin.backends.knownhosts.KnownHostsQuery static method) (cumin.query.Query static method) _global_timeout_nodes_report() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) _load_known_hosts() (cumin.backends.knownhosts.KnownHostsQuery method) _loop_stack() (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.query.Query method) _open_subgroup() (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.puppetdb.PuppetDBQuery method) (cumin.query.Query method) _parse_token() (cumin.backends.BaseQuery method) (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.openstack.OpenStackQuery method) (cumin.backends.puppetdb.PuppetDBQuery method) (cumin.query.Query method) _print_report_line() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) _query_default_backend() (cumin.query.Query method) _replace_alias() (cumin.query.Query method) _success_nodes_report() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method)

A

allowed_state_transitions (cumin.transports.State attribute)

AsyncEventHandler (class in cumin.transports.clustershell)

B

Backend (class in cumin.grammar) base_url_template (cumin.backends.puppetdb.PuppetDBQuery attribute) BaseEventHandler (class in cumin.transports.clustershell)

BaseQuery (class in cumin.backends) BaseQueryAggregator (class in cumin.backends) BaseWorker (class in cumin.transports)

C

capwords() (cumin.backends.puppetdb.ParsedString method) CATEGORIES (in module cumin.backends.puppetdb) category_prefixes (cumin.backends.puppetdb.PuppetDBQuery attribute) close() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.NoProgress method) (cumin.transports.ProgressBars method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) cls (cumin.grammar.Backend attribute) ClusterShellWorker (class in cumin.transports.clustershell) Command (class in cumin.transports) commands (cumin.transports.BaseWorker attribute) (cumin.transports.clustershell.ClusterShellWorker attribute)

Config (class in cumin) cumin (module) cumin.backends (module) cumin.backends.direct (module) cumin.backends.knownhosts (module) cumin.backends.openstack (module) cumin.backends.puppetdb (module) cumin.grammar (module) cumin.query (module) cumin.transport (module) cumin.transports (module) cumin.transports.clustershell (module) CuminError current (cumin.transports.State attribute)

D

DEFAULT_HANDLERS (in module cumin.transports.clustershell)

DirectQuery (class in cumin.backends.direct)

E

end_command() (cumin.transports.clustershell.SyncEventHandler method) endpoint (cumin.backends.puppetdb.PuppetDBQuery attribute) endpoints (cumin.backends.puppetdb.PuppetDBQuery attribute) ev_close() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) ev_hup() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) ev_msg() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) ev_pickup() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) ev_read() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method)

ev_start() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) ev_timer() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) ev_written() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) execute() (cumin.backends.BaseQuery method) (cumin.backends.BaseQueryAggregator method) (cumin.backends.direct.DirectQuery method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.openstack.OpenStackQuery method) (cumin.backends.puppetdb.PuppetDBQuery method) (cumin.query.Query method) (cumin.transports.BaseWorker method) (cumin.transports.clustershell.ClusterShellWorker method)

F

failed (cumin.transports.State attribute)

first_batch (cumin.transports.Target attribute)

G

get_registered_backends() (in module cumin.grammar) get_results() (cumin.transports.BaseWorker method) (cumin.transports.clustershell.ClusterShellWorker method) grammar (cumin.backends.BaseQuery attribute) (cumin.backends.direct.DirectQuery attribute) (cumin.backends.knownhosts.KnownHostsQuery attribute) (cumin.backends.openstack.OpenStackQuery attribute) (cumin.backends.puppetdb.PuppetDBQuery attribute)

grammar() (in module cumin.backends.direct) (in module cumin.backends.knownhosts) (in module cumin.backends.openstack) (in module cumin.backends.puppetdb) (in module cumin.grammar) GRAMMAR_PREFIX (in module cumin.backends.direct) (in module cumin.backends.knownhosts) (in module cumin.backends.openstack) (in module cumin.backends.puppetdb)

H

handler (cumin.transports.BaseWorker attribute) (cumin.transports.clustershell.ClusterShellWorker attribute)

I

init() (cumin.transports.NoProgress method) (cumin.transports.ProgressBars method)

InvalidQueryError InvalidStateError

K

keyword (cumin.grammar.Backend attribute) KnownHostsLineError

KnownHostsQuery (class in cumin.backends.knownhosts) KnownHostsSkippedLineError

N

name (cumin.grammar.Backend attribute) new() (cumin.transport.Transport static method) Node (class in cumin.transports.clustershell)

nodeset() (in module cumin) nodeset_fromlist() (in module cumin) NoProgress (class in cumin.transports)

O

ok_codes (cumin.transports.Command attribute) on_timeout() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method)

OpenStackQuery (class in cumin.backends.openstack) OPERATORS (in module cumin.backends.puppetdb)

P

parse_config() (in module cumin) parse_known_hosts_line() (cumin.backends.knownhosts.KnownHostsQuery static method) parse_line_hosts() (cumin.backends.knownhosts.KnownHostsQuery static method)

ParsedString (class in cumin.backends.puppetdb) pending (cumin.transports.State attribute) ProgressBars (class in cumin.transports) PuppetDBQuery (class in cumin.backends.puppetdb)

Q

Query (class in cumin.query) query_class (in module cumin.backends.direct) (in module cumin.backends.knownhosts) (in module cumin.backends.openstack) (in module cumin.backends.puppetdb)

R

raise_error() (in module cumin.transports)

replace() (cumin.backends.puppetdb.ParsedString method) running (cumin.transports.State attribute)

S

scheduled (cumin.transports.State attribute) short_command_length (cumin.transports.clustershell.BaseEventHandler attribute) start_command() (cumin.transports.clustershell.SyncEventHandler method) State (class in cumin.transports) states_representation (cumin.transports.State attribute)

StateTransitionError success (cumin.transports.State attribute) success_threshold (cumin.transports.BaseWorker attribute) (cumin.transports.clustershell.ClusterShellWorker attribute) SyncEventHandler (class in cumin.transports.clustershell)

T

Target (class in cumin.transports) timeout (cumin.transports.BaseWorker attribute) (cumin.transports.Command attribute) (cumin.transports.State attribute) (cumin.transports.clustershell.ClusterShellWorker attribute)

trace() (in module cumin) Transport (class in cumin.transport)

U

update() (cumin.transports.State method) update_failed() (cumin.transports.NoProgress method) (cumin.transports.ProgressBars method)

update_success() (cumin.transports.NoProgress method) (cumin.transports.ProgressBars method)

V

valid_states (cumin.transports.State attribute) validate_list() (in module cumin.transports)

validate_positive_float() (in module cumin.transports) validate_positive_integer() (in module cumin.transports)

W

with_traceback() (cumin.backends.InvalidQueryError method) (cumin.backends.knownhosts.KnownHostsLineError method) (cumin.backends.knownhosts.KnownHostsSkippedLineError method) (cumin.transports.InvalidStateError method) (cumin.transports.StateTransitionError method) (cumin.transports.WorkerError method)

worker_class (in module cumin.transports.clustershell) WorkerError