Runtime

• Runtime
  • Runtime
    • Runtime.address
    • Runtime.async_for()
    • Runtime.barrier()
    • Runtime.cmd()
    • Runtime.connect()
    • Runtime.cpu_load()
    • Runtime.dec_committed_mem()
    • Runtime.dec_pending_tasks()
    • Runtime.dec_ref()
    • Runtime.dec_refs()
    • Runtime.dec_running_tasks()
    • Runtime.deregister()
    • Runtime.disconnect()
    • Runtime.drop()
    • Runtime.fits_in_memory()
    • Runtime.get()
    • Runtime.get_comms()
    • Runtime.get_event_loop()
    • Runtime.get_head()
    • Runtime.get_local_warehouse()
    • Runtime.get_monitor()
    • Runtime.get_node()
    • Runtime.get_nodes()
    • Runtime.get_warehouse()
    • Runtime.get_worker()
    • Runtime.get_workers()
    • Runtime.get_zmq_context()
    • Runtime.hand()
    • Runtime.inc_committed_mem()
    • Runtime.inc_pending_tasks()
    • Runtime.inc_ref()
    • Runtime.inc_running_tasks()
    • Runtime.init()
    • Runtime.init_task()
    • Runtime.init_tessera()
    • Runtime.init_warehouse()
    • Runtime.is_head
    • Runtime.is_monitor
    • Runtime.is_node
    • Runtime.is_warehouse
    • Runtime.is_worker
    • Runtime.log_debug()
    • Runtime.log_error()
    • Runtime.log_info()
    • Runtime.log_perf()
    • Runtime.log_warning()
    • Runtime.maintenance()
    • Runtime.maintenance_msg()
    • Runtime.maintenance_queue()
    • Runtime.memory_limit()
    • Runtime.needs_registering()
    • Runtime.nodes
    • Runtime.num_nodes
    • Runtime.num_workers
    • Runtime.port
    • Runtime.proxy()
    • Runtime.proxy_from_uid()
    • Runtime.ps_process
    • Runtime.pubsub_port
    • Runtime.put()
    • Runtime.raise_exception()
    • Runtime.recv_profile()
    • Runtime.register()
    • Runtime.remove_proxy_from_uid()
    • Runtime.request_profile()
    • Runtime.send_profile()
    • Runtime.set_comms()
    • Runtime.set_logger()
    • Runtime.set_profiler()
    • Runtime.shake()
    • Runtime.stop()
    • Runtime.wait()
    • Runtime.workers
  • RuntimeProxy
    • RuntimeProxy.address
    • RuntimeProxy.comms
    • RuntimeProxy.port
    • RuntimeProxy.pubsub_port
    • RuntimeProxy.subprocess
• Head
  • Head
    • Head.init()
    • Head.init_monitor()
    • Head.is_head
    • Head.set_logger()
    • Head.set_profiler()
    • Head.stop()
• Monitor
  • Monitor
    • Monitor.add_task_event()
    • Monitor.add_task_profile()
    • Monitor.add_tessera_event()
    • Monitor.add_tessera_profile()
    • Monitor.append_description()
    • Monitor.barrier()
    • Monitor.init()
    • Monitor.init_cluster()
    • Monitor.init_file()
    • Monitor.init_local()
    • Monitor.is_monitor
    • Monitor.select_worker()
    • Monitor.set_logger()
    • Monitor.set_profiler()
    • Monitor.stop()
    • Monitor.update_node()
  • Strategies
    • MonitorStrategy
      • MonitorStrategy.select_worker()
      • MonitorStrategy.update_node()
      • MonitorStrategy.update_task()
      • MonitorStrategy.update_tessera()
    • RoundRobin
      • RoundRobin.select_worker()
      • RoundRobin.update_node()
• Node
  • Node
    • Node.heart()
    • Node.init()
    • Node.init_workers()
    • Node.is_node
    • Node.resource_monitor()
    • Node.set_logger()
    • Node.set_profiler()
    • Node.stop()
    • Node.update_monitored_node()
• Worker
  • Worker
    • Worker.is_worker
    • Worker.set_logger()
    • Worker.set_profiler()
• Utils
  • MonitoredObject
    • MonitoredObject.add_event()
    • MonitoredObject.add_profile()
    • MonitoredObject.append()
    • MonitoredObject.collect()
    • MonitoredObject.state
  • MonitoredResource
    • MonitoredResource.add_group()
    • MonitoredResource.add_resource()
    • MonitoredResource.append()
    • MonitoredResource.get_update()
    • MonitoredResource.sort_resources()
    • MonitoredResource.state
    • MonitoredResource.update()