# octavia.cmd.octavia_worker

# Source code for octavia.cmd.octavia_worker

    # Copyright 2014 Rackspace
    #
    #    Licensed under the Apache License, Version 2.0 (the "License"); you may
    #    not use this file except in compliance with the License. You may obtain
    #    a copy of the License at
    #
    #         http://www.apache.org/licenses/LICENSE-2.0
    #
    #    Unless required by applicable law or agreed to in writing, software
    #    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
    #    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
    #    License for the specific language governing permissions and limitations
    #    under the License.

    import sys

    import cotyledon
    from cotyledon import oslo_config_glue
    from oslo_config import cfg
    from oslo_reports import guru_meditation_report as gmr

    from octavia.common import service as octavia_service
    from octavia.controller.queue.v1 import consumer as consumer_v1
    from octavia.controller.queue.v2 import consumer as consumer_v2
    from octavia import version

    CONF = cfg.CONF

    def main():
        octavia_service.prepare_service(sys.argv)

        gmr.TextGuruMeditation.setup_autorun(version)

        sm = cotyledon.ServiceManager()
        sm.add(consumer_v1.ConsumerService, workers=CONF.controller_worker.workers,
               args=(CONF,))
        sm.add(consumer_v2.ConsumerService,
               workers=CONF.controller_worker.workers, args=(CONF,))
        oslo_config_glue.setup(sm, CONF, reload_method="mutate")
        sm.run()

    if __name__ == "__main__":
        main()

this page last updated: 2020-04-10 18:17:54

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.

found an error? report a bug questions?