# octavia.controller.queue.v2 package

## Submodules

## octavia.controller.queue.v2.consumer module

class ConsumerService(worker_id, conf)

  Bases: `Service`

  run()

    Method representing the service activity

    If not implemented the process will just wait to receive an ending signal.

    This method is ran into the thread and can block or return as needed

    Any exceptions raised by this method will be logged and the worker will exit with status 1.

  terminate()

    Gracefully shutdown the service

    This method will be executed when the Service has to shutdown cleanly.

    If not implemented the process will just end with status 0.

    To customize the exit code, the `SystemExit` exception can be used.

    Any exceptions raised by this method will be logged and the worker will exit with status 1.

## octavia.controller.queue.v2.endpoints module

class Endpoints

  Bases: `object`

  batch_update_members(context, old_members, new_members, updated_members)
  create_health_monitor(context, health_monitor)
  create_l7policy(context, l7policy)
  create_l7rule(context, l7rule)
  create_listener(context, listener)
  create_load_balancer(context, loadbalancer, flavor=None, availability_zone=None)
  create_member(context, member)
  create_pool(context, pool)
  delete_amphora(context, amphora_id)
  delete_health_monitor(context, health_monitor)
  delete_l7policy(context, l7policy)
  delete_l7rule(context, l7rule)
  delete_listener(context, listener)
  delete_load_balancer(context, loadbalancer, cascade=False)
  delete_member(context, member)
  delete_pool(context, pool)
  failover_amphora(context, amphora_id)
  failover_load_balancer(context, load_balancer_id)
  target = <Target namespace=controller, version=2.0>
  update_amphora_agent_config(context, amphora_id)
  update_health_monitor(context, original_health_monitor, health_monitor_updates)
  update_l7policy(context, original_l7policy, l7policy_updates)
  update_l7rule(context, original_l7rule, l7rule_updates)
  update_listener(context, original_listener, listener_updates)
  update_load_balancer(context, original_load_balancer, load_balancer_updates)
  update_member(context, original_member, member_updates)
  update_pool(context, original_pool, pool_updates)

## Module contents

this page last updated: 2025-10-06 11:22:08

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