octavia.amphorae.drivers.haproxy package¶

Submodules¶

octavia.amphorae.drivers.haproxy.data_models module¶

class CPU(total=None, user=None, system=None, soft_irq=None)[source]¶

Bases: octavia.common.data_models.BaseDataModel

class Details(hostname=None, uuid=None, version=None, api_version=None, network_tx=None, network_rx=None, active=None, haproxy_count=None, cpu=None, memory=None, disk=None, load=None, listeners=None, packages=None)[source]¶

Bases: octavia.common.data_models.BaseDataModel

class Disk(used=None, available=None)[source]¶

Bases: octavia.common.data_models.BaseDataModel

class Info(hostname=None, uuid=None, version=None, api_version=None)[source]¶

Bases: octavia.common.data_models.BaseDataModel

class ListenerStatus(status=None, uuid=None, provisioning_status=None, type=None, pools=None)[source]¶

Bases: octavia.common.data_models.BaseDataModel

class Memory(total=None, free=None, available=None, buffers=None, cached=None, swap_used=None, shared=None, slab=None, committed_as=None)[source]¶

Bases: octavia.common.data_models.BaseDataModel

class Pool(uuid=None, status=None, members=None)[source]¶

Bases: octavia.common.data_models.BaseDataModel

class Topology(hostname=None, uuid=None, topology=None, role=None, ip=None, ha_ip=None)[source]¶

Bases: octavia.common.data_models.BaseDataModel

octavia.amphorae.drivers.haproxy.exceptions module¶

exception APIException(**kwargs)[source]¶

Bases: webob.exc.HTTPClientError

code = 500¶

msg = 'Something unknown went wrong'¶

exception Conflict(**kwargs)[source]¶

Bases: octavia.amphorae.drivers.haproxy.exceptions.APIException

code = 409¶

msg = 'Conflict'¶

exception Forbidden(**kwargs)[source]¶

Bases: octavia.amphorae.drivers.haproxy.exceptions.APIException

code = 403¶

msg = 'Forbidden'¶

exception InternalServerError(**kwargs)[source]¶

Bases: octavia.amphorae.drivers.haproxy.exceptions.APIException

code = 500¶

msg = 'Internal Server Error'¶

exception InvalidRequest(**kwargs)[source]¶

Bases: octavia.amphorae.drivers.haproxy.exceptions.APIException

code = 400¶

msg = 'Invalid request'¶

exception NotFound(**kwargs)[source]¶

Bases: octavia.amphorae.drivers.haproxy.exceptions.APIException

code = 404¶

msg = 'Not Found'¶

exception ServiceUnavailable(**kwargs)[source]¶

Bases: octavia.amphorae.drivers.haproxy.exceptions.APIException

code = 503¶

msg = 'Service Unavailable'¶

exception Unauthorized(**kwargs)[source]¶

Bases: octavia.amphorae.drivers.haproxy.exceptions.APIException

code = 401¶

msg = 'Unauthorized'¶

check_exception(response, ignore=())[source]¶

octavia.amphorae.drivers.haproxy.rest_api_driver module¶

class AmphoraAPIClient0_5[source]¶

Bases: octavia.amphorae.drivers.haproxy.rest_api_driver.AmphoraAPIClientBase

delete_cert_pem(amp, listener_id, pem_filename)[source]¶

delete_listener(amp, listener_id)[source]¶

get_all_listeners(amp)[source]¶

get_cert_md5sum(amp, listener_id, pem_filename, ignore=())[source]¶

get_details(amp)[source]¶

get_info(amp)[source]¶

get_interface(amp, ip_addr, timeout_dict=None)[source]¶

plug_network(amp, port)[source]¶

plug_vip(amp, vip, net_info)[source]¶

update_agent_config(amp, agent_config, timeout_dict=None)[source]¶

update_cert_for_rotation(amp, pem_file)[source]¶

upload_cert_pem(amp, listener_id, pem_filename, pem_file)[source]¶

upload_config(amp, listener_id, config, timeout_dict=None)[source]¶

upload_udp_config(amp, listener_id, config, timeout_dict=None)[source]¶

upload_vrrp_config(amp, config)[source]¶

class AmphoraAPIClient1_0[source]¶

Bases: octavia.amphorae.drivers.haproxy.rest_api_driver.AmphoraAPIClientBase

delete_cert_pem(amp, loadbalancer_id, pem_filename)[source]¶

delete_listener(amp, object_id)[source]¶

get_all_listeners(amp)[source]¶

get_cert_md5sum(amp, loadbalancer_id, pem_filename, ignore=())[source]¶

get_details(amp)[source]¶

get_info(amp)[source]¶

get_interface(amp, ip_addr, timeout_dict=None)[source]¶

get_listener_status(amp, listener_id)[source]¶

plug_network(amp, port)[source]¶

plug_vip(amp, vip, net_info)[source]¶

update_agent_config(amp, agent_config, timeout_dict=None)[source]¶

update_cert_for_rotation(amp, pem_file)[source]¶

upload_cert_pem(amp, loadbalancer_id, pem_filename, pem_file)[source]¶

upload_config(amp, loadbalancer_id, config, timeout_dict=None)[source]¶

upload_udp_config(amp, listener_id, config, timeout_dict=None)[source]¶

upload_vrrp_config(amp, config)[source]¶

class AmphoraAPIClientBase[source]¶

Bases: object

get_api_version(amp)[source]¶

request(method, amp, path='/', timeout_dict=None, retry_404=True, **kwargs)[source]¶

class CustomHostNameCheckingAdapter(pool_connections=10, pool_maxsize=10, max_retries=0, pool_block=False)[source]¶

Bases: requests.adapters.HTTPAdapter

cert_verify(conn, url, verify, cert)[source]¶

class HaproxyAmphoraLoadBalancerDriver[source]¶

Bases: octavia.amphorae.drivers.driver_base.AmphoraLoadBalancerDriver, octavia.amphorae.drivers.keepalived.vrrp_rest_driver.KeepalivedAmphoraDriverMixin

delete(listener)[source]¶

finalize_amphora(amphora)[source]¶

get_diagnostics(amphora)[source]¶

get_info(amphora)[source]¶

post_network_plug(amphora, port)[source]¶

post_vip_plug(amphora, load_balancer, amphorae_network_config)[source]¶

start(loadbalancer, amphora=None)[source]¶

update(loadbalancer)[source]¶

update_amphora_agent_config(amphora, agent_config, timeout_dict=None)[source]¶

Update the amphora agent configuration file.

Parameters:	amphora (object) – The amphora to update. agent_config (string) – The new amphora agent configuration. timeout_dict – Dictionary of timeout values for calls to the amphora. May contain: req_conn_timeout, req_read_timeout, conn_max_retries, conn_retry_interval
Returns:	None

Note: This will mutate the amphora agent config and adopt the

new values.

update_amphora_listeners(loadbalancer, amphora, timeout_dict=None)[source]¶

Update the amphora with a new configuration.

Parameters:	loadbalancer (object) – The load balancer to update amphora (object) – The amphora to update timeout_dict – Dictionary of timeout values for calls to the amphora. May contain: req_conn_timeout, req_read_timeout, conn_max_retries, conn_retry_interval
Returns:	None

Updates the configuration of the listeners on a single amphora.

upload_cert_amp(amp, pem)[source]¶

Module contents¶