Index

Symbols

--sup-interval cyme-branch command line option --without-httpd cyme-branch command line option -a, --app cyme command line option -b, --broker cyme command line option -C, --numc cyme-branch command line option -D, --instance-dir cyme command line option cyme-branch command line option

-F, --format cyme command line option -f, --logfile cyme command line option cyme-branch command line option -i, --id cyme-branch command line option -L, --local cyme command line option -l, --loglevel cyme command line option cyme-branch command line option -n, --nowait cyme command line option

_

_action() (cyme.models.Instance method)

_query() (cyme.models.Instance method)

A

about() (cyme.branch.Branch method) Accepted() (cyme.api.web.ApiView method) add() (cyme.branch.managers.LocalInstanceManager method) (cyme.client.Client method) (cyme.client.Client.Instances method) (cyme.client.Client.Queues method) (cyme.client.base.Section method) (cyme.models.managers.AppManager method) (cyme.models.managers.InstanceManager method) (cyme.models.managers.QueueManager method) add_app() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) add_consumer() (cyme.branch.managers.LocalInstanceManager method) (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) add_instance() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) add_queue() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) (cyme.models.Instance method) add_queue_to_instances() (cyme.models.managers.InstanceManager method) after() (cyme.branch.Branch method) (cyme.branch.thread.gThread method) alive() (cyme.models.Instance method) all() (cyme.client.base.Section method) (cyme.client.Client method) all_apps() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) all_branches() (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) all_consumers() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method)

all_instances() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) (cyme.status.Status method) all_names() (cyme.client.base.Section method) all_queues() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) AlreadyStarted (cyme.branch.thread.gThread attribute) AlreadyStartedError ApiView (class in cyme.api.web) app (cyme.client.Client attribute) app() (in module cyme.bin.base) AppManager (class in cyme.models.managers) args (cyme.management.commands.cyme.Command attribute) (cyme.management.commands.cyme_branch.Command attribute) arguments (cyme.client.Instance attribute) as_dict() (cyme.models.Broker method) (cyme.models.Instance method) (cyme.models.Queue method) autoscale() (cyme.client.Client.Instances method) (cyme.client.Client.Instances.Model method) (cyme.models.Instance method) available (cyme.branch.metrics.df attribute)

B

banner() (cyme.management.commands.cyme_branch.Command method) Base (class in cyme.client.base) BaseApp (class in cyme.bin.base) before() (cyme.branch.supervisor.Supervisor method) (cyme.branch.thread.gThread method) Branch (class in cyme.branch) branch_cls (cyme.management.commands.cyme_branch.Command attribute) branch_info() (cyme.client.Client method) branch_ready (in module cyme.branch.signals)

branches (cyme.client.Client attribute) Broker (class in cyme.models) broker (cyme.client.Instance attribute) (cyme.models.Instance attribute) Broker (cyme.models.Instance attribute) broker_last_revived (cyme.branch.state.State attribute) BrokerManager (class in cyme.models.managers) Brokers (cyme.branch.managers.LocalInstanceManager attribute) (cyme.models.managers.AppManager attribute) build_url() (cyme.client.Client method)

C

cancel() (cyme.branch.thread.gThread.Timeout method) cancel_consumer() (cyme.branch.managers.LocalInstanceManager method) cancel_queue() (cyme.models.Instance method) capacity (cyme.branch.metrics.df attribute) Client (class in cyme.client) (class in cyme.client.base) client (cyme.management.commands.cyme.WebI attribute) Client.Instances (class in cyme.client) Client.Instances.Model (class in cyme.client) Client.Instances.Model.Consumers (class in cyme.client) Client.Instances.Model.LazyQueues (class in cyme.client) Client.Queues (class in cyme.client) Client.Queues.Model (class in cyme.client) clone() (cyme.client.Client method) Command (class in cyme.management.commands.cyme) (class in cyme.management.commands.cyme_branch) configure() (cyme.bin.base.Env method) connect_signals() (cyme.management.commands.cyme_branch.Command method) connection() (cyme.models.Broker method) consuming_from() (cyme.models.Instance method) controller_cls (cyme.branch.Branch attribute) controller_ready (in module cyme.branch.signals) create_http_protocol() (cyme.branch.httpd.HttpServer method) create_log() (cyme.branch.httpd.HttpServer method) create_model() (cyme.client.base.Section method) (cyme.client.Client method) (cyme.client.Client.Instances method) (cyme.client.Client.Instances.Model.Consumers method) create_superuser() (cyme.management.commands.cyme.Command method) Created() (cyme.api.web.ApiView method) created_at (cyme.models.Instance attribute) (cyme.models.Queue attribute)

