octavia.cmd package¶

Submodules¶

octavia.cmd.agent module¶

class AmphoraAgent(app, options=None)[source]¶

Bases: gunicorn.app.base.BaseApplication

load()[source]¶

load_config()[source]¶

This method is used to load the configuration from one or several input(s). Custom Command line, configuration file. You have to override this method in your class.

main()[source]¶

octavia.cmd.api module¶

main()[source]¶

octavia.cmd.driver_agent module¶

main()[source]¶

octavia.cmd.haproxy_vrrp_check module¶

get_status(sock_address)[source]¶

Query haproxy stat socket

Only VRRP fail over if the stats socket is not responding.

Parameters

sock_address – unix socket file

Returns

0 if haproxy responded

health_check(sock_addresses)[source]¶

Invoke queries for all defined listeners

Parameters

sock_addresses –

Returns

main()[source]¶

octavia.cmd.health_checker module¶

crc32c(data)[source]¶

main()[source]¶

sctp_health_check(ip_address, port, timeout=2)[source]¶

octavia.cmd.health_manager module¶

hm_health_check(exit_event)[source]¶

hm_listener(exit_event)[source]¶

main()[source]¶

octavia.cmd.house_keeping module¶

cert_rotation()[source]¶

Perform certificate rotation.

db_cleanup()[source]¶

Perform db cleanup for old resources.

main()[source]¶

octavia.cmd.interface module¶

exception InterfaceException(*args, **kwargs)[source]¶

Bases: octavia.common.exceptions.OctaviaException

message = 'Could not configure interface: %(msg)s'¶

interface_cmd(interface_name, action)[source]¶

interfaces_find(interface_controller, name)[source]¶

interfaces_update(interfaces, action_fn, action_str)[source]¶

main()[source]¶

octavia.cmd.octavia_worker module¶

main()[source]¶

octavia.cmd.prometheus_proxy module¶

class PrometheusProxy(*args, directory=None, **kwargs)[source]¶

Bases: http.server.SimpleHTTPRequestHandler

do_GET()[source]¶

Serve a GET request.

log_request(*args, **kwargs)[source]¶

Log an accepted request.

This is called by send_response().

protocol_version = 'HTTP/1.1'¶

class SignalHandler[source]¶

Bases: object

shutdown(*args)[source]¶

class ThreadedHTTPServer(server_address, RequestHandlerClass, bind_and_activate=True)[source]¶

Bases: socketserver.ThreadingMixIn, http.server.HTTPServer

daemon_threads = True¶

main()[source]¶

shutdown_thread(http)[source]¶

octavia.cmd.status module¶

class Checks[source]¶

Bases: oslo_upgradecheck.upgradecheck.UpgradeCommands

Contains upgrade checks

Various upgrade checks should be added as separate methods in this class and added to _upgrade_checks tuple.

main()[source]¶

Module contents¶