o Rh@sdddlmZddlmZmZddlmZddlmZddl Z ddl Z e j e j dGdd d Z dS) ) ApiException)clientconfig) ApiClient)LeaderElectionRecordN)levelc@s<eZdZddZddZddZddZd d Zd d Zd S) ConfigMapLockcCs@t|_d|_||_||_t||_d|_ddddd|_ dS)z :param name: name of the lock :param namespace: namespace :param identity: A unique identifier that the candidate is using z(control-plane.alpha.kubernetes.io/leaderN)holderIdentityleaseDurationSeconds acquireTime renewTime) r CoreV1Api api_instance#leader_electionrecord_annotationkeyname namespacestridentityconfigmap_reference lock_record)selfrrrrv/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/kubernetes/leaderelection/resourcelock/configmaplock.py__init__s   zConfigMapLock.__init__c CszF|j||}|jj}|dus|dkr!|jdi|j_||_WdS||js4|jdi|j_||_WdS|t ||j}||_d|fWSt y\}z d|fWYd}~Sd}~ww)z :param name: Name of the configmap object information to get :param namespace: Namespace in which the configmap object is to be searched :return: 'True, election record' if object found else 'False, exception response' N)TNTF) rread_namespaced_config_mapmetadata annotationsrrgetget_lock_objectjsonloadsr)rrr api_responserrerrrr-s$  zConfigMapLock.getc Csttj||jt||idd}z |jj||dd}WdSty9}zt d |WYd}~dSd}~ww)a :param electionRecord: Annotation string :param name: Name of the configmap object to be created :param namespace: Namespace in which the configmap object is to be created :return: 'True' if object is created else 'False' if failed )rr)rT)prettyzFailed to create lock as {}NF) r V1ConfigMaprr!dumps get_lock_dictrcreate_namespaced_config_maprlogginginfoformat)rrrelection_recordbodyr#r$rrrcreateJszConfigMapLock.createc Csnzt|||jjj|j<|jj|||jd}WdSt y6}zt d |WYd}~dSd}~ww)z :param name: name of the lock to be updated :param namespace: namespace the lock is in :param updated_record: the updated election record :return: True if update is successful False if it fails )rrr.TzFailed to update lock as {}NF) r!r'r(rrrrrreplace_namespaced_config_maprr*r+r,)rrrupdated_recordr#r$rrrupdate\s zConfigMapLock.updatecCsbtdddd}|dr|d|_|dr|d|_|dr%|d|_|dr/|d|_|SNr r r r )rrholder_identitylease_duration acquire_time renew_time)rrleader_election_recordrrrr ms        zConfigMapLock.get_lock_objectcCs6|j|jd<|j|jd<|j|jd<|j|jd<|jSr3)r4rr5r6r7)rr8rrrr({s    zConfigMapLock.get_lock_dictN) __name__ __module__ __qualname__rrr/r2r r(rrrrr s r )kubernetes.client.restr kubernetesrrkubernetes.client.api_clientrleaderelectionrecordrr!r* basicConfigINFOr rrrrs