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

_generate_next_value_() (cumin.transports.HostState static 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_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 attribute) 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) CommandOutputResult (class in cumin.transports) CommandResults (class in cumin.transports) commands (cumin.transports.BaseWorker property) completed (cumin.transports.HostResults property) COMPLETED_WITH_FAILURES (cumin.transports.ExecutionStatus 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.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.BaseEventHandler 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) ExecutionResults (class in cumin.transports) ExecutionRun (class in cumin.transports.clustershell) ExecutionStatus (class in cumin.transports)

F

FAILED (cumin.transports.ExecutionStatus attribute) (cumin.transports.HostState attribute) failed_nodes() (cumin.transports.clustershell.BaseReporter method) (cumin.transports.clustershell.TqdmQuietReporter method)

first_batch (cumin.transports.Target property) format() (cumin.transports.CommandOutputResult method)

G

get_command_outputs() (cumin.transports.clustershell.ExecutionRun method) get_counter() (cumin.transports.clustershell.ExecutionRun method) get_host_output() (cumin.transports.CommandResults method) get_registered_backends() (in module cumin.grammar) get_results() (cumin.transports.BaseWorker method) (cumin.transports.clustershell.ClusterShellWorker method) (cumin.transports.clustershell.ExecutionRun method) get_single_output() (cumin.transports.CommandResults method) get_targeted_hosts() (in module cumin.transports) get_targets() (cumin.transports.clustershell.ExecutionRun 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) has_completed (cumin.transports.clustershell.HostRun property) has_no_outputs (cumin.transports.CommandResults property) (cumin.transports.ExecutionResults property)

has_single_output (cumin.transports.CommandResults property) HostNotFoundError HostResults (class in cumin.transports) HostRun (class in cumin.transports.clustershell) HostsOutputResult (class in cumin.transports) HostState (class in cumin.transports)

I

init() (cumin.transports.BaseExecutionProgress method) (cumin.transports.NoProgress method) (cumin.transports.TqdmProgressBars method) init_command_results() (cumin.transports.clustershell.ExecutionRun method) INTERNAL_BACKEND_PREFIX (in module cumin.grammar) INTERRUPTED (cumin.transports.ExecutionStatus attribute) InvalidQueryError

InvalidStateError is_above_threshold (cumin.transports.clustershell.BaseEventHandler property) 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 attribute) 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 attribute) new() (cumin.transport.Transport static method) next_host() (cumin.transports.clustershell.ExecutionRun method)

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

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

return_code (cumin.transports.ExecutionResults property) run() (cumin.transports.BaseWorker method) (cumin.transports.clustershell.ClusterShellWorker method) run_one() (cumin.transports.BaseWorker method) RUNNING (cumin.transports.HostState attribute)

S

SCHEDULED (cumin.transports.HostState attribute) short_command_length (cumin.transports.clustershell.TqdmQuietReporter attribute) shortened() (cumin.transports.Command method) SingleCommandOnlyError SingleOutputMissingHostsError start_command() (cumin.transports.clustershell.SyncEventHandler method) State (class in cumin.transports) StateTransitionError

stderr() (cumin.transports.CommandOutputResult method) stdout() (cumin.transports.CommandOutputResult method) SUCCEEDED (cumin.transports.ExecutionStatus attribute) SUCCESS (cumin.transports.HostState 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) TargetedHosts (class in cumin.transports) TargetedHostsCounters (class in cumin.transports) TargetedHostsMembers (class in cumin.transports) TIMEDOUT (cumin.transports.ExecutionStatus attribute) timeout (cumin.transports.BaseWorker property) (cumin.transports.Command property)

TIMEOUT (cumin.transports.HostState 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

UNKNOWN (cumin.transports.ExecutionStatus attribute) 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

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