haproxy.py 文件源码

def update(self, services, fqdn="flyby.example.com", resolvers=None, log_endpoint=None, log_format=None):
        logger.debug("Updating HAProxy configs...")
        resolvers = resolvers if resolvers else []
        env = Environment(loader=PackageLoader('flyby', 'config'))
        template = env.get_template('haproxy.cfg.j2')
        tempate_params = dict(
            fqdn=fqdn,
            services=self._filter_services(services),
            resolvers=resolvers,
            log_endpoint=log_endpoint,
            log_format=log_format
        )
        c = template.render(**tempate_params)
        if self.config != c:
            logger.debug("Changed configs identified.")
            self.config = c
            self._run()
            logger.debug("HAProxy configs successfully updated.")
        else:
            logger.debug("HAProxy configs up-to-date. Nothing to do.")