o wOi@sddlZddlmZddlmZeeZzddlmZWne y/Gdddej ZYnwe eGdd d e Z Gd d d eZGd d d eeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGd d!d!eZGd"d#d#eZGd$d%d%eZGd&d'd'eZGd(d)d)eZGd*d+d+eZ Gd,d-d-eZ!Gd.d/d/e Z"z dd0l#m$Z$e$%WdSe yYdSw)1N)Client)Lock) NullHandlerc@seZdZddZdS)rcCsdSN)selfrecordrrA/home/ubuntu/.local/lib/python3.10/site-packages/etcd/__init__.pyemitszNullHandler.emitN)__name__ __module__ __qualname__r rrrr r s rc @sneZdZdddddddddZdddZddZddd Zed d Zed d Z ddZ ddZ ddZ dS) EtcdResultNF)keyvalue expirationttl modifiedIndex createdIndexnewKeydircKs||_|jD]\}}||vrt||||qt|||qg|_|jr/d|vr/|d|_|rDtd|d|_|jjrF|jsHd|_dSdSdSdS)a Creates an EtcdResult object. Args: action (str): The action that resulted in key creation node (dict): The dictionary containing all node information. prevNode (dict): The dictionary containing previous node information. nodesN)nodeT)action _node_propsitemssetattr _childrenrr _prev_node)rrrprevNodekwdargsrdefaultrrr __init__s   zEtcdResult.__init__cCs0|}t|dd|_t|dd|_dS)Nz x-etcd-indexrz x-raft-index) getheadersintget etcd_index raft_index)rresponseheadersrrr parse_headers=szEtcdResult.parse_headersccsN|js |VdS|s|V|jD]}td|}|j|dD]}|VqqdS)z Get all the subtree resulting from a recursive=true call to etcd. Args: leaves_only (bool): if true, only value nodes are returned N leaves_only)rr get_subtree)rr-nrchildrrr r.Bs   zEtcdResult.get_subtreecCs |jddS)NTr,)r.rrrr leavesYs zEtcdResult.leavescCs|jS)z+ Deprecated, use EtcdResult.leaves instead )r2r1rrr children]szEtcdResult.childrencCs^t|t|ur dS|jD]}zt||}t||}||kr$WdSWqYdSdS)NFT)typerkeysgetattr)rotherkabrrr __eq__bs  zEtcdResult.__eq__cCs || Sr)r;)rr7rrr __ne__os zEtcdResult.__ne__cCsd|j|jfS)Nz%s(%r)) __class____dict__r1rrr __repr__rszEtcdResult.__repr__NNN)F) r r rrr#r+r.propertyr2r3r;r<r?rrrr rs(     rc"eZdZdZdfdd ZZS) EtcdExceptionz! Generic Etcd Exception. Ncstt||||_dSr)superrCr#payload)rmessagerEr=rr r#{s zEtcdException.__init__)NNr r r__doc__r# __classcell__rrrGr rCvsrCc@eZdZdZdS)EtcdValueErrorz3 Base class for Etcd value-related errors. Nr r rrIrrrr rLrLc@rK)EtcdCompareFailedz" Compare-and-swap failure NrMrrrr rOrNrOc@rK)EtcdClusterIdChangedz The etcd cluster ID changed. This may indicate the cluster was replaced with a backup. Raised to prevent waiting on an etcd_index that was only valid on the old cluster. NrMrrrr rPsrPc@rK) EtcdKeyErrorz) Etcd Generic KeyError Exception NrMrrrr rQrNrQc@rK)EtcdKeyNotFoundz, Etcd key not found exception (100) NrMrrrr rRrNrRc@rK) EtcdNotFilez) Etcd not a file exception (102) NrMrrrr rSrNrSc@rK) EtcdNotDirz. Etcd not a directory exception (104) NrMrrrr rTrNrTc@rK)EtcdAlreadyExistz, Etcd already exist exception (105) NrMrrrr rUrNrUc@rK)EtcdEventIndexClearedzB Etcd event index is outdated and cleared exception (401) NrMrrrr rVrNrVcrB)EtcdConnectionFailedz$ Connection to etcd failed. Ncstt|j||d||_dS)N)rFrE)rDrWr#cause)rrFrErXrGrr r#s  zEtcdConnectionFailed.__init__r@rHrrrGr rWsrWc@rK)EtcdInsufficientPermissionsz= Request failed because of insufficient permissions. NrMrrrr rYrNrYc@rK)EtcdWatchTimedOutz7 A watch timed out without returning a result. NrMrrrr rZrNrZc@rK)EtcdWatcherClearedz2 Watcher is cleared due to etcd recovery. NrMrrrr r[rNr[c@rK)EtcdLeaderElectionInProgressz< Request failed due to in-progress leader election. NrMrrrr r\rNr\c@rK)EtcdRootReadOnlyzA Operation is not valid on the root, which is read only. NrMrrrr r]rNr]c@rK)EtcdDirNotEmptyz Directory not empty. NrMrrrr r^rNr^c@rK)EtcdLockExpiredzI Our lock apparently expired while we were trying to acquire it. NrMrrrr r_rNr_c@seZdZidedededededede de d e d e d e d e d e de de de de e e e e edZeddZdS) EtcdErrordefhikln)i-icCsx|d}|d}|d}d||}|d}|dkr!d}n|dkr'd }|j|t}t|tr8|||||) z Decodes the error and throws the appropriate error message :param payload: The decoded JSON error payload as a dict. errorCoderFrXz{} : {}statusirartrh)r&formaterror_exceptionsrC issubclass)clsrE error_coderFrXmsgrvexcrrr handles       zEtcdError.handleN)r r rrRrOrSrTrUr]r^rYrLr\r[rVrx classmethodr~rrrr r`sX    r`) pyopenssl)&loggingclientrlockr getLoggerr _logr ImportErrorHandler addHandlerobjectr ExceptionrC ValueErrorrLrOrPrQrRrSrTrUrVrWrYrZr[r\r]r^r_r`urllib3.contribrinject_into_urllib3rrrr sH     c   =