Index

A

add_app() (troup.store.InMemorySyncedStore method) (troup.store.Store method) App (class in troup.apps) APPS_FILE (troup.store.InMemorySyncedStore attribute) AsyncIOWebSocketServer (class in troup.infrastructure)

atomic_op() (troup.threading.AtomicIncrement method) (troup.threading.AtomicOperation method) AtomicIncrement (class in troup.threading) AtomicOperation (class in troup.threading)

B

build() (troup.messaging.MessageBuilder method) build_channel() (troup.client.ChannelClient method)

build_task() (in module troup.tasks) Bus (class in troup.infrastructure)

C

CallbackWrapper (class in troup.client) cancel() (troup.threading.IntervalTimer method) Channel (class in troup.infrastructure) channel() (troup.infrastructure.ChannelManager method) ChannelClient (class in troup.client) ChannelClosedError ChannelError ChannelManager (class in troup.infrastructure) check_expired() (troup.client.CallbackWrapper method) check_local_node_lock() (in module troup.node) clear() (troup.tasks.TasksRunner method) client_to_local_node() (in module troup.client) close() (troup.infrastructure.Channel method) close_channel() (troup.infrastructure.ChannelManager method) close_streams() (troup.process.LocalProcess method)

CLOSED (troup.infrastructure.Channel attribute) closed() (troup.infrastructure.IncomingChannelWSAdapter method) (troup.infrastructure.OutgoingChannelWSAdapter method) CLOSING (troup.infrastructure.Channel attribute) CodeTask (class in troup.tasks) command() (troup.client.CommandAPI method) command_handler() (troup.node.Node method) CommandAPI (class in troup.client) complete() (troup.distributed.Promise method) configure_node_parser() (in module troup.main) connect() (troup.infrastructure.Channel method) (troup.infrastructure.OutgoingChannelOverWS method) CONNECTING (troup.infrastructure.Channel attribute) content (troup.process.LockFile attribute) CpuinfoParser (class in troup.system) create_channel() (troup.client.ChannelClient method) CREATED (troup.infrastructure.Channel attribute) (troup.tasks.TaskRun attribute)

D

data() (troup.messaging.MessageBuilder method) data_received() (troup.infrastructure.Channel method) debug_cli() (in module troup.debug) default() (troup.messaging.DictEncoder method) (troup.store.DictEncoder method) deserialize() (in module troup.messaging) deserialize_dict() (in module troup.messaging)

DictEncoder (class in troup.messaging) (class in troup.store) disconnect() (troup.infrastructure.Channel method) (troup.infrastructure.IncommingChannel method) (troup.infrastructure.OutgoingChannelOverWS method) DistributedException do_start() (troup.tasks.TaskRun method) do_stop() (troup.tasks.TaskRun method) DONE (troup.tasks.TaskRun attribute)

E

ENTRY_REGEX (troup.system.CpuinfoParser attribute) ERROR (troup.infrastructure.Channel attribute) (troup.tasks.TaskRun attribute) exec() (troup.tasks.CodeTask method) (troup.tasks.FunctionBytecodeTask method) execute() (troup.process.LocalProcess method) (troup.process.Process method)

execute_callback() (troup.client.CallbackWrapper method) exists() (troup.process.LockFile method) ExitCliException

F

find_app() (troup.store.InMemorySyncedStore method) (troup.store.Store method)

FunctionBytecodeTask (class in troup.tasks)

G

get_apps() (troup.node.Node method) get_available_apps() (troup.node.Node method) get_bogomips() (in module troup.system) get_channel() (troup.client.ChannelClient method) get_info() (troup.process.ProcessInfoFile method) get_node_info() (troup.node.Node method) (troup.node.SyncManager method) get_returncode() (troup.process.LocalProcess method) (troup.process.Process method)

get_server_endpoint() (troup.infrastructure.AsyncIOWebSocketServer method) get_setting() (troup.store.InMemorySyncedStore method) (troup.store.Store method) get_settings() (troup.store.InMemorySyncedStore method) (troup.store.Store method) get_ssh_args() (troup.process.SSHRemoteProcess method) get_stats() (troup.node.Node method) (troup.system.StatsTracker method) get_sync_message() (troup.node.SyncManager method)

H

header() (troup.messaging.MessageBuilder method)

I

id() (troup.messaging.MessageBuilder method) inc() (troup.threading.AtomicIncrement method) IncomingChannelWSAdapter (class in troup.infrastructure) IncommingChannel (class in troup.infrastructure)

InMemorySyncedStore (class in troup.store) IntervalTimer (class in troup.threading) is_done (troup.distributed.Promise attribute)

K

kill() (troup.process.LocalProcess method)

L

listen() (troup.infrastructure.ChannelManager method) ListenerWrapper (class in troup.infrastructure) load_from_file() (troup.store.InMemorySyncedStore method) local_address (troup.infrastructure.IncomingChannelWSAdapter attribute)

local_node_lock_file() (in module troup.node) LocalProcess (class in troup.process) LocalProcessTask (class in troup.tasks) LockFile (class in troup.process)

M

main() (in module troup.setup) Message (class in troup.messaging) message() (in module troup.messaging) MessageBuilder (class in troup.messaging)

MessageBus (class in troup.infrastructure) MessageHandler (class in troup.infrastructure) monitor() (troup.client.CommandAPI method)

N

next() (troup.node.RandomBuffer method) Node (class in troup.node) node_info_from_dict() (in module troup.node)

NodeInfo (class in troup.node) notify_close() (troup.infrastructure.IncommingChannel method) notify_event() (troup.infrastructure.AsyncIOWebSocketServer method)

O

