octavia.amphorae.drivers.haproxy package

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 AmphoraAPIClient[source]

Bases: object

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]
get_listener_status(amp, listener_id)[source]
plug_network(amp, port)[source]
plug_vip(amp, vip, net_info)[source]
request(method, amp, path='/', timeout_dict=None, **kwargs)[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 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, vip)[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(listener, vip, amphora=None)[source]
stop(listener, vip)[source]
update(listener, vip)[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(listeners, amphora_index, amphorae, timeout_dict=None)[source]

Update the amphora with a new configuration.

Parameters:
  • listeners – List of listeners to update.
  • amphora_index (integer) – The index of the amphora to update
  • amphorae (list) – List of amphorae
  • 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

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.