cyme.management.commands.cyme

cyme

Cyme management utility

Options

-a, --app

Application to use. Required for all operations except for when creating, deleting or listing apps.

-n, --nowait

Don’t want for operations to complete (async).

-F, --format

Output format: pretty (default) or json.

-L, --local

Flag that if set means that operations will be performed locally for the current branch only. This means the instance directory must be properly set.

-l, --loglevel

Set custom log level. One of DEBUG/INFO/WARNING/ERROR/CRITICAL. Default is INFO.

-f, --logfile

Set custom logfile path. Default is <stderr>

-D, --instance-dir

Custom instance directory (default is instances/) Must be readable by the current user.

This needs to be properly specified if the -L option is used.

-b, --broker

Broker to use for a local branches request.

class cyme.management.commands.cyme.Command(env=None, *args, **kwargs)
args = 'type command [args]\nE.g.:\n cyme apps\n cyme apps.add <name> [broker URL] [arguments] [extra config]\n cyme apps.[get|delete] <name>\n\n cyme -a <app> instances\n cyme -a <app> instances.add [name] [broker URL] [arguments] [extra config]\n cyme -a <app> instances.[get|delete|stats] <name>\n cyme -a <app> instances.autoscale <name> [max] [min]\n\n cyme -a <app> queues\n cyme -a <app> queues.add <name> [exchange] [type] [rkey] [opts]\n cyme -a <app> queues.[get|delete] <name>\n\n cyme start-all\n cyme shutdown-all\n\n cyme createsuperuser\n\n cyme shell\n '
create_superuser()
drop_into_shell()
handle(*args, **kwargs)
help = 'Cyme management utility'
name = 'cyme'
option_list = (<Option at 0x1f5f320: -v/--verbosity>, <Option at 0x1f5f3b0: --settings>, <Option at 0x1f5f368: --pythonpath>, <Option at 0x1f5f3f8: --traceback>, <Option at 0x41833b0: -a/--app>, <Option at 0x41837a0: -n/--nowait>, <Option at 0x4183320: -F/--format>, <Option at 0x4183710: -L/--local>, <Option at 0x41839e0: -l/--loglevel>, <Option at 0x4183518: -D/--instance-dir>, <Option at 0x4183638: -u/--url>, <Option at 0x41835a8: -b/--broker>)
restart_all()
shutdown_all()
start_all()
status
class cyme.management.commands.cyme.I(app=None, format=None, nowait=False, url=None, **kwargs)
DISPATCH(fqdn, *args)
add_app(*args, **kwargs)
add_consumer(*args, **kwargs)
add_instance(*args, **kwargs)
add_queue(*args, **kwargs)
all_apps(*args, **kwargs)
all_consumers(*args, **kwargs)
all_instances(*args, **kwargs)
all_queues(*args, **kwargs)
delete_app(*args, **kwargs)
delete_consumer(*args, **kwargs)
delete_instance(*args, **kwargs)
delete_queue(*args, **kwargs)
format_optargs(optargs)
format_response(ret)
get_app(*args, **kwargs)
get_instances(*args, **kwargs)
get_queue(*args, **kwargs)
getsig(fun, opt_args=None)
instance_autoscale(*args, **kwargs)
instance_stats(*args, **kwargs)
prepare_response(ret)
class cyme.management.commands.cyme.LocalI(*args, **kwargs)
add_app(name, broker=None, arguments=None, extra_config=None)
add_consumer(instance_name, queue_name)
add_instance(name=None, broker=None, arguments=None, extra_config=None)
add_queue(name, exchange=None, exchange_type=None, routing_key=None, options=None)
all_apps()
all_branches()
all_consumers(instance_name)
all_instances()
all_queues()
delete_app(name)
delete_consumer(instance_name, queue_name)
delete_instance(name)
delete_queue(name)
get_app()
get_instance(name)
get_queue(name)
instance_autoscale(name, max=None, min=None)
instance_stats(name)
class cyme.management.commands.cyme.WebI(app=None, format=None, nowait=False, url=None, **kwargs)
add_app(name, broker=None, arguments=None, extra_config=None)
add_consumer(instance_name, queue_name)
add_instance(name=None, broker=None, arguments=None, extra_config=None)
add_queue(name, exchange=None, exchange_type=None, routing_key=None, options=None)
all_apps()
all_branches()
all_consumers(instance_name)
all_instances()
all_queues()
client
delete_app(name)
delete_consumer(instance_name, queue_name)
delete_instance(name)
delete_queue(name)
get_app(name)
get_instance(name)
get_queue(name)
instance_autoscale(name, max=None, min=None)
instance_stats(name)
prepare_response(ret)

Previous topic

cyme.tasks

Next topic

cyme.management.commands.cyme_branch

This Page