
    [j3                         d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl	m
Z
 ddlZddlmZmZmZmZmZmZ ddlmZ  ej        e          Z G d dej                  Z G d	 d
e          ZdS )z
    Kubernetes

    No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)  # noqa: E501

    The version of the OpenAPI document: release-1.36
    Generated by: https://openapi-generator.tech
    )absolute_importN)	urlencode)ApiExceptionUnauthorizedExceptionForbiddenExceptionNotFoundExceptionServiceExceptionApiValueError)should_bypass_proxiesc                   "    e Zd Zd Zd ZddZdS )RESTResponsec                 \    || _         |j        | _        |j        | _        |j        | _        d S N)urllib3_responsestatusreasondata)selfresps     S/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/kubernetes/client/rest.py__init__zRESTResponse.__init__#   s)     $kkI			    c                 4    | j                                         S )z-Returns a dictionary of the response headers.)r   
getheaders)r   s    r   r   zRESTResponse.getheaders)   s    $//111r   Nc                 8    | j                             ||          S )z Returns a given response header.)r   	getheader)r   namedefaults      r   r   zRESTResponse.getheader-   s    $..tW===r   r   )__name__
__module____qualname__r   r   r    r   r   r   r   !   sF          2 2 2> > > > > >r   r   c                   x    e Zd ZddZ	 	 	 ddZ	 	 ddZ	 	 ddZ	 	 ddZ	 	 dd	Z	 	 dd
Z		 	 ddZ
	 	 ddZdS )RESTClientObject   Nc                    |j         rt          j        }nt          j        }i }|j        
|j        |d<   |j        
|j        |d<   |j        r
|j        |d<   |j        
|j        |d<   ||j        |j        }nd}|j	        rWt          |j        |j        pd          s:t          j        d
||||j        |j        |j        |j	        |j        d|| _        d S t          j        d
||||j        |j        |j        d	|| _        d S )Nassert_hostnameretriesserver_hostnamesocket_optionsr%    )no_proxy)	num_poolsmaxsize	cert_reqsca_certs	cert_filekey_file	proxy_urlproxy_headers)r-   r.   r/   r0   r1   r2   r"   )
verify_sslsslCERT_REQUIRED	CERT_NONEr'   r(   tls_server_namer*   connection_pool_maxsizeproxyr   hostr,   urllib3ProxyManagerssl_ca_certr1   r2   r4   pool_managerPoolManager)r   configuration
pools_sizer.   r/   addition_pool_argss         r   r   zRESTClientObject.__init__4   sv    # 	&)III(44A4Q01 ,,9,Ay)( 	R4A4Q01'33@3O/0?4@'?  	'<]=OZgZpZvtv'w'w'w 	 ' 4 
!$#&2'1&/'-+9
! 
! %
! 
!D !( 3 !$#&2'1&/! ! %! !Dr   Tc	           	         |                                 }|dv sJ |r|rt          d          |pi }|pi }d}	|rt          |t          j        t
          fz             rt          j        |          }	nJt          |t                    r5t          |          dk    r"t          j        |d         |d                   }	d	|vrd
|d	<   	 |dv rg|r|dt          |          z   z  }t          j        d|d	         t          j                  s|d	         dk    r_|d	         dk    rt          |t                    sd|d	<   d}
|t          j        |          }
| j                            |||
||	|          }n|d	         dk    r"| j                            |||d||	|          }n|d	         dk    r%|d	= | j                            |||d||	|          }nt          |t&                    st          |t(                    r#|}
| j                            |||
||	|          }n3d}t+          d|          | j                            |||||	|          }nb# t          j        j        $ rK}d                    t3          |          j        t'          |                    }t+          d|          d}~ww xY w|r/t7          |          }t8                              d|j                   d|j        cxk    rdk    sn |j        dk    rtA          |          |j        d k    rtC          |          |j        d!k    rtE          |          d"|j        cxk    rd#k    rn ntG          |          t+          |          |S )$a  Perform requests.

        :param method: http request method
        :param url: http request url
        :param query_params: query parameters in the url
        :param headers: http request headers
        :param body: request json body, for `application/json`
        :param post_params: request post parameters,
                            `application/x-www-form-urlencoded`
                            and `multipart/form-data`
        :param _preload_content: if False, the urllib3.HTTPResponse object will
                                 be returned without reading/decoding response
                                 data. Default is True.
        :param _request_timeout: timeout setting for this request. If one
                                 number provided, it will be total request
                                 timeout. It can also be a pair (tuple) of
                                 (connection, read) timeouts.
        )GETHEADDELETEPOSTPUTPATCHOPTIONSz9body parameter cannot be used with post_params parameter.N)total   r      )connectreadzContent-Typezapplication/json)rI   rJ   rK   rL   rH   ?jsonzapplication/apply-patch+yamlzapplication/json-patch+jsonz&application/strategic-merge-patch+json)bodypreload_contenttimeoutheadersz!application/x-www-form-urlencodedF)fieldsencode_multipartrU   rV   rW   zmultipart/form-dataTzCannot prepare a request message for provided
                             arguments. Please check that your arguments match
                             declared content type.)r   r   )rX   rU   rV   rW   z{0}
{1}zresponse body: %s   i+  i  )	http_respi  i  i  iW  )$upperr
   
