Index

_

__eq__() (cumin.transports.Command method) __getattr__() (cumin.transports.State method) __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.NoProgress 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 property) ClusterShellWorker (class in cumin.transports.clustershell) Command (class in cumin.transports) commands() (cumin.transports.BaseWorker property) (cumin.transports.clustershell.ClusterShellWorker property)

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 property) 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 property)

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 property) (cumin.transports.clustershell.ClusterShellWorker property)

I

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

InvalidQueryError InvalidStateError

K

keyword() (cumin.grammar.Backend property) KnownHostsLineError

KnownHostsQuery (class in cumin.backends.knownhosts) KnownHostsSkippedLineError

N

name() (cumin.grammar.Backend property) 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 property) 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 property) (cumin.transports.clustershell.ClusterShellWorker property) SyncEventHandler (class in cumin.transports.clustershell)

T

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

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