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

octavia.controller.queue.endpoint module

class Endpoint[source]

Bases: object

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]
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]
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]

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.