cwd (cyme.models.Instance attribute) cyme command line option -D, --instance-dir -F, --format -L, --local -a, --app -b, --broker -f, --logfile -l, --loglevel -n, --nowait cyme-branch command line option --sup-interval --without-httpd -C, --numc -D, --instance-dir -f, --logfile -i, --id -l, --loglevel cyme.api.web (module) cyme.bin.base (module) cyme.bin.cyme (module) cyme.bin.cyme_branch (module) cyme.branch (module) cyme.branch.httpd (module) cyme.branch.intsup (module) cyme.branch.managers (module) cyme.branch.metrics (module) cyme.branch.signals (module) cyme.branch.state (module) cyme.branch.supervisor (module) cyme.branch.thread (module) cyme.client (module) cyme.client.base (module) cyme.management.commands.cyme (module) cyme.management.commands.cyme_branch (module) cyme.models (module) cyme.models.managers (module) cyme.status (module) cyme.tasks (module) cyme.utils (module)

D

default_detach_logfile (cyme.management.commands.cyme_branch.Command attribute) default_detach_pidfile (cyme.management.commands.cyme_branch.Command attribute) DEFAULT_HEADERS (in module cyme.tasks) default_url (cyme.client.base.Client attribute) (cyme.models.managers.BrokerManager attribute) DELETE() (cyme.client.base.Client method) delete() (cyme.client.base.Model method) (cyme.client.Client method) (cyme.client.base.Section method) (cyme.client.base.Section.Model method) delete_app() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) delete_consumer() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method)

delete_instance() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) delete_queue() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) deserialize() (cyme.client.base.Base method) df (class in cyme.branch.metrics) disable() (cyme.branch.managers.LocalInstanceManager method) (cyme.models.Instance method) (cyme.models.managers.InstanceManager method) dispatch() (cyme.api.web.ApiView method) DISPATCH() (cyme.management.commands.cyme.I method) drop_into_shell() (cyme.management.commands.cyme.Command method)

E

enable() (cyme.branch.managers.LocalInstanceManager method) (cyme.models.Instance method) (cyme.models.managers.InstanceManager method) enabled() (cyme.models.managers.InstanceManager method) (cyme.models.managers.QueueManager method) Env (class in cyme.bin.base) env (cyme.bin.base.BaseApp attribute) exchange (cyme.client.Queue attribute) (cyme.models.Queue attribute)

exchange_type (cyme.client.Queue attribute) (cyme.models.Queue attribute) extra_config (cyme.client.Instance attribute) extra_shutdown_steps (cyme.branch.thread.gThread attribute) extra_startup_steps (cyme.branch.thread.gThread attribute)

F

find_package() (in module cyme.utils) find_symbol() (in module cyme.utils) finish() (cyme.utils.LazyProgressBar method) force_list() (in module cyme.utils)

format_optargs() (cyme.management.commands.cyme.I method) format_response() (cyme.management.commands.cyme.I method) from_json() (cyme.models.managers.AppManager method)

G

g (cyme.branch.thread.gThread attribute) get() (cyme.branch.managers.LocalInstanceManager method) GET() (cyme.client.base.Client method) get() (cyme.client.base.Section method) (cyme.client.Client method) get_app() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) get_broker() (cyme.models.managers.AppManager method) get_current() (in module cyme.branch.supervisor) get_default() (cyme.models.managers.AppManager method) (cyme.models.managers.BrokerManager method) get_instance() (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) get_instances() (cyme.management.commands.cyme.I method)

get_or_post() (cyme.api.web.ApiView method) get_param() (cyme.api.web.ApiView method) get_queue() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) get_version() (cyme.bin.base.BaseApp method) getpid() (cyme.models.Instance method) getsig() (cyme.management.commands.cyme.I method) gSup (class in cyme.branch.intsup) gThread (class in cyme.branch.thread) gThread.Timeout

H

handle() (cyme.management.commands.cyme.Command method) (cyme.management.commands.cyme_branch.Command method) headers (cyme.client.base.Client attribute) help (cyme.management.commands.cyme.Command attribute) (cyme.management.commands.cyme_branch.Command attribute) httpd_cls (cyme.branch.Branch attribute)

httpd_ready (in module cyme.branch.signals) HttpResponseNotImplemented (class in cyme.api.web) HttpResponseTimeout (class in cyme.api.web) HttpServer (class in cyme.branch.httpd)

