octavia.controller.queue.v2 package

Submodules

octavia.controller.queue.v2.consumer module

class ConsumerService(worker_id, conf)

Bases: Service

name: ClassVar[str | None] = 'ConsumerService'

Service name used in the process title and the log messages in additional of the worker_id.

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