isinstancesixinteger_typesfloatr=   Timeouttuplelenr   research
IGNORECASElistrS   dumpsr@   requeststrbytesr   
exceptionsSSLErrorformattyper   r   loggerdebugr   r   r   r   r   r	   )r   methodurlquery_paramsrW   rT   post_params_preload_content_request_timeoutrV   request_bodyrmsges                 r   ri   zRESTClientObject.requestl   ss   *  . . . . .  	4 	K   "'R-R 	K*C,=	,IJJ K!/0@AAA-u55 K&''1,,!/,Q/6Fq6IK K K ((&8GN#B	5FFF 93<!8!888CIfgn&=r}MM 3=/3QQQ~.2OOO)$55 I H $N3#'L''+z$'7'7)11)(8 ' ' 2 ) )AA ^,0SSS)11*).(8 ' ' 2 ) )AA ^,0EEE  /)11*)-(8 ' ' 2 ) )AA  c** =ju.E.E =#'L)11)(8 ' ' 2 ) )AA7C 'a<<<< %--fc5A>N6=6=	 . ? ?
 !* 	5 	5 	5##DGG$4c!ff==Ca4444	5  	6QA LL,af555ah%%%%#%%%%x3+a8888x3(15555x3'!4444ah%%%%#%%%%%&3333++++s   FI J3(AJ..J3c                 8    |                      d|||||          S )NrF   rW   rv   rw   rt   ri   r   rs   rW   rt   rv   rw   s         r   rF   zRESTClientObject.GET   s-    ||E3$+-=-=)5	  7 7 	7r   c                 8    |                      d|||||          S )NrG   r}   r~   r   s         r   rG   zRESTClientObject.HEAD   s-    ||FC$+-=-=)5	  7 7 	7r   c           
      <    |                      d|||||||          S )NrL   rW   rt   ru   rv   rw   rT   r~   r   rs   rW   rt   ru   rT   rv   rw   s           r   rL   zRESTClientObject.OPTIONS  s3    ||Is$+)5(3-=-=!%  ' ' 	'r   c           	      :    |                      d||||||          S )NrH   )rW   rt   rv   rw   rT   r~   )r   rs   rW   rt   rT   rv   rw   s          r   rH   zRESTClientObject.DELETE  s0    ||Hc$+)5-=-=!%  ' ' 	'r   c           
      <    |                      d|||||||          S )NrI   r   r~   r   s           r   rI   zRESTClientObject.POST  s3    ||FC$+)5(3-=-=!%  ' ' 	'r   c           
      <    |                      d|||||||          S )NrJ   r   r~   r   s           r   rJ   zRESTClientObject.PUT!  s3    ||E3$+)5(3-=-=!%  ' ' 	'r   c           
      <    |                      d|||||||          S )NrK   r   r~   r   s           r   rK   zRESTClientObject.PATCH+  s3    ||GS$+)5(3-=-=!%  ' ' 	'r   )r%   N)NNNNTN)NNTN)NNNTN)r   r    r!   r   ri   rF   rG   rL   rH   rI   rJ   rK   r"   r   r   r$   r$   2   s        6 6 6 6p ?C>B!%F F F FP JN!7 7 7 7 KO"7 7 7 7 IMCG' ' ' ' AE7;' ' ' ' FJ@D' ' ' ' EI?C' ' ' ' GKAE' ' ' ' ' 'r   r$   )__doc__
__future__r   iorS   loggingrd   r6   r^   six.moves.urllib.parser   r=   kubernetes.client.exceptionsr   r   r   r   r	   r
   requests.utilsr   	getLoggerr   rp   IOBaser   objectr$   r"   r   r   <module>r      sf    ' & & & & & 				   				 



 


 , , , , , ,  U  U  U  U  U  U  U  U  U  U  U  U  U  U  U  U 0 0 0 0 0 0 
	8	$	$> > > > >29 > > >"A' A' A' A' A'v A' A' A' A' A'r   