Index

_

__eq__() (cumin.transports.Command method) __getattr__() (cumin.transports.State method) __ne__() (cumin.transports.Command 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) _api_call() (cumin.backends.puppetdb.PuppetDBQuery method) _build() (cumin.backends.BaseQuery method) (cumin.backends.BaseQueryAggregator method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.openstack.OpenStackQuery method) (cumin.backends.puppetdb.PuppetDBQuery method) _callable() (cumin.transports.clustershell.NullReporter method) _close_subgroup() (cumin.backends.BaseQueryAggregator method) (cumin.backends.puppetdb.PuppetDBQuery method) _cmp() (cumin.transports.State method) _color() (cumin.color.Colored static method) _compute_batch_size() (cumin.transports.Target method) _compute_batch_sleep() (cumin.transports.Target static method) _execute() (cumin.backends.BaseQuery method) (cumin.backends.BaseQueryAggregator method) (cumin.backends.knownhosts.KnownHostsQuery method) (cumin.backends.openstack.OpenStackQuery method) (cumin.backends.puppetdb.PuppetDBQuery 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.TqdmQuietReporter 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.TqdmQuietReporter method) _get_special_resource_query() (cumin.backends.puppetdb.PuppetDBQuery method) _get_stack_element() (cumin.backends.BaseQueryAggregator static method) _import_backend() (in module cumin.grammar) _load_known_hosts() (cumin.backends.knownhosts.KnownHostsQuery method) _loop_stack() (cumin.backends.BaseQueryAggregator method) _open_subgroup() (cumin.backends.BaseQueryAggregator method) (cumin.backends.puppetdb.PuppetDBQuery 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) _query_default_backend() (cumin.query.Query method) _replace_alias() (cumin.query.Query method) _report_line() (cumin.transports.clustershell.TqdmQuietReporter method) _success_nodes_report() (cumin.transports.clustershell.BaseEventHandler 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) BaseExecutionProgress (class in cumin.transports)

BaseQuery (class in cumin.backends) BaseQueryAggregator (class in cumin.backends) BaseReporter (class in cumin.transports.clustershell) 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.BaseExecutionProgress method) (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.BaseEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) (cumin.transports.NoProgress method) (cumin.transports.TqdmProgressBars method) cls (cumin.grammar.Backend property) ClusterShellWorker (class in cumin.transports.clustershell) Colored (class in cumin.color) ColoredType (class in cumin.color) COLORS (cumin.color.ColoredType attribute) Command (class in cumin.transports) command_completed() (cumin.transports.clustershell.BaseReporter method) (cumin.transports.clustershell.TqdmReporter method) command_header() (cumin.transports.clustershell.BaseReporter method) (cumin.transports.clustershell.TqdmReporter method) command_output() (cumin.transports.clustershell.BaseReporter method) (cumin.transports.clustershell.TqdmReporter method) commands (cumin.transports.BaseWorker 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.color 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) disabled (cumin.color.Colored attribute)

E

end_command() (cumin.transports.clustershell.SyncEventHandler method) endpoint (cumin.backends.puppetdb.PuppetDBQuery property) endpoints (cumin.backends.puppetdb.PuppetDBQuery attribute) ensure_kerberos_ticket() (in module cumin) ev_close() (cumin.transports.clustershell.BaseEventHandler method) ev_hup() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.SyncEventHandler method)

ev_pickup() (cumin.transports.clustershell.BaseEventHandler method) ev_read() (cumin.transports.clustershell.BaseEventHandler method) ev_timer() (cumin.transports.clustershell.AsyncEventHandler method) (cumin.transports.clustershell.SyncEventHandler method) execute() (cumin.backends.BaseQuery method) (cumin.query.Query method) (cumin.transports.BaseWorker method) (cumin.transports.clustershell.ClusterShellWorker method)

F

failed (cumin.transports.State attribute) failed_nodes() (cumin.transports.clustershell.BaseReporter method) (cumin.transports.clustershell.TqdmQuietReporter method)

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) global_timeout_nodes() (cumin.transports.clustershell.BaseReporter method) (cumin.transports.clustershell.TqdmQuietReporter 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.BaseExecutionProgress method) (cumin.transports.NoProgress method) (cumin.transports.TqdmProgressBars method) INTERNAL_BACKEND_PREFIX (in module cumin.grammar) InvalidQueryError InvalidStateError

is_failed (cumin.transports.State attribute) is_pending (cumin.transports.State attribute) is_running (cumin.transports.State attribute) is_scheduled (cumin.transports.State attribute) is_success (cumin.transports.State attribute) is_timeout (cumin.transports.State attribute)

K

keyword (cumin.grammar.Backend property) KnownHostsLineError

KnownHostsQuery (class in cumin.backends.knownhosts) KnownHostsSkippedLineError

M

message_element() (cumin.transports.clustershell.BaseReporter method) (cumin.transports.clustershell.TqdmReporter method) module cumin cumin.backends cumin.backends.direct cumin.backends.knownhosts cumin.backends.openstack cumin.backends.puppetdb cumin.color cumin.grammar cumin.query cumin.transport cumin.transports cumin.transports.clustershell

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) NullReporter (class in cumin.transports.clustershell)

O

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

reporter (cumin.transports.clustershell.ClusterShellWorker property) running (cumin.transports.State attribute) running_command_index (cumin.transports.clustershell.Node attribute)

S

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

StateTransitionError success (cumin.transports.State attribute) success_nodes() (cumin.transports.clustershell.BaseReporter method) (cumin.transports.clustershell.TqdmQuietReporter method) success_threshold (cumin.transports.BaseWorker property) SyncEventHandler (class in cumin.transports.clustershell)

T

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

TqdmProgressBars (class in cumin.transports) TqdmQuietReporter (class in cumin.transports.clustershell) TqdmReporter (class in cumin.transports.clustershell) trace() (in module cumin) Transport (class in cumin.transport)

U

update() (cumin.transports.State method) update_failed() (cumin.transports.BaseExecutionProgress method) (cumin.transports.NoProgress method) (cumin.transports.TqdmProgressBars method)

update_success() (cumin.transports.BaseExecutionProgress method) (cumin.transports.NoProgress method) (cumin.transports.TqdmProgressBars 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

worker_class (in module cumin.transports.clustershell)

WorkerError