Mosaic API Reference

• Running mosaic
  • run()
  • init()
• 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()
• Comms
  • Comms
    • CommsManager
      • CommsManager.address
      • CommsManager.beat()
      • CommsManager.call()
      • CommsManager.call_safe()
      • CommsManager.cmd()
      • CommsManager.cmd_async()
      • CommsManager.cmd_pubsub()
      • CommsManager.cmd_pubsub_async()
      • CommsManager.cmd_recv()
      • CommsManager.cmd_recv_async()
      • CommsManager.connect()
      • CommsManager.connect_pubsub()
      • CommsManager.connect_recv()
      • CommsManager.connect_send()
      • CommsManager.connected()
      • CommsManager.disconnect()
      • CommsManager.disconnect_recv()
      • CommsManager.disconnect_send()
      • CommsManager.hand()
      • CommsManager.handshake()
      • CommsManager.heart()
      • CommsManager.listen()
      • CommsManager.listen_async()
      • CommsManager.logger
      • CommsManager.port
      • CommsManager.process_msg()
      • CommsManager.pubsub_port
      • CommsManager.recv()
      • CommsManager.recv_async()
      • CommsManager.recv_pubsub()
      • CommsManager.recv_pubsub_async()
      • CommsManager.register_reply_future()
      • CommsManager.reply()
      • CommsManager.send()
      • CommsManager.send_async()
      • CommsManager.send_exception()
      • CommsManager.send_pubsub()
      • CommsManager.send_pubsub_async()
      • CommsManager.send_recv()
      • CommsManager.send_recv_async()
      • CommsManager.shake()
      • CommsManager.shaken()
      • CommsManager.start_heartbeat()
      • CommsManager.stop()
      • CommsManager.uid_address()
      • CommsManager.uid_port()
      • CommsManager.wait()
      • CommsManager.wait_for()
  • Serialisation
    • serialise()
    • deserialise()
  • Compression
    • maybe_compress()
    • decompress()