I

I (class in cyme.management.commands.cyme) ib() (cyme.status.Status method) id (cyme.client.base.Model attribute) (cyme.client.base.Section.Model attribute) imerge_settings() (in module cyme.utils) install_signal_handlers() (cyme.management.commands.cyme_branch.Command method) Instance (class in cyme.client) (class in cyme.models) instance() (cyme.models.managers.AppManager method) instance_autoscale() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) instance_dir (cyme.bin.base.BaseApp attribute)

instance_stats() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.LocalI method) (cyme.management.commands.cyme.WebI method) InstanceManager (class in cyme.models.managers) Instances (cyme.branch.managers.LocalInstanceManager attribute) instantiate() (in module cyme.utils) insured() (cyme.status.Status method) interval (cyme.branch.supervisor.Supervisor attribute) intsup_cls (cyme.branch.Branch attribute) is_branch (cyme.branch.state.State attribute) is_enabled (cyme.client.Instance attribute) (cyme.models.Instance attribute) (cyme.models.Queue attribute)

J

join() (cyme.branch.thread.gThread method) joinable (cyme.branch.httpd.HttpServer attribute) (cyme.branch.thread.gThread attribute)

JsonResponse() (in module cyme.api.web)

K

keys() (cyme.client.base.Base method)

kill() (cyme.branch.thread.gThread method)

L

LazyProgressBar (class in cyme.utils) load_average() (in module cyme.branch.metrics) LocalI (class in cyme.management.commands.cyme)

LocalInstanceManager (class in cyme.branch.managers) logger_name (cyme.branch.httpd.HttpServer attribute) (cyme.branch.intsup.gSup attribute) (cyme.branch.thread.gThread attribute)

M

management (cyme.bin.base.Env attribute) max_concurrency (cyme.client.Instance attribute) (cyme.models.Instance attribute) maybe_async() (cyme.client.base.Base method) (cyme.client.base.Section method) maybe_wait() (cyme.branch.managers.LocalInstanceManager method)

min_concurrency (cyme.client.Instance attribute) (cyme.models.Instance attribute) MockSup (class in cyme.branch) Model (class in cyme.client.base) MultiTool (cyme.models.Instance attribute)

N

name (cyme.branch.thread.gThread attribute) (cyme.client.Instance attribute) (cyme.client.Queue attribute) (cyme.client.base.Section attribute) (cyme.management.commands.cyme.Command attribute) (cyme.management.commands.cyme_branch.Command attribute) (cyme.models.Instance attribute) (cyme.models.Queue attribute) needs_eventlet (cyme.bin.base.BaseApp attribute)

NotImplemented() (cyme.api.web.ApiView method) nowait (cyme.api.web.ApiView attribute)

O

objects (cyme.models.Broker attribute) (cyme.models.Instance attribute) (cyme.models.Queue attribute) Ok() (cyme.api.web.ApiView method) on_branch_ready() (cyme.management.commands.cyme_branch.Command method) on_branch_shutdown() (cyme.management.commands.cyme_branch.Command method)

on_broker_revive() (cyme.branch.state.State method) on_ready() (cyme.branch.Branch method) option_list (cyme.management.commands.cyme.Command attribute) (cyme.management.commands.cyme_branch.Command attribute) options (cyme.client.Queue attribute) (cyme.models.Queue attribute)

P

params() (cyme.api.web.ApiView method) Path (class in cyme.client.base) (class in cyme.utils) path (cyme.client.base.Section attribute) pause() (cyme.branch.supervisor.Supervisor method) (cyme.status.Status method) paused (cyme.branch.supervisor.Supervisor attribute) (cyme.status.Status attribute) pending (cyme.branch.thread.gThread.Timeout attribute) ping() (cyme.branch.thread.gThread method)

pool (cyme.client.Instance attribute) (cyme.models.Broker attribute) POST() (cyme.client.base.Client method) prepare_response() (cyme.management.commands.cyme.I method) (cyme.management.commands.cyme.WebI method) prepare_signals() (cyme.branch.Branch method) proxy (cyme.client.base.Section attribute) PUT() (cyme.client.base.Client method)

Q

Queue (class in cyme.client) (class in cyme.models) (cyme.models.Instance attribute) queue_names (cyme.client.Instance attribute)

QueueManager (class in cyme.models.managers) queues (cyme.client.Client.Instances.Model attribute) (cyme.models.Instance attribute)

R

