??????????????
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
Z y* d d l
m Z d d l m Z e Z Wn# e k
r¹ e
j ƒ Z e Z n Xd d
l m Z m Z d d l m Z d „ Z d „ Z d d d „ ƒ YZ e d k re ƒ n d
S( i ( t absolute_importt divisiont print_functions 1.1t metadata_versiont previewt statust communityt supported_bys-
---
module: znode
version_added: "2.0"
short_description: Create, delete, retrieve, and update znodes using ZooKeeper
description:
- Create, delete, retrieve, and update znodes using ZooKeeper.
options:
hosts:
description:
- A list of ZooKeeper servers (format '[server]:[port]').
required: true
name:
description:
- The path of the znode.
required: true
value:
description:
- The value assigned to the znode.
op:
description:
- An operation to perform. Mutually exclusive with state.
state:
description:
- The state to enforce. Mutually exclusive with op.
timeout:
description:
- The amount of time to wait for a node to appear.
default: 300
recursive:
description:
- Recursively delete node and all its children.
type: bool
default: 'no'
version_added: "2.1"
requirements:
- kazoo >= 2.1
- python >= 2.6
author: "Trey Perry (@treyperry)"
s;
# Creating or updating a znode with a given value
- znode:
hosts: 'localhost:2181'
name: /mypath
value: myvalue
state: present
# Getting the value and stat structure for a znode
- znode:
hosts: 'localhost:2181'
name: /mypath
op: get
# Listing a particular znode's children
- znode:
hosts: 'localhost:2181'
name: /zookeeper
op: list
# Waiting 20 seconds for a znode to appear at path /mypath
- znode:
hosts: 'localhost:2181'
name: /mypath
op: wait
timeout: 20
# Deleting a znode at path /mypath
- znode:
hosts: 'localhost:2181'
name: /mypath
state: absent
# Creating or updating a znode with a given value on a remote Zookeeper
- znode:
hosts: 'my-zookeeper-node:2181'
name: /mypath
value: myvalue
state: present
delegate_to: 127.0.0.1
N( t KazooClient( t KazooTimeoutError( t
AnsibleModulet missing_required_lib( t to_bytesc C` s( t d t d t d t d d ƒ d t d t d d ƒ d t d t d d d d ƒ d t d t d d d
d d d
g ƒ d t d
d d g ƒ d t d t d d d d ƒ d t d t d t d d ƒ ƒ d t ƒ } t sñ | j d t d ƒ d t ƒ n t | j
ƒ } | d s!| j d | d ƒ n t | ƒ } y | j ƒ Wn! t
k
r^| j d d ƒ n Xi i | j d 6| j d
6| j d 6d 6i | j d 6| j d 6d 6} d | j
k rÍ| j
d d k rÍd n d } | j
| } | | | ƒ \ } } | j ƒ | r| j | n
| j | d S( Nt
argument_spect hostst requiredt typet strt namet valuet defaultt opt choicest gett waitt listt statet presentt absentt timeouti, t intt recursivet boolt supports_check_modet msgs kazoo >= 2.1t exceptiont successs3 The connection to the ZooKeeper ensemble timed out.( R
t dictt Truet Falset Nonet KAZOO_INSTALLEDt fail_jsonR t
KAZOO_IMP_ERRt check_paramst paramst KazooCommandProxyt startR R R R R R t shutdownt exit_json( t modulet checkt zoot command_dictt command_typet methodt resultt result_dict( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyt mainq sF $
.
c C` sY | d r( | d r( i t d 6d d 6S| d rN | d rN i t d 6d d 6Si t d 6S( NR R R$ s+ Please define an operation (op) or a state.R" s9 Please choose an operation (op) or a state, but not both.( R' R& ( R- ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR, £ s
R. c B` s€ e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z
d d
„ Z RS( c C` s# | | _ t | j d ƒ | _ d S( NR ( R2 R R- t zk( t selfR2 ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyt __init__® s c C` s | j | j j d ƒ S( NR ( t _absentR2 R- ( R< ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR ² s c C` s | j j | ƒ S( N( R; t exists( R< t znode( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR? µ s c C` sR | j j | j j d ƒ } t i t | ƒ d 6| d 6d d 6| j j d d 6f S( NR t countt itemss Retrieved znodes in path.R" R@ ( R; t get_childrenR2 R- R& t len( R< t children( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR ¸ s !c C` s$ | j | j j d | j j d ƒ S( NR R ( t _presentR2 R- ( R< ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR ½ s c C` s | j | j j d ƒ S( NR ( t _getR2 R- ( R< ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR À s c C` s | j j ƒ | j j ƒ d S( N( R; t stopt close( R< ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR0 Ã s
c C` s | j j ƒ d S( N( R; R/ ( R< ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR/ Ç s c C` s$ | j | j j d | j j d ƒ S( NR R ( t _waitR2 R- ( R< ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR Ê s c C` sc | j | ƒ rG | j j | d | j j d ƒt i t d 6d d 6f St i t d 6d d 6f Sd S( NR t changeds The znode was deleted.R" s The znode does not exist.( R? R; t deleteR2 R- R& R' ( R< R@ ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR> Í s c C` sÉ | j | ƒ r² | j j | ƒ \ } } i } xW t | ƒ D]I } | j d ƒ s: t | | ƒ } t | t t f ƒ rƒ | | | RG RF RJ ( ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyR. s
t __main__( ( t
__future__R R R R t
__metaclass__t ANSIBLE_METADATAt
DOCUMENTATIONt EXAMPLESR\ t tracebackR( R+ t kazoo.clientR t kazoo.handlers.threadingR R& R) t ImportErrort
format_excR' t ansible.module_utils.basicR
R t ansible.module_utils._textR R: R, R. R` ( ( ( sD /usr/lib/python2.7/site-packages/ansible/modules/clustering/znode.pyt s.
**
2
R