• Core
  • Tessera
    • tessera()
    • Tessera
      • Tessera.call_safe()
      • Tessera.collectable
      • Tessera.get_attr()
      • Tessera.is_parameter
      • Tessera.listen()
      • Tessera.listen_async()
      • Tessera.make_parameter()
      • Tessera.obj
      • Tessera.queue_task()
      • Tessera.remote_cls()
      • Tessera.remote_runtime
      • Tessera.run_async()
      • Tessera.send_exception()
      • Tessera.set_attr()
      • Tessera.type
    • TesseraProxy
      • TesseraProxy.collectable
      • TesseraProxy.get_attr()
      • TesseraProxy.init()
      • TesseraProxy.is_parameter
      • TesseraProxy.make_parameter()
      • TesseraProxy.remote_cls()
      • TesseraProxy.remote_runtime
      • TesseraProxy.runtime_id
      • TesseraProxy.select_worker()
      • TesseraProxy.set_attr()
      • TesseraProxy.type
    • ArrayProxy
      • ArrayProxy.get_attr()
      • ArrayProxy.init()
      • ArrayProxy.make_parameter()
      • ArrayProxy.remote_runtime
      • ArrayProxy.remote_type()
      • ArrayProxy.runtime_id
      • ArrayProxy.set_attr()
      • ArrayProxy.type
    • ParameterMixin
      • ParameterMixin.cached
      • ParameterMixin.get()
      • ParameterMixin.has_tessera
      • ParameterMixin.is_proxy
      • ParameterMixin.is_tessera
      • ParameterMixin.publish()
      • ParameterMixin.pull()
      • ParameterMixin.push()
      • ParameterMixin.ref
      • ParameterMixin.set()
  • Task
    • Task
      • Task.add_event()
      • Task.add_profile()
      • Task.args_value()
      • Task.check_result()
      • Task.collectable
      • Task.is_remote
      • Task.kwargs_value()
      • Task.prepare_args()
      • Task.remote_cls()
      • Task.remote_runtime
      • Task.sender_id
      • Task.set_done()
      • Task.set_exception()
      • Task.set_result()
      • Task.tessera_id
      • Task.type
    • TaskProxy
      • TaskProxy.add_done_callback()
      • TaskProxy.add_event()
      • TaskProxy.add_profile()
      • TaskProxy.check_result()
      • TaskProxy.collectable
      • TaskProxy.deregister_runtime()
      • TaskProxy.done
      • TaskProxy.done_future
      • TaskProxy.init()
      • TaskProxy.init_future
      • TaskProxy.outputs
      • TaskProxy.remote_cls()
      • TaskProxy.remote_runtime
      • TaskProxy.result()
      • TaskProxy.runtime_id
      • TaskProxy.set_done()
      • TaskProxy.set_exception()
      • TaskProxy.set_result()
      • TaskProxy.size()
      • TaskProxy.tessera_id
      • TaskProxy.type
      • TaskProxy.wait()
    • TaskOutputGenerator
    • TaskOutput
      • TaskOutput.result()
      • TaskOutput.size()
    • TaskDone
      • TaskDone.result()
      • TaskDone.size()
  • Base
    • CMDBase
      • CMDBase.add_event()
      • CMDBase.add_profile()
      • CMDBase.cmd()
      • CMDBase.cmd_async()
      • CMDBase.cmd_recv()
      • CMDBase.cmd_recv_async()
      • CMDBase.collectable
      • CMDBase.deregister()
      • CMDBase.deregister_runtime()
      • CMDBase.init()
      • CMDBase.init_future
      • CMDBase.is_proxy
      • CMDBase.is_remote
      • CMDBase.proxy()
      • CMDBase.remote_cls()
      • CMDBase.remote_runtime
      • CMDBase.remote_type()
      • CMDBase.runtime_id
      • CMDBase.start_trace()
      • CMDBase.state
      • CMDBase.state_changed()
      • CMDBase.stop_trace()
      • CMDBase.type
      • CMDBase.uid
    • RemoteBase
      • RemoteBase.dec_ref()
      • RemoteBase.deregister_proxy()
      • RemoteBase.inc_ref()
      • RemoteBase.is_proxy
      • RemoteBase.is_remote
      • RemoteBase.proxies
      • RemoteBase.register_proxy()
      • RemoteBase.remote_runtime
      • RemoteBase.remote_type()
      • RemoteBase.runtime_id
    • ProxyBase
      • ProxyBase.deregister()
      • ProxyBase.is_proxy
      • ProxyBase.is_remote
      • ProxyBase.remote_runtime
      • ProxyBase.remote_type()
      • ProxyBase.runtime_id
• Profiling
• Types
  • Struct
    • Struct
      • Struct.copy()
      • Struct.delete()
      • Struct.get()
      • Struct.items()
      • Struct.keys()
      • Struct.pop()
      • Struct.update()
      • Struct.values()
• File manipulation
  • HDF5
    • HDF5
      • HDF5.append()
      • HDF5.close()
      • HDF5.dump()
      • HDF5.file
      • HDF5.filename
      • HDF5.load()
      • HDF5.mode
    • file_exists()
• Utils
  • Event loop
    • EventLoop
      • EventLoop.get_event_loop()
      • EventLoop.interval()
      • EventLoop.run()
      • EventLoop.run_forever()
      • EventLoop.run_in_executor()
      • EventLoop.set_main_thread()
      • EventLoop.stop()
      • EventLoop.timeout()
      • EventLoop.wrap_future()
    • Future
      • Future.add_done_callback()
      • Future.cancelled()
      • Future.done()
      • Future.exception()
      • Future.future
      • Future.result()
      • Future.set_exception()
      • Future.set_result()
      • Future.state
      • Future.uid
    • async_property
      • async_property.awaitable_only()
      • async_property.get_loader()
    • gather()
  • Subprocess
    • subprocess()
  • Logger
    • LoggerManager
      • LoggerManager.debug()
      • LoggerManager.error()
      • LoggerManager.info()
      • LoggerManager.perf()
      • LoggerManager.send()
      • LoggerManager.set_default()
      • LoggerManager.set_level()
      • LoggerManager.set_local()
      • LoggerManager.set_remote()
      • LoggerManager.warn()
      • LoggerManager.warning()
    • clear_logger()
  • Change case
    • camel_case()
    • snake_case()
  • Utils
    • MultiError
      • MultiError.add()
    • cpu_count()
    • gpu_count()
    • memory_limit()
    • memory_used()
    • remote_sizeof()
    • set_main_thread()
    • sizeof()