scheduler.py 文件源码

def __init__(self, scheduler, name, user=getpass.getuser(),
                 master=os.getenv('MESOS_MASTER', 'zk://localhost:2181'),
                 failover_timeout=100, capabilities=None, principal=None, secret=None,
                 implicit_acknowledgements=True, handlers={}, loop=None):
        self.loop = loop or IOLoop()
        self.master = master
        self.leading_master_seq = None
        self.leading_master_info = None

        self.scheduler = scheduler
        self.framework = {
            'user': user,
            'name': name,
            'capabilities': capabilities or [],
            'failover_timeout': failover_timeout,
            'hostname': socket.gethostname()
        }

        self.implicit_acknowledgements = implicit_acknowledgements

        defaults = {Event.SUBSCRIBED: self.on_subscribed,
                    Event.OFFERS: self.on_offers,
                    Event.RESCIND: self.on_rescind,
                    Event.UPDATE: self.on_update,
                    Event.MESSAGE: self.on_message,
                    Event.RESCIND_INVERSE_OFFER: self.on_rescind_inverse,
                    Event.FAILURE: self.on_failure,
                    Event.ERROR: self.on_error,
                    Event.HEARTBEAT: self.on_heartbeat,
                    Event.OUTBOUND_SUCCESS: self.on_outbound_success,
                    Event.OUTBOUND_ERROR: self.on_outbound_error}
        self.handlers = merge(defaults, handlers)

        self.subscription = Subscription(self.framework, self.master,
                                         '/api/v1/scheduler', self.handlers,
                                         principal=principal,
                                         secret=secret,
                                         timeout=failover_timeout,
                                         loop=self.loop)