recreate() (cyme.models.managers.AppManager method) redirect_stdouts_to_logger() (in module cyme.utils) remove() (cyme.branch.managers.LocalInstanceManager method) (cyme.models.managers.InstanceManager method) remove_queue() (cyme.branch.managers.LocalInstanceManager method) remove_queue_from_instances() (cyme.models.managers.InstanceManager method) repr_controller_id() (cyme.management.commands.cyme_branch.Command method) request() (cyme.client.base.Client method) respond_to_ping() (cyme.branch.thread.gThread method) (cyme.status.Status method) responds_to_ping() (cyme.models.Instance method) responds_to_signal() (cyme.models.Instance method)

Response() (cyme.api.web.ApiView method) response_to_dict() (in module cyme.tasks) restart() (cyme.branch.managers.LocalInstanceManager method) (cyme.branch.supervisor.Supervisor method) (cyme.models.Instance method) restart_all() (cyme.management.commands.cyme.Command method) (cyme.status.Status method) restart_max_rate (cyme.branch.supervisor.Supervisor attribute) (cyme.status.Status attribute) resume() (cyme.branch.supervisor.Supervisor method) (cyme.status.Status method) root() (cyme.client.base.Client method) routing_key (cyme.client.Queue attribute) (cyme.models.Queue attribute) run() (cyme.branch.Branch method) (cyme.branch.httpd.HttpServer method) (cyme.branch.intsup.gSup method) (cyme.branch.supervisor.Supervisor method) (cyme.branch.thread.gThread method) run_from_argv() (cyme.bin.base.BaseApp method)

S

Section (class in cyme.client.base) Section.Model (class in cyme.client.base) serialize() (cyme.client.base.Base method) server() (cyme.branch.httpd.HttpServer method) set_access_control_options() (in module cyme.api.web) set_current() (in module cyme.branch.supervisor) set_process_title() (cyme.management.commands.cyme_branch.Command method) setup_default_env() (cyme.management.commands.cyme_branch.Command method) setup_eventlet() (cyme.bin.base.Env method) setup_logging() (in module cyme.utils) setup_pool_limit() (cyme.bin.base.Env method) setup_shutdown_progress() (cyme.management.commands.cyme_branch.Command method) setup_startup_progress() (cyme.management.commands.cyme_branch.Command method) should_stop (cyme.branch.thread.gThread attribute) shutdown() (cyme.branch.supervisor.Supervisor method) shutdown_all() (cyme.management.commands.cyme.Command method) (cyme.status.Status method) signals (cyme.management.commands.cyme_branch.Command attribute) simple_get() (in module cyme.api.web)

spawn() (cyme.branch.thread.gThread method) start() (cyme.branch.MockSup method) (cyme.branch.thread.gThread method) (cyme.branch.thread.gThread.Timeout method) (cyme.models.Instance method) start_all() (cyme.management.commands.cyme.Command method) (cyme.status.Status method) start_periodic_timer() (cyme.branch.thread.gThread method) start_wait_child() (cyme.branch.intsup.gSup method) stat (cyme.branch.metrics.df attribute) State (class in cyme.branch.state) stats() (cyme.client.Client.Instances method) (cyme.client.Client.Instances.Model method) (cyme.models.Instance method) Status (class in cyme.status) status (cyme.management.commands.cyme.Command attribute) status_code (cyme.api.web.HttpResponseNotImplemented attribute) (cyme.api.web.HttpResponseTimeout attribute) step() (cyme.utils.LazyProgressBar method) stop() (cyme.branch.Branch method) (cyme.branch.MockSup method) (cyme.branch.intsup.gSup method) (cyme.branch.thread.gThread method) (cyme.management.commands.cyme_branch.Command method) (cyme.models.Instance method) Supervisor (class in cyme.branch.supervisor) supervisor (cyme.branch.state.State attribute) supervisor_cls (cyme.branch.Branch attribute) supervisor_ready (in module cyme.branch.signals) syncdb() (cyme.bin.base.Env method)

T

time_since_broker_revived (cyme.branch.state.State attribute) total_blocks (cyme.branch.metrics.df attribute)

typemap (cyme.api.web.ApiView attribute)

U

UA (in module cyme.tasks)

url (cyme.branch.httpd.HttpServer attribute) (cyme.models.Broker attribute)

V

verify() (cyme.branch.supervisor.Supervisor method)

W

wait_after_broker_revived (cyme.branch.supervisor.Supervisor attribute)

WebI (class in cyme.management.commands.cyme)