octavia.api.handlers.queue package¶

Submodules¶

octavia.api.handlers.queue.producer module¶

class AmphoraProducer[source]¶

Bases: octavia.api.handlers.queue.producer.BaseProducer

Sends failover messages to the RPC end of the queue consumer

PAYLOAD_CLASS = 'amphora'¶

failover(data_model)[source]¶

sends a failover message to the controller via oslo.messaging

Parameters:	data_model –

payload_class¶

returns a string representing the container class.

class BaseProducer[source]¶

Bases: octavia.api.handlers.abstract_handler.BaseObjectHandler

Base queue producer class.

create(model)[source]¶

Sends a create message to the controller via oslo.messaging

Parameters:	model –

delete(data_model)[source]¶

sends a delete message to the controller via oslo.messaging

Parameters:	data_model –

payload_class¶

returns a string representing the container class.

update(data_model, updated_model)[source]¶

sends an update message to the controller via oslo.messaging

Parameters:	updated_model – data_model –

class HealthMonitorProducer[source]¶

Bases: octavia.api.handlers.queue.producer.BaseProducer

Sends updates,deletes and creates to the RPC end of the queue consumer

PAYLOAD_CLASS = 'health_monitor'¶

payload_class¶

returns a string representing the container class.

class L7PolicyProducer[source]¶

Bases: octavia.api.handlers.queue.producer.BaseProducer

Sends updates,deletes and creates to the RPC end of the queue consumer

PAYLOAD_CLASS = 'l7policy'¶

payload_class¶

returns a string representing the container class.

class L7RuleProducer[source]¶

Bases: octavia.api.handlers.queue.producer.BaseProducer

Sends updates,deletes and creates to the RPC end of the queue consumer

PAYLOAD_CLASS = 'l7rule'¶

payload_class¶

returns a string representing the container class.

class ListenerProducer[source]¶

Bases: octavia.api.handlers.queue.producer.BaseProducer

Sends updates,deletes and creates to the RPC end of the queue consumer

PAYLOAD_CLASS = 'listener'¶

payload_class¶

returns a string representing the container class.

class LoadBalancerProducer[source]¶

Bases: octavia.api.handlers.queue.producer.BaseProducer

Sends updates,deletes and creates to the RPC end of the queue consumer

PAYLOAD_CLASS = 'load_balancer'¶

delete(data_model, cascade)[source]¶

sends a delete message to the controller via oslo.messaging

Parameters:	data_model –
Param:	cascade: delete listeners, etc. as well

failover(data_model)[source]¶

sends a failover message to the controller via oslo.messaging

Parameters:	data_model –

payload_class¶

returns a string representing the container class.

class MemberProducer[source]¶

Bases: octavia.api.handlers.queue.producer.BaseProducer

Sends updates,deletes and creates to the RPC end of the queue consumer

PAYLOAD_CLASS = 'member'¶

batch_update(old_ids, new_ids, updated_models)[source]¶

sends an update message to the controller via oslo.messaging

Parameters:	old_ids – list of member ids that are being deleted new_ids – list of member ids that are being created updated_models – list of member model objects to update

payload_class¶

returns a string representing the container class.

class PoolProducer[source]¶

Bases: octavia.api.handlers.queue.producer.BaseProducer

Sends updates,deletes and creates to the RPC end of the queue consumer

PAYLOAD_CLASS = 'pool'¶

payload_class¶

returns a string representing the container class.

class ProducerHandler[source]¶

Bases: octavia.api.handlers.abstract_handler.BaseHandler

Base class for all QueueProducers.

used to send messages via the Class variables load_balancer, listener, health_monitor, member, l7policy and l7rule.

amphora = <octavia.api.handlers.queue.producer.AmphoraProducer object>¶

health_monitor = <octavia.api.handlers.queue.producer.HealthMonitorProducer object>¶

l7policy = <octavia.api.handlers.queue.producer.L7PolicyProducer object>¶

l7rule = <octavia.api.handlers.queue.producer.L7RuleProducer object>¶

listener = <octavia.api.handlers.queue.producer.ListenerProducer object>¶

load_balancer = <octavia.api.handlers.queue.producer.LoadBalancerProducer object>¶

member = <octavia.api.handlers.queue.producer.MemberProducer object>¶

pool = <octavia.api.handlers.queue.producer.PoolProducer object>¶

Module contents¶