pulsar.mesos package¶

Submodules¶

pulsar.mesos.framework module¶

class pulsar.mesos.framework.PulsarScheduler(executor, manager_options, mesos_url)[source]¶

Bases: object

frameworkMessage(driver, executorId, slaveId, message)[source]¶

handle_setup_message(body, message)[source]¶

registered(driver, frameworkId, masterInfo)[source]¶

resourceOffers(driver, offers)[source]¶

statusUpdate(driver, update)[source]¶

pulsar.mesos.framework.run(master, manager_options, config)[source]¶

Module contents¶

This module and submodules contain code for interfacing the Apache Mesos framework.

pulsar.mesos.ensure_mesos_libs()[source]¶: Raise import error if mesos is not actually available. Original import errors above supressed because mesos is meant as an optional dependency for the Pulsar.