??????????????
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 173
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 174
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 175
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 176
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 177
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 178
ó
àUdac @` s d d l m Z m Z m Z e Z i d d 6d g d 6d d 6Z d Z d Z d d
l Z d d
l
Z
d d
l Z d d l m
Z
d d l m Z d d
l m Z m Z d Z d Z d d d g Z d Z d Z d e f d „ ƒ YZ d e f d „ ƒ YZ d „ Z e d k re ƒ n d
S( i ( t absolute_importt divisiont print_functions 1.1t metadata_versiont previewt statust communityt supported_bysk
---
module: haproxy
version_added: "1.9"
short_description: Enable, disable, and set weights for HAProxy backend servers using socket commands
author:
- Ravi Bhure (@ravibhure)
description:
- Enable, disable, drain and set weights for HAProxy backend servers using socket commands.
notes:
- Enable, disable and drain commands are restricted and can only be issued on
sockets configured for level 'admin'. For example, you can add the line
'stats socket /var/run/haproxy.sock level admin' to the general section of
haproxy.cfg. See U(http://haproxy.1wt.eu/download/1.5/doc/configuration.txt).
- Depends on netcat (nc) being available; you need to install the appropriate
package for your operating system before this module can be used.
options:
backend:
description:
- Name of the HAProxy backend pool.
- If this parameter is unset, it will be auto-detected.
type: str
drain:
description:
- Wait until the server has no active connections or until the timeout
determined by wait_interval and wait_retries is reached.
- Continue only after the status changes to 'MAINT'.
- This overrides the shutdown_sessions option.
type: bool
version_added: "2.4"
host:
description:
- Name of the backend host to change.
type: str
required: true
shutdown_sessions:
description:
- When disabling a server, immediately terminate all the sessions attached
to the specified server.
- This can be used to terminate long-running sessions after a server is put
into maintenance mode. Overridden by the drain option.
type: bool
default: no
socket:
description:
- Path to the HAProxy socket file.
type: path
default: /var/run/haproxy.sock
state:
description:
- Desired state of the provided backend host.
- Note that C(drain) state was added in version 2.4.
- It is supported only by HAProxy version 1.5 or later,
- When used on versions < 1.5, it will be ignored.
type: str
required: true
choices: [ disabled, drain, enabled ]
fail_on_not_found:
description:
- Fail whenever trying to enable/disable a backend host that does not exist
type: bool
default: no
version_added: "2.2"
wait:
description:
- Wait until the server reports a status of 'UP' when C(state=enabled),
status of 'MAINT' when C(state=disabled) or status of 'DRAIN' when C(state=drain)
type: bool
default: no
version_added: "2.0"
wait_interval:
description:
- Number of seconds to wait between retries.
type: int
default: 5
version_added: "2.0"
wait_retries:
description:
- Number of times to check for status after changing the state.
type: int
default: 25
version_added: "2.0"
weight:
description:
- The value passed in argument.
- If the value ends with the `%` sign, then the new weight will be
relative to the initially configured weight.
- Relative weights are only permitted between 0 and 100% and absolute
weights are permitted between 0 and 256.
type: str
s¡
- name: Disable server in 'www' backend pool
haproxy:
state: disabled
host: '{{ inventory_hostname }}'
backend: www
- name: Disable server without backend pool name (apply to all available backend pool)
haproxy:
state: disabled
host: '{{ inventory_hostname }}'
- name: Disable server, provide socket file
haproxy:
state: disabled
host: '{{ inventory_hostname }}'
socket: /var/run/haproxy.sock
backend: www
- name: Disable server, provide socket file, wait until status reports in maintenance
haproxy:
state: disabled
host: '{{ inventory_hostname }}'
socket: /var/run/haproxy.sock
backend: www
wait: yes
# Place server in drain mode, providing a socket file. Then check the server's
# status every minute to see if it changes to maintenance mode, continuing if it
# does in an hour and failing otherwise.
- haproxy:
state: disabled
host: '{{ inventory_hostname }}'
socket: /var/run/haproxy.sock
backend: www
wait: yes
drain: yes
wait_interval: 1
wait_retries: 60
- name: Disable backend server in 'www' backend pool and drop open sessions to it
haproxy:
state: disabled
host: '{{ inventory_hostname }}'
backend: www
socket: /var/run/haproxy.sock
shutdown_sessions: yes
- name: Disable server without backend pool name (apply to all available backend pool) but fail when the backend host is not found
haproxy:
state: disabled
host: '{{ inventory_hostname }}'
fail_on_not_found: yes
- name: Enable server in 'www' backend pool
haproxy:
state: enabled
host: '{{ inventory_hostname }}'
backend: www
- name: Enable server in 'www' backend pool wait until healthy
haproxy:
state: enabled
host: '{{ inventory_hostname }}'
backend: www
wait: yes
- name: Enable server in 'www' backend pool wait until healthy. Retry 10 times with intervals of 5 seconds to retrieve the health
haproxy:
state: enabled
host: '{{ inventory_hostname }}'
backend: www
wait: yes
wait_retries: 10
wait_interval: 5
- name: Enable server in 'www' backend pool with change server(s) weight
haproxy:
state: enabled
host: '{{ inventory_hostname }}'
socket: /var/run/haproxy.sock
weight: 10
backend: www
- name: Set the server in 'www' backend pool to drain mode
haproxy:
state: drain
host: '{{ inventory_hostname }}'
socket: /var/run/haproxy.sock
backend: www
N( t Template( t
AnsibleModule( t to_bytest to_texts /var/run/haproxy.socki t enabledt disabledt draini i t TimeoutExceptionc B` s e Z RS( ( t __name__t
__module__( ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR × s t HAProxyc B` s† e Z d Z d „ Z d e d „ Z d „ Z d „ Z d „ Z d d „ Z
d „ Z d „ Z d
„ Z
d „ Z d d
„ Z d „ Z RS( s]
Used for communicating with HAProxy through its local UNIX socket interface.
Perform common tasks in Haproxy related to enable server and
disable server.
The complete set of external commands Haproxy handles is documented
on their website:
http://haproxy.1wt.eu/download/1.5/doc/configuration.txt#Unix Socket commands
c C` sç | | _ | j j d | _ | j j d | _ | j j d | _ | j j d | _ | j j d | _ | j j d | _ | j j d | _ | j j d | _ | j j d | _
| j j d
| _ | j j d | _ i | _
d S( Nt statet hostt backendt weightt sockett shutdown_sessionst fail_on_not_foundt waitt wait_retriest
wait_intervalR ( t modulet paramsR R R R R R R R R R t _draint command_results( t selfR ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyt __init__ç s iÈ c C` sÑ t j t j t j ƒ | _ | j j | j ƒ | j j t d | ƒ ƒ d } d } | j j t ƒ } x& | rŽ | | 7} | j j t ƒ } qi Wt | d d ƒ} | rÀ | j
| | j ƒ ƒ n | j j ƒ | S( s¥
Executes a HAProxy command by sending a message to a HAProxy's local
UNIX socket and waiting up to 'timeout' milliseconds for the response.
s %s
t t errorst surrogate_or_strict(
R t AF_UNIXt SOCK_STREAMt clientt connectt sendallR
t recvt RECV_SIZER t capture_command_outputt stript close( R! t cmdt timeoutt capture_outputt resultt buf( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyt execute÷ s
c C` sj d | j k r g | j d s c S` s | d d k S( Nt svnamet BACKEND( ( R: ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR; s ( R5 t Falset lstript csvt
DictReadert
splitlinest tuplet mapt filter( R! t datat r( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyt discover_all_backends s c C` sº | j d d t ƒ } | j ƒ } g | D] } d | k r( | ^ q( } yM | d j d ƒ d j ƒ j d d ƒ } t | d ƒ t | d ƒ f } Wn t t t f k
rµ d
} n X| S( st
Attempt to extract the haproxy version.
Return a tuple containing major and minor version.
s show infoiÈ s Version:i t :i t .i i N( R5 R> RB t partitionR. t splitt intt
ValueErrort TypeErrort
IndexErrort None( R! RF t linest xt linet version_valuest version( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyt discover_version! s %)$
c C` sÓ | d k r | j ƒ } n | g } x¨ | D] } | j | | ƒ } | j rx | d k rx | j j d d | | f ƒ n | d k r+ | j t | ƒ j d | d | ƒ ƒ | j rË | j
| | | ƒ qË q+ q+ Wd S( s–
Run some command on the specified backends. If no backends are provided they will
be discovered automatically (all backends)
t msgs, The specified backend '%s/%s' was not found!R9 R< N( RQ RH t
get_state_forR R t fail_jsonR5 R t
substituteR t wait_until_status( R! R0 R9 R< t wait_for_statust backendsR R ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyt execute_for_backends1 s
% c ` sj | j d d t ƒ j d ƒ } t j | j ƒ ƒ } t t d „ t ‡ ‡ f d † | ƒ ƒ ƒ } | pi d S( sÐ
Find the state of specific services. When pxname is not set, get all backends for a specific host.
Returns a list of dictionaries containing the status and weight for those services.
s show statiÈ s # c S` s% i | d d 6| d d 6| d d 6S( NR R t scur( ( R: ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR; R s c ` s* ˆ d k s | d ˆ k o) | d ˆ k S( NR9 R< ( RQ ( R: ( R9 R< ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR; S s N(
R5 R> R? R@ RA RB RC RD RE RQ ( R! R9 R< RF RG R ( ( R9 R< sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyRY I s c C` s® x t d | j ƒ D]m } | j | | ƒ } | | d d k rp | j si | d d d k r€ d | k r€ t Sq t j | j ƒ q W| j j d d | | | | j f ƒ d S(
s#
Wait for a service to reach the specified status. Try RETRIES times
with INTERVAL seconds of sleep in between. If the service has not reached
the expected status in that time, the module will fail. If the service was
not found, the module will fail.
i i R R` t 0t MAINTRX s8 server %s/%s not status '%s' after %d retries. Aborting.N(
t rangeR RY R t Truet timet sleepR R RZ ( R! R9 R< R t iR ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR\ Y s *c C` s7 d } | r | d | 7} n | j | | | d ƒ d S( sÕ
Enabled action, marks server to UP and checks are re-enabled,
also supports to get current weight for server (default) and
set the weight for haproxy backend server when provides.
s9 get weight $pxname/$svname; enable server $pxname/$svnames ; set weight $pxname/$svname %st UPN( R_ ( R! R R R R0 ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR n s c C` s3 d } | r | d 7} n | j | | | d ƒ d S( sñ
Disabled action, marks server to DOWN for maintenance. In this mode, no more checks will be
performed on the server until it leaves maintenance,
also it shutdown sessions while disabling backend host server.
s: get weight $pxname/$svname; disable server $pxname/$svnames* ; shutdown sessions server $pxname/$svnameRb N( R_ ( R! R R R R0 ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR
y s
t DRAINc C` sA | j ƒ } | r= d | k r= d } | j | | | | ƒ n d S( sÄ
Drain action, sets the server to DRAIN mode.
In this mode mode, the server will not accept any new connections
other than those that are accepted via persistence.
i i s& set server $pxname/$svname state drainN( i i ( RW R_ ( R! R R R t haproxy_versionR0 ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR „ s c C` sK | j | j | j ƒ | j d <| j d k rM | j | j | j | j ƒ n§ | j d k r„ | j r„ | j | j | j d d ƒnp | j d k r² | j | j | j | j
ƒ nB | j d k rÚ | j | j | j ƒ n | j j d d | j ƒ | j | j | j ƒ | j d <| j d | j d k | j d
<| j j
| j d S( sN
Figure out what you want to do from ansible, and then do it.
t state_beforeR R
R Rb R RX s unknown state specified: '%s't state_aftert changedN( RY R R R R R R R R R
R R RZ t exit_json( R! ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyt act‘ s !N( R R t __doc__R" Rd R5 R- RH RW RQ R_ RY R\ R R
R Ro ( ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyR Û s
c C` s& t d t d t d d d t d t ƒ d t d d d t ƒ d t d d ƒ d t d d ƒ d
t d d d t ƒ d
t d d d t ƒ d t d d d t ƒ d t d d d t ƒ d t d d d t ƒ d t d d d t ƒ d t d d d t ƒ ƒ ƒ } t s | j d d ƒ n t
| ƒ } | j ƒ d S( Nt
argument_specR t typet strt requiredt choicesR R R R t patht defaultR t boolR R R RM R R RX s unable to locate haproxy socket( R t dictRd t ACTION_CHOICESt DEFAULT_SOCKET_LOCATIONR> t WAIT_RETRIESt
WAIT_INTERVALR RZ R Ro ( R t ansible_haproxy( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyt main s" t __main__( t
__future__R R R Rr t
__metaclass__t ANSIBLE_METADATAt
DOCUMENTATIONt EXAMPLESR@ R Re t stringR t ansible.module_utils.basicR t ansible.module_utils._textR
R R{ R, Rz R| R} t ExceptionR t objectR R R ( ( ( sE /usr/lib/python2.7/site-packages/ansible/modules/net_tools/haproxy.pyt s,
\\ Ò