Observable (class in troup.observer) on() (troup.infrastructure.Channel method) (troup.infrastructure.MessageBus method) (troup.observer.Observable method) on_channel_closed() (troup.infrastructure.AsyncIOWebSocketServer method) on_channel_open() (troup.infrastructure.AsyncIOWebSocketServer method) on_closed() (troup.infrastructure.OutgoingChannelOverWS method) on_data() (troup.infrastructure.ChannelManager method) (troup.infrastructure.ListenerWrapper method) on_event() (troup.infrastructure.AsyncIOWebSocketServer method) on_opened() (troup.infrastructure.OutgoingChannelOverWS method)

op() (troup.threading.AtomicOperation method) OPEN (troup.infrastructure.Channel attribute) open() (troup.infrastructure.Channel method) open_channel_to() (troup.infrastructure.ChannelManager method) open_process_lock_file() (in module troup.process) opened() (troup.infrastructure.IncomingChannelWSAdapter method) (troup.infrastructure.OutgoingChannelWSAdapter method) OutgoingChannelOverWS (class in troup.infrastructure) OutgoingChannelWSAdapter (class in troup.infrastructure)

P

parse() (troup.system.CpuinfoParser method) peer_address (troup.infrastructure.IncomingChannelWSAdapter attribute) print_help() (in module troup.debug) print_threads() (in module troup.debug) Process (class in troup.process)

PROCESS_BUILDERS (troup.tasks.LocalProcessTask attribute) ProcessInfoFile (class in troup.process) ProcessTaskException Promise (class in troup.distributed) publish() (troup.infrastructure.MessageBus method)

Q

query() (troup.node.Node method)

quit_cli() (in module troup.debug)

R

RandomBuffer (class in troup.node) read_local_node_lock() (in module troup.node) received_message() (troup.infrastructure.IncomingChannelWSAdapter method) (troup.infrastructure.OutgoingChannelWSAdapter method) refresh_values() (troup.system.StatsTracker method) register_listener() (troup.infrastructure.Channel method) register_node() (troup.node.SyncManager method) RemoteProcess (class in troup.process) remove() (troup.infrastructure.MessageBus method)

remove_app() (troup.store.InMemorySyncedStore method) (troup.store.Store method) remove_listener() (troup.observer.Observable method) result (troup.distributed.Promise attribute) run() (troup.tasks.CodeTask method) (troup.tasks.LocalProcessTask method) (troup.tasks.Task method) (troup.tasks.TasksRunner method) (troup.threading.IntervalTimer method) run_app() (troup.node.Node method) run_debug_cli() (in module troup.debug) run_node() (in module troup.main) RUNNING (troup.tasks.TaskRun attribute)

S

search_apps() (troup.store.InMemorySyncedStore method) (troup.store.Store method) send() (troup.client.CommandAPI method) (troup.infrastructure.Channel method) (troup.infrastructure.ChannelManager method) (troup.infrastructure.IncommingChannel method) (troup.infrastructure.OutgoingChannelOverWS method) send_message() (troup.client.ChannelClient method) send_message_to_node() (troup.client.ChannelClient method) send_signal() (troup.process.Process method) serialize() (in module troup.messaging) ServerAwareWebSocketProtocol (class in troup.infrastructure) set_info() (troup.process.ProcessInfoFile method) set_setting() (troup.store.InMemorySyncedStore method) (troup.store.Store method) SETTINGS_FILE (troup.store.InMemorySyncedStore attribute) shutdown() (troup.client.ChannelClient method) (troup.client.CommandAPI method) (troup.tasks.TasksRunner method) SSHRemoteProcess (class in troup.process) start() (troup.infrastructure.AsyncIOWebSocketServer method) (troup.node.Node method) (troup.node.SyncManager method) (troup.tasks.TaskRun method) (troup.threading.IntervalTimer method)

stats (troup.tasks.TasksRunner attribute) StatsTracker (class in troup.system) stop() (troup.infrastructure.AsyncIOWebSocketServer method) (troup.node.Node method) (troup.node.SyncManager method) (troup.tasks.LocalProcessTask method) (troup.tasks.Task method) (troup.tasks.TaskRun method) (troup.tasks.TasksRunner method) stop_tracking() (troup.system.StatsTracker method) STOPPING (troup.tasks.TaskRun attribute) Store (class in troup.store) store_settings() (troup.store.InMemorySyncedStore method) (troup.store.Store method) Subscribe (class in troup.infrastructure) sync() (troup.store.InMemorySyncedStore method) sync_one_node() (troup.node.SyncManager method) sync_random_nodes() (troup.node.SyncManager method) SyncManager (class in troup.node) SystemStats (class in troup.system)

T

Task (class in troup.tasks) task() (troup.client.CommandAPI method) task_for_app() (in module troup.tasks) TaskException TaskRun (class in troup.tasks) TaskRunException TasksRunner (class in troup.tasks) this_process_info_file() (in module troup.process) trigger() (troup.infrastructure.Channel method) (troup.observer.Observable method) troup (module), [1] troup.apps (module) troup.client (module) troup.debug (module)

troup.distributed (module) troup.infrastructure (module) troup.main (module) troup.messaging (module) troup.metadata (module) troup.node (module) troup.observer (module) troup.process (module) troup.setup (module) troup.store (module) troup.system (module) troup.tasks (module) troup.threading (module)

U

unlock() (troup.process.LockFile method) unregister_node() (troup.node.SyncManager method)

update_app() (troup.store.InMemorySyncedStore method) (troup.store.Store method)

V

value (troup.threading.AtomicIncrement attribute)

value() (troup.messaging.MessageBuilder method)

W

wait() (troup.process.LocalProcess method)