octavia.controller.queue package

octavia.controller.queue package

Submodules

octavia.controller.queue.consumer module

class ConsumerService(worker_id, conf)[source]

Bases: cotyledon._service.Service

run()[source]

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(graceful=False)[source]

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.endpoint module

class Endpoint[source]

Bases: object

batch_update_members(context, old_member_ids, new_member_ids, updated_members)[source]
create_health_monitor(context, health_monitor_id)[source]
create_l7policy(context, l7policy_id)[source]
create_l7rule(context, l7rule_id)[source]
create_listener(context, listener_id)[source]
create_load_balancer(context, load_balancer_id)[source]
create_member(context, member_id)[source]
create_pool(context, pool_id)[source]
delete_health_monitor(context, health_monitor_id)[source]
delete_l7policy(context, l7policy_id)[source]
delete_l7rule(context, l7rule_id)[source]
delete_listener(context, listener_id)[source]
delete_load_balancer(context, load_balancer_id, cascade=False)[source]
delete_member(context, member_id)[source]
delete_pool(context, pool_id)[source]
failover_amphora(context, amphora_id)[source]
failover_load_balancer(context, load_balancer_id)[source]
target = <Target namespace=controller, version=1.0>
update_health_monitor(context, health_monitor_id, health_monitor_updates)[source]
update_l7policy(context, l7policy_id, l7policy_updates)[source]
update_l7rule(context, l7rule_id, l7rule_updates)[source]
update_listener(context, listener_id, listener_updates)[source]
update_load_balancer(context, load_balancer_id, load_balancer_updates)[source]
update_member(context, member_id, member_updates)[source]
update_pool(context, pool_id, pool_updates)[source]

octavia.controller.queue.event_queue module

class EventStreamerBase[source]

Bases: object

Base class for EventStreamer

A stand in abstract class that defines what methods are stevedore loaded implementations of event streamer is expected to provide.

emit(cnt)[source]

method to send a DB event to neutron-lbaas if it is needed.

Parameters:cnt – an InfoContainer container object
Returns:None
class EventStreamerNeutron[source]

Bases: octavia.controller.queue.event_queue.EventStreamerBase

Neutron LBaaS

When you’re using Octavia alongside neutron LBaaS this class provides a mechanism to send updates to neutron LBaaS database via oslo_messaging queues.

emit(cnt)[source]

method to send a DB event to neutron-lbaas if it is needed.

Parameters:cnt – an InfoContainer container object
Returns:None
class EventStreamerNoop[source]

Bases: octavia.controller.queue.event_queue.EventStreamerBase

Nop class implementation of EventStreamer

Useful if you’re running in standalone mode and don’t need to send updates to Neutron LBaaS

emit(cnt)[source]

method to send a DB event to neutron-lbaas if it is needed.

Parameters:cnt – an InfoContainer container object
Returns:None

Module contents

Creative Commons Attribution 3.0 License

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