Файловый менеджер - Редактировать - /usr/lib/rads/venv/lib/python3.13/site-packages/bakauth/__pycache__/__init__.cpython-313.pyc
Ðазад
� � �iʝ � � � S r SSKrSSKJrJr SSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK JrJr SSKJrJrJrJrJrJrJr SSKJrJrJrJ r J r SSK J r J r J!r!J"r"J#r#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r, S r-S r.S r/S r0S r11 Skr2 " S S5 r3g)a� Code for accessing the backup authority server api .. data:: bakauth.AUTH_JSON: "/opt/backups/etc/auth.json" *(str)* .. data:: bakauth.BAKAUTH1: "ash-sys-pro-bakauth1.imhadmin.net" *(str)* .. data:: bakauth.BAKAUTH2: "ash-sys-dev-bakauth2.imhadmin.net" *(str)* .. data:: bakauth.BAKAUTH3: "lax-sys-pro-bakauth3.imhadmin.net" *(str)* .. data:: bakauth.SHARED_CLASSES: {'imh_reseller', 'imh_shared', 'hub_shared', 'imh_ngx'} *(set)* � N)�Union�Any)�Restic� ResticRepo� )�SharedFailoverLocks�AgentClientLookup�AgentCpuserLookup�VznodeBackupLookup�VznodeRestoreLookup� UserBuckets� RegDetails)�Status�MdsState�post�DEFAULT_TIMEOUT�DEFAULT_RETRIES)� BakAuthError� BakAuthDown�ClusterUnavailable� AMPDownError�WrongServerClass�BakAuthLoginFailed�BakAuthWrongLogin� VpsRestricted� LookupMissing�WrongSharedServer� NoAmpAccount�DedicatedMoved� InternalQuota� Unregisteredz1.5.5z!ash-sys-pro-bakauth1.imhadmin.netz!ash-sys-dev-bakauth2.imhadmin.netz!lax-sys-pro-bakauth3.imhadmin.netz/opt/backups/etc/auth.json> �imh_ngx� hub_shared� imh_shared� imh_resellerc �F � \ rS rSrSrS rSS.S\S\S\S \S \ \ \ 4 4 S jjr SSS .S\S\S\S \S \S \ \ \ \4 4 S jjr SS.S\S\S\S \S \ \ \ 4 4 S jjrSS\\\S.S\S\S\S\S\S\S S4S jjr\SS.S\S \S \S \\\4 4S jj5 rS\\S .S \\\4 S!\\S4 S\S\S \4 S" jjrS\\S .S#\\S4 S!\\S4 S\S\S \4 S$ jjr\\4S%\S\S\S \4S& jjr \\S'.S(\S)\ S*\S+\S,\\\4 S\S\S S4S- jjr \\S'.S(\S.\S/\S0\ \ S1\S\S\S S4S2 jjr \\S'.S3\S4\S%\S5\S\S\S S4S6 jjr!\\S'.S7\\\\\4 4 S8\ \ S9\ \ S\S\S S4 S: jjr"SS\\S;.S<\S=\S8\S9\S\S\S S4S> jjr#\\4S%\S?\S\S\S \$4 S@ jjr%\\4S \S?\S\S\S \&4 SA jjr'\\4SB\S?\S\S\S \&4 SC jjr(SS\\SD.SE\ \ S\SF\SG\\S4 S\S\S \)4SH jjr*\\S'.S%\S\S\S \ \\+4 4SI jjr,\\S'.S%\S\S\S \ \\+\4 4SJ jjr-\\S'.S\S\S \4SK jjr.S\\SL.S \4SM jjr/S\\SL.S \ \\4 4SN jjr0SS\\SO.S!\\S4 SP\S\S\S \14 SQ jjr2\\S4S\S\S \S S4SR jjr3\\SSS.S%\SB\S\S\ST\\S4 S S4 SU jjr4 SZSSV.S%\ST\S \54SW jjjr6 S[SE\\ \ S4 ST\S \\\54 4SX jjr7SYr8g)\�BakAuth�O z!Handles backup authority requestsc � � [ [ SS9 n[ R " U5 nS S S 5 [ R " [ WS US 4S9U l g ! , ( d f N5= f! [ a n[ [ U5 5 UeS nAff = f)Nzutf-8)�encoding�apiuser�authkey)�auth) �open� AUTH_JSON�json�load�FileNotFoundErrorr! �str� functools�partialr �_post)�self�handle�data�excs �C/usr/lib/rads/venv/lib/python3.13/site-packages/bakauth/__init__.py�__init__�BakAuth.__init__R su � � 2��i�'�2�f��y�y��(�� 3� �&�&� ��Y���i� �9� �� � 3�2�� � 2� �s�3�x�(�c� 1�� 2�s3 �A' �A�A' � A$� A' �$A' �' B �1B�B T)� log_retries�uri�timeout�retriesr> �returnc �2 � U R [ UUUUUS9$ )ax Perform a post request that only the primary bakauth server can handle Args: uri (str): HTTP request URI timeout (int): HTTP request timeout in seconds retries (int): HTTP request auto-retries after timeout log_retries (bool): whether to log on auto-retries. Defaults False **data: POST form data Returns: tuple[Status, Any]: (``Status`` enum, data) �� bakauth_hostr? r@ rA r> r9 )r6 �BAKAUTH1)r7 r? r@ rA r> r9 s r; � _post_main�BakAuth._post_main\ s, � �, �z�z�!����#�� � � � )r> � pref_mainrJ c �F � UUUUUS.nU( a [ [ /nO [ [ /nU R " SSUS 0UD6u p�U [ R L aG U( a [ R " SUS UUS 5 U R " SSUS 0UD6n / U QUS P7$ X�US 4$ )a1 Perform a post request that the primary bakauth server should handle, but will failover to a replicant bakauth server if needed Args: uri (str): HTTP request URI timeout (int): HTTP request timeout in seconds retries (int): HTTP request auto-retries after timeout log_retries (bool): whether to log on auto-retries. Defaults False pref_main (bool): If true, try bakauth1 first. If false, try bakauth3 first. Defaults True. **data: POST form data Returns: tuple[Status, Any, str]: (``Status`` enum, data, bakauth host used) �r? r@ rA r> r9 rE r z-%s::%s: request exception - retrying using %sr � )rF �BAKAUTH3r6 r �REQUEST_EXCEPTION�logging�warning) r7 r? r@ rA r> rJ r9 �kwargs� bakauth_hosts�status�rets r; � _post_pref�BakAuth._post_pref{ s� � �4 � � �&�� �� � %�x� 0�M� %�x� 0�M��z�z�J�}�Q�/?�J�6�J� �� �V�-�-� -�����C�!�!�$��!�!�$� � �*�*�E�-��*:�E�f�E�C�)�C�)� �q�)�)� )��]�1� -�-�-rI c �. � [ [ /n[ R " U5 UUUUUS.nU R " SSUS 0UD6u p�U[ R L a= U( a [ R " SUS UUS 5 U R " SSUS 0UD6$ X�4$ )a� Perform a post request that any production bakauth server can handle (round robin) Args: uri (str): HTTP request URI timeout (int): HTTP request timeout in seconds retries (int): HTTP request auto-retries after timeout log_retries (bool): whether to log on auto-retries. Defaults False **data: POST form data Returns: tuple[Status, Any]: (``Status`` enum, data) rL rE r z,%s:%s: request exception - retrying using %sr rM ) rF rN �random�shuffler6 r rO rP rQ ) r7 r? r@ rA r> r9 �priorR rT s r; � _post_either�BakAuth._post_either� s� � �, �(�#�����t� �� � �&�� �� �z�z�A�t�A�w�A�&�A� �� �V�-�-� -�����B���G����G� � �:�:�=�4��7�=�f�=� =��|�rI �� � )� wait_mins� poll_secsrE r@ rA �task_idr` ra rE Nc �b � SnUS- n[ R " 5 n US; a� [ R " 5 U - U: ap [ R " U5 U R USUUSSU0S9u p�U [ R La [ X�S9eUS; a [ R " 5 U - U: a Mn g g g g ) a� Wait for a celery task to finish on the Backup Authority server Args: task_id (str): task identifier string wait_mins (int, optional): max minutes to wait. Defaults to 240. poll_secs (int, optional): secondss between checking the state of the task. Defaults to 3. timeout (int, optional): request timeout in secs (per poll request, not in total) retries (int): number of times to retry the request on timeout Raises: BakAuthError: error checking the state of the task �QUEUED�< )rd �STARTEDz/lookup/check_taskTrb rD �rT r9 N)�time�sleepr6 r �OKAYr ) r7 rb r` ra rE r@ rA � state_msg�wait�startrT s r; � task_wait�BakAuth.task_wait� s� � �0 � ��2�~��� � � ���0�0�T�Y�Y�[�5�5H�4�5O� �J�J�y� !� $� � � )�(� � � � ��)� !+� !� �F� �V�[�[�(�"�&�A�A� �0�0�T�Y�Y�[�5�5H�4�5O�0�5O�0rI F)� require_amp� svr_class�hostrp c � � [ [ S[ [ SUU U( a SOSS.S9u p4U[ R La [ X4S9eU$ )a Register a (non-internal) server in backup authority Args: svr_class (str): server classification, one in: imh_vps, imh_reseller, imh_shared, hub_shared, imh_ngx, or imh_ded host (str): short hostname which should match what AMP knows require_amp (bool): if True, instruct bakauth to reject registration if the supplied host does not match a known AMP account Raises: BakAuthError: any error registering the server Returns: dict[str, str]: contains keys "authkey" and "apiuser" z /registerT�1�0)rr rq rp rD rg )r rF r r r rj r )rq rr rp rT r9 s r; �register�BakAuth.register� sO � �. �!��#�#� � � &�&1�s�s�� � �� ���� $� �f�8� 8�� rI )�netr@ rA �veidsrx c �: � U R S[ R " U5 UUUS9u pVU[ R La [ XVS9eUS H n U R XsUS9 M US [ S 0 US D6US R 5 V V s0 s H u p�[ U 5 [ S 0 U D6_M sn n US R 5 V V s0 s H u p�[ U 5 U _M sn n S .$ ! [ a" n[ R " SU5 SnAM� SnAff = fs sn n f s sn n f )a� Requests information form bakauth needed to backup a vz node Args: veids (dict[int, str]): If performing a vps backup run, provide the IDs of all vps found on this compute node, mapped to their FQDNs. If only backing up mds, send an empty dict net (str | None): set "lan" or "wan" to override which ceph network to use timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: error looking up data Returns: VznodeBackupLookup: restic info needed to backup a vznode. Contains keys "endpoints", "node_keys", and "vps_keys" z/vzclient/backup)r? ry rx r@ rA rg �task_ids�r@ rA z%sN� endpoints� node_keys�vps_keys�changed)r} r~ r r� rM ) rG r0 �dumpsr rj r rn rP rQ r �items�int) r7 ry rx r@ rA rT r9 rb r: �k�vs r; �vzclient_backup�BakAuth.vzclient_backup& s# � �4 ���"��*�*�U�#���� '� � �� ���� $� �f�8� 8��J�'�G� +����w���I� (� �k�*�#�8�d�;�&7�8�48��4D�4J�4J�4L��4L�D�A��A�� ��Q��'�4L�� /3�9�o�.C�.C�.E�F�.E�d�a��A��� �.E�F� � �� � +�����c�*�*�� +�� �� Gs$ �C"� !D �D �" D�,D � D�veidc � � Uc SS0nOSU0nU R " SSUUUS.UD6u pgU[ R La [ XgS9e[ S0 US D6US' U$ ) aP Requests information from bakauth needed to restore data for a vps from a vznode Args: veid (int | None): ID for the vps you're trying to restore. Explicitly set to None to fetch info for the node itself. net (str | None): set "lan" or "wan" to override which ceph network to use timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthDown: if bakauth could not be reached BakAuthLoginFailed: API user/password is wrong LookupMissing: if a requested vps's keys do not exist VpsRestricted: if a requested vps is internal BakAuthError: catch-all for any other api error Returns: VznodeRestoreLookup: restic info needed to restore a vps from a vznode. The dict has keys "this_endpoint", "key_info", and "all_endpoints" �nodert r� z/vzclient/restore)r? rx r@ rA rg �key_inforM )r\ r rj r r )r7 r� rx r@ rA rR rT r9 s r; �vzclient_restore�BakAuth.vzclient_restoreW s} � �> �<� �c�]�F� �d�^�F��(�(� �#���� � � � �� ���� $� �f�8� 8�%�9��Z�(8�9��Z��� rI �userc �j � U R SUUSUS9u pEnU[ R La [ XES9eU$ )z2Check which failover backups should not be rotatedz/failover/get_shared_locksF)r? r@ rA rJ r� rg )rV r rj r )r7 r� r@ rA rT r9 �_s r; �get_shared_failover_locks�!BakAuth.get_shared_failover_locks� sH � � �/�/�,����� *� ���a� ���� $� �f�8� 8�� rI r| �version� mds_state�vps_crit�vps_warn� vps_sizesc �0 � [ R nU R SUUR UU[ R " U5 [ R " [ R " 5 5 US SUS 3UUS9 u p�U [ R La [ X�S9eg)a� Post backup monitoring status for a vznode Args: version (str): RPM version mds_state (MdsState): MDS status enum vps_crit (int): number of vps old enough to be a nrpe critical vps_warn (int): number of vps behind schedule but not critical vps_sizes (dict[int, int]): veids mapped to VPS sizes in MiB timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: error updating monitoring status z/monitoring/vz_updater �.r ) r? r� r� r� r� r� �os_info�py_infor@ rA rg N) �sys� version_inforG �valuer0 r� �distro�infor rj r ) r7 r� r� r� r� r� r@ rA � py_versionrT r9 s r; �monitoring_vz_update� BakAuth.monitoring_vz_update� s� � �2 �%�%� ����'�� �o�o� � ��j�j��+��J�J�v�{�{�}�-�!�!�}�o�Q�z�!�}�o�6��� '� � �� ���� $� �f�8� 8� %rI �running� ded_moved�errors�num_oldc �@ � [ R nU R SUUUU( a SOSU( a SOS[ R " U5 U[ R " [ R " 5 5 US SUS 3S9 u p�U [ R La [ X�S9eg)a Updates bakauth with client server status Args: version (str): backup client RPM version running (bool): whether the backup runner daemon is running ded_moved (bool): True if this is a dedi and its bucket was moved to a new server errors (list[str]): error messages to display in monitoring dash num_old (int): number of old tasks in queue timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: error updating monitoring status z/monitoring/updater r r� ) r? r@ rA r� r� r� r� r� r� r� rg N) r� r� rG r0 r� r� r� r rj r ) r7 r� r� r� r� r� r@ rA r� rT r9 s r; �monitoring_update�BakAuth.monitoring_update� s� � �4 �%�%� ����$���� �A�a�$�a�!��:�:�f�%���J�J�v�{�{�}�-�!�!�}�o�Q�z�!�}�o�6� '� � �� ���� $� �f�8� 8� %rI �task�plugin�ipaddrc �j � U R SUUUUUUS9u pxU[ R La [ XxS9eg)a~ Add an account note when a ticket is generated Args: task (str): backup/restore task name plugin (str): plugin task name (e.g. "cPanel Backup Manager") user (str): username ipaddr (str): IP address of user timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: error posting note z/note/auto_ticket)r? r@ rA r� r� r� r� rg N�rG r rj r ) r7 r� r� r� r� r@ rA rT r9 s r; �note_auto_ticket�BakAuth.note_auto_ticket� sL � �. ���#������� '� � �� ���� $� �f�8� 8� %rI � user_sizes�notify�resetc �� � U R SUU[ R " U5 [ R " U5 [ R " U5 S9u pgU[ R La [ XgS9eg)a� Post a user's account size for AMP to access Args: user_sizes (dict[str, dict[str, int]]): user account sizes (in MiB). each dict should have keys "total_mb" and "usage_mb" notify (list[str]): users over quota reset (list[str]): users under quota (to reset their notify times) timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error updating usage z/usage/set/shared)r? r@ rA �usersr� r� rg N)rG r0 r� r rj r )r7 r� r� r� r@ rA rT r9 s r; �post_user_sizes�BakAuth.post_user_sizes sd � �, ���#����*�*�Z�(��:�:�f�%��*�*�U�#� '� � �� ���� $� �f�8� 8� %rI )r� r� r@ rA �usage�totalc � � U R SUUUUU( a SOSU( a SOSS9u pxU[ R La [ XxS9eg)a� Post a v/ded server's size for AMP to access Args: usage (int): disk usage of selected backups (in MiB) total (int): disk usage of all account data (in MiB) notify (bool, optional): notify as over quota. Defaults to False. reset (bool, optional): reset notify counter. Defaults to False. timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error updating usage z/usage/set/vdedrt ru )r? r@ rA r� r� r� r� rg Nr� ) r7 r� r� r� r� r@ rA rT r9 s r; �post_vded_size�BakAuth.post_vded_size/ sT � �. ���!����� �3�c� �#�C� '� � �� ���� $� �f�8� 8� %rI �keyc � � U R SUUUUS9u pVU[ R La [ XVS9eUR S5 nU[ S0 UD6S.$ )a� Used by support tooling to request a shared user's bucket details from a server other than where the bucket belongs Args: user (str): username key (str): agent key from cpjump timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting bucket details Returns: AgentCpuserLookup: restic auth info and wans available z/agent/get_bucket/cpuser)r? r@ rA �cpuserr� rg �wans)r� �reporM �rG r rj r �popr )r7 r� r� r@ rA rT r9 r� s r; �agent_get_user_bucket� BakAuth.agent_get_user_bucketR sb � �, ���*����� '� � �� ���� $� �f�8� 8��x�x�� �� �j�&8�4�&8�9�9rI c �� � U R SUUUUS9u pVU[ R La [ XVS9eUR S5 nUR S5 nUU[ S0 UD6S.$ )a� Used by support tooling to request v/ded bucket details for a server with an active registration, from a server other than where the bucket belongs Args: host (str): short hostname key (str): agent key from cpjump timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting bucket details Returns: AgentClientLookup: restic auth info and wans available �/agent/get_bucket/client)r? r@ rA rr r� rg r� rq �r� rq r� rM r� ) r7 rr r� r@ rA rT r9 r� rq s r; �agent_get_server_bucket� BakAuth.agent_get_server_buckett sx � �. ���*����� '� � �� ���� $� �f�8� 8��x�x�� ���H�H�[�)� ��"� �&��&� � rI �bucketc �� � U R SUUUUS9u pVU[ R La [ XVS9eUR S5 nUR S5 nUU[ S0 UD6S.$ )a� Used by support tooling (baksync) to request v/ded bucket details for a bucket which is marked for deletion Args: bucket (str): full bucket name from cpjump key (str): agent key from cpjump timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting bucket details Returns: AgentClientLookup: restic auth info and wans available r� )r? r@ rA �stashed_bucketr� rg r� rq r� rM r� ) r7 r� r� r@ rA rT r9 r� rq s r; �agent_get_stashed_bucket� BakAuth.agent_get_stashed_bucket� sx � �, ���*���!�� '� � �� ���� $� �f�8� 8��x�x�� ���H�H�[�)� ��"� �&��&� � rI )�nocache�suspendsr@ rA r� r� r� c � � [ U[ 5 ( d [ e[ R " U5 U( a SOSS.nUb [ R " U5 US' U R " SSUUS.UD6u p�n U[ R La [ X�S9eU( a U S H n U R X�S 9 M U S R 5 V Vs0 s H u p�X�R S 5 _M nn nU S UU S R 5 V Vs0 s H u p�U [ S0 UD6_M snn U S S.$ ! [ a" n [ R " S U 5 Sn A M� Sn A ff = fs snn f s snn f )a� Get quota and bucket details for multiple shared users Args: users (list[str]): users to get bucket data for wait_mins (int): max number of minutes to wait for bucket creation (per cluster) nocache (bool): Instruct bakauth to skip cache when looking up quota information. Defaults to False. suspends (dict | None): only used by the scheduler cron. This is a dict of suspended users and when/why. timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting bucket details Returns: UserBuckets: dict where "quotas_gb" contains a dict of usernames to quotas in GiB. "repos" contains a dict of usernames to ResticRepo objects. "missing" is specific to the replicant, ``BAKAUTH3``. If ``BAKAUTH1`` did not reply, we use ``BAKAUTH3``, which is unable to setup new users. "copy_users" are users which get cross-coast backups r r )r� r� Nr� z/buckets/users�r? r@ rA rg r{ )r` z*error when waiting for ceph user setup: %sr� �quota� copy_users�missing)r� � quotas_gb�reposr� rM )� isinstance�list� TypeErrorr0 r� rV r rj r rn rP rQ r� r� r )r7 r� r` r� r� r@ rA rR rT r9 r� rb r: r� r� �quotass r; �get_user_buckets�BakAuth.get_user_buckets� s^ � �D �%��&�&��O� �:�:�e�,�g��1�M�� � �!%���H�!5�F�:� � �/�/� � ��� � � ���a� ���� $� �f�8� 8� � � �+����N�N�7�N�@� ,� 15�W� �0C�0C�0E�F�0E���!�U�U�7�^�#�0E��F� �|�,� �59�'�]�5H�5H�5J�K�5J�T�Q�a�� �a� �(�5J�K��I�� � �� $� ��O�O�D�c�� ���� G�� Ls$ � D%� E�E �% E�/E � Ec �& � [ U[ 5 ( d [ SU< S35 eU R U/SSX#S9nXS ; a [ [ R U S3S9eXS ; a [ [ R S [ 3S9eUS U US U 4$ ) a� Like get_user_buckets but for only one user and wait_mins=0. Args: user (str): username timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: WrongSharedServer: The requested user does not belong here BakAuthDown: Backup Authority server was unreachable BakAuthError: any other error Returns: tuple[int, ResticRepo]: quota in GiB and ResticRepo object �get_user_bucket(user=�)Tr �r� r` r@ rA r� � is not assigned to this serverrg r� �Could not connect to r� � r� r3 r� r� r r �ERRORr rO rF )r7 r� r@ rA �lookups r; �get_user_bucket�BakAuth.get_user_bucket s� � �, �$��$�$�� 4�t�g�Q� 7�8� 8��&�&� �F�D�A�w� '� �� �g�� &�#� �|�|� �v� <�=�� � �)�$� $� � �/�/�,�X�J�7�� � �k�"�4�(�&��/�$�*?�?�?rI c �6 � [ U[ 5 ( d [ SU< S35 eU R U/SSX#S9nXS ; a [ [ R U S3S9eXS ; a [ [ R S [ 3S9eXS ; nUS U US U U4$ ) a� Like get_user_buckets but for only one user and wait_mins=0. Args: user (str): username timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: WrongSharedServer: The requested user does not belong here BakAuthDown: Backup Authority server was unreachable BakAuthError: any other error Returns: tuple[int, ResticRepo, bool]: quota in GiB, ResticRepo object, and whether this user gets cross-coast backups. r� r� Tr r� r� r� rg r� r� r� r� r� )r7 r� r@ rA r� �geos r; �get_user_bucket_v2�BakAuth.get_user_bucket_v2- s� � �. �$��$�$�� 4�t�g�Q� 7�8� 8��&�&� �F�D�A�w� '� �� �g�� &�#� �|�|� �v� <�=�� � �)�$� $� � �/�/�,�X�J�7�� � �\�*�*���k�"�4�(�&��/�$�*?��D�DrI c �j � U R SUUS9u p4U[ R La [ X4S9eUS $ )a& Get the shared failover account size limit in GiB Args: timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting the size limit Returns: int: shared failover account size limit in GiB z/buckets/failover_limitr� rg � failover_gib�r\ r rj r )r7 r@ rA rT r9 s r; �get_failover_limit�BakAuth.get_failover_limitZ sH � �$ �(�(�)��� )� � �� ���� $� �f�8� 8��N�#�#rI )r� r@ rA c �z � U R SUUS[ U5 S9u pEU[ R La [ XES9eU$ )a� Get this v/ded server's quota as an int in GiB Args: nocache (bool): Instruct bakauth to skip cache when looking up quota information. Defaults to False. timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting the server's quota Returns: int: this v/ded server's quota as an int in GiB �/buckets/vded_quotar �r? r@ rA �verr� rg �r\ r� r rj r �r7 r� r@ rA rT r9 s r; �get_vded_quota�BakAuth.get_vded_quotau sL � �* �(�(�%������L� )� � �� ���� $� �f�8� 8�� rI c � � U R SUUS[ U5 S9u pEU[ R La [ XES9eUS US 4$ )a� Get this v/ded server's quota as an int in GiB Args: nocache (bool): Instruct bakauth to skip cache when looking up quota information. Defaults to False. timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting the server's quota Returns: int: this v/ded server's quota as an int in GiB bool: whether this server gets cross-coast backups r� � r� rg r� �copyr� r� s r; �get_vded_quota_v2�BakAuth.get_vded_quota_v2� sZ � �, �(�(�%������L� )� � �� ���� $� �f�8� 8��G�}�d�6�l�*�*rI )rx �startupr@ rA r c � � 0 nU( a XS' U( a SUS' U R " SSUUS.UD6u peU[ R La [ XeS9eUS [ ; aM US [ R " 5 R S 5 S :w a [ [ R S US < 3S9eUS US US US US US US [ US US US US S9S.$ )a� Fetch registration details needed for backup-runner to start Args: startup (bool): If True, bakauth performs extra checks on buckets. This should only be set to True on initial backup-runner startup. Defaults false. net(str, optional): "wan" or "lan" to request that ceph endpoint timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthLoginFailed: auth.json is invalid BakAuthWrongLogin: this server has the wrong server's auth.json BakAuthError: any other error getting the server's registration info Returns: RegDetails: contains "svr_class", "client_host", "endpoint", and "repo" rx rt r z/buckets/reg_detailsr� rg rq � client_hostr� r z4Shared server registration incorrect! Registered as �name�endpoint�locationr� r� r� � restic_pass� access_key� secret_key)r� r r r )r rq r r r r� r� r� rM ) r\ r rj r �SHARED_CLASSES�platformr� �splitr r� r )r7 rx r r@ rA r9 rT s r; �get_reg_details�BakAuth.get_reg_details� s# � �6 �� � ��K� � !�D��O��(�(� �&��� � � � �� ���� $� �f�8� 8� � � �� .��M�"�h�m�m�o�&;�&;�C�&@��&C�C�'�!�<�<�%�%)�-�%8�$;�=�� � ��L� �k�*� � �.� �Z�(� �Z�(���L���L� ��H�~� � � /� � �-� � �-� � � rI c �d � U R SUUUS9u pEU[ R La [ XES9eg)aA Check if backup authority is reachable and raise an exception if not Args: timeout (int): request timeout in seconds retries (int): number of times to retry each server on timeout log_retries (bool): whether to log on auto-retries. Defaults False Raises: BakAuthError: backup authority is not reachable z/monitoring/ping)r? r@ rA r> rg Nr� )r7 r@ rA r> rT r9 s r; �ping� BakAuth.ping� sE � � �(�(�"���#� )� � �� ���� $� �f�8� 8� %rI )r@ rA r� r� c � � Uc 0 nO S[ U5 0nU R " S SUUSUUS.UD6u pxn U[ R La [ XxS9eU R USSU S 9 g) a� Tell ceph to repair a bucket's index Args: user (str): username that owns the bucket (root if v/ded) bucket (str): full bucket name timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout geo (bool | None): if True, check opposite coast; if False, check same-coast. If None (default), check both if present. Raises: BakAuthError: error either requesting the repair, or checking on it Nr� z/buckets/queue_repairF)r? r@ rA rJ r� r� rg � � )r` ra rE rM )r� rV r rj r rn ) r7 r� r� r@ rA r� rR rT r9 � auth_hosts r; �check_bucket_index�BakAuth.check_bucket_index s � �, �;��F��S��X�&�F�"&�/�/� # �'������ # � �# � ��i� ���� $� �f�8� 8� ���t�r�R�i��PrI )r� c � � U R 5 nU( aN [ US S US S US S 45 ( d [ [ R SS9eUS S nUS S nO US nUS nUS [ ; nU( d US:w a [ S U< S US 35 eUS:X a [ S XVUS S .UD6$ U R U5 u p�[ S XVU S .UD6$ )a� Get a Restic instance for a specific user on a backups 3.x client, assuming the current server is setup with it Args: user (str): If on a shared server, this is the username to get the Restic instance for. For reseller children, supply their reseller's name. If on vps/dedicated, always lookup "root" geo (bool): If True, use the secondary, geographically separated cluster. **kwargs: other keyword arguments to send as-is to the Restic() constructor Raises: ValueError: Incorrect user argument supplied WrongSharedServer: The requested user does not belong here BakAuthDown: Backup Authority server was unreachable BakAuthError: Any other API error Returns: Restic: restic instance r� r r r � This cluster is not availablerg rq �rootzuser=z; should be root on r� �r �clusterr� rM ) r �allr r r� r � ValueErrorr r� ) r7 r� r� rR �regr r � is_sharedr� r� s r; � get_restic�BakAuth.get_restic: s � �0 �"�"�$�� ����K� �+���K��'���K� �+��� � )�!�<�<�.M�� � �6�{�:�.�H��&�k�&�)�G��:��H��&�k�G�� �$��6� ��T�V�^� ���w�&:�3�{�;K�:L� M�N� N� �6�>�� �!��V���HN�� � �&�&�t�,����N�x�t�N�v�N�NrI c � � Uc [ R " 5 nU R USS9S nU R 5 nU( aM [ US S US S US S 5 ( d [ [ R SS 9eUS S nUS S nO US nUS nS [ S XgUS S .UD60nUR 5 H u p�[ S XgU S .UD6X�' M U$ )a� If users are not supplied, get all restic instances for this shared server, including root. Otherwise, get that set of users Args: users (list[str] | None): List of users to obtain restic instances for. This function will not resolve child account names to resellers, so be sure to only request main cpanel users geo (bool): If True, use the secondary, geographically separated cluster. **kwargs: other keyword arguments to send as-is to the Restic() constructor Raises: BakAuthDown: Backup Authority server was unreachable WrongServerClass: The current server is not a shared server BakAuthError: Any other API error Returns: dict[str, Restic]: usernames mapped to Restic instances. If users was supplied, not all usernames requested may be in the result, if bakauth did not recognize some as belonging to this server r )r� r` r� r� r r r r rg r r� r rM ) �rads� main_cpusersr� r r r r r� r r� ) r7 r� r� rR r� r r r rU r� r� s r; � all_restics�BakAuth.all_resticsm s � �2 �=��%�%�'�E��%�%�E�Q�%�?��H���"�"�$�� ���F� �J�'��F� �F�#��F� �J�'�� � )�!�<�<�.M�� � �6�{�:�.�H��&�k�&�)�G��:��H��&�k�G� �F� �!��V���HN�� �� �+�+�-�J�D� � �!���AG��C�I� (� � rI )r6 )r )NF)9�__name__� __module__� __qualname__�__firstlineno__�__doc__r< r3 r� �bool�tupler r rG rV r\ rF r rn � staticmethod�dictrv r r r r� r r� r r� r r� r� r� r� r� r� r r� r r� r� r r� r r� r� r� r� r� r r r r r r! r& �__static_attributes__rM rI r; r' r' O s� � �+� � !� � � � � � � � � � �v�s�{� � �J !� �/.� �/.� � /.� � /.� � /.� �/.� �v�s�C� � �/.�n !� ) � �) � � ) � � ) � � ) � �v�s�{� �) �^ �� $�&�&�&B��&B� � &B� � &B� � &B� �&B� �&B� �&B�P � "� $��$� �$� � $� �c�3�h� � $� �$�T !%�&�&� / � �C��H�~�/ � �3��9� � / � � / � � / � �/ �j !%�&�&� -��C��I� �-� �3��9� � -� � -� � -� �-�d '�&� ��� �� � � � �4 '�&�'9� �'9� � '9� � '9� � '9� ��S��>�'9� �'9� �'9� �'9�b '�&�(9� �(9� � (9� � (9� �S� � (9� �(9� �(9� �(9� �(9�b '�&�!9� �!9� � !9� � !9� � !9� �!9� �!9� �!9�R '�&� 9���d�3��8�n�,�-� 9� �S� � 9� �C�y� 9� � 9� � 9� � 9�L ��&�&�!9��!9� �!9� � !9� � !9� �!9� �!9� �!9�N '�&� :�� :� � :� � :� � :� � :�L '�&� & ��& � �& � � & � � & � � & �X '�&� % ��% � �% � � % � � % � � % �X �&*�&�&�= ��C�y�= � � = � � = � ��d� �#� = � �= � �= � �= �F '�&� )@��)@� � )@� � )@� �s�J�� � )@�^ '�&� +E��+E� � +E� � +E� �s�J��$� %� +E�` '�&� $� �$� � $� � $�< � � � � � �F � � � +� �s�D�y� � +�H !%� �&�&� > � �3��9� �> � � > � � > � � > � �> �D '�&� !� 9��9� �9� � 9� � 9�< '�&�!%�)Q� �)Q� � )Q� � )Q� � )Q� �4��:� �)Q� �)Q�X !�1O�16�1O��1O�*.�1O� �1O�h AF�4��4��9�d�?�+�4�9=�4� �c�6�k� �4� 4rI r' )4r, r� �typingr r r4 rP rY r0 rh r r� r$ �resticr r �hintsr r r r r r r �sessr r r r r r: r r r r r r r r r r r r r r! � __version__rF �BAKAUTH2rN r/ r r' rM rI r; �<module>r8 s� ���8 � � � � � � � � � � %�� � � K� J�� � � �" � � /�� .�� .�� (� �H��R� RrI
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка