
    :gA3                         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	Z	ddl
mZ ddlZddlmZmZ ddlmZ  ej$                  e      Z G d dej*                        Z G d	 d
e      Zy)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.32
    Generated by: https://openapi-generator.tech
    )absolute_importN)	urlencode)ApiExceptionApiValueError)should_bypass_proxiesc                        e Zd Zd Zd ZddZy)RESTResponsec                 x    || _         |j                  | _        |j                  | _        |j                  | _        y N)urllib3_responsestatusreasondata)selfresps     K/var/www/openai/venv/lib/python3.12/site-packages/kubernetes/client/rest.py__init__zRESTResponse.__init__$   s+     $kkkkII	    c                 6    | j                   j                         S )z-Returns a dictionary of the response headers.)r   
getheaders)r   s    r   r   zRESTResponse.getheaders*   s    $$//11r   Nc                 :    | j                   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	   "   s    2>r   r	   c                   v    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y)RESTClientObjectNc                    |j                   rt        j                  }nt        j                  }|j                  r|j                  }nt        j                         }i }|j                  |j                  |d<   |j                  |j                  |d<   |j                  r|j                  |d<   ||j                  |j                  }nd}|j                  rqt        |j                  |j                  xs d      sLt        j                   d	|||||j"                  |j$                  |j                  |j&                  d|| _        y t        j*                  d	|||||j"                  |j$                  d|| _        y )
Nassert_hostnameretriesserver_hostname    )no_proxy)	num_poolsmaxsize	cert_reqsca_certs	cert_filekey_file	proxy_urlproxy_headers)r(   r)   r*   r+   r,   r-   r   )
verify_sslsslCERT_REQUIRED	CERT_NONEssl_ca_certcertifiwherer"   r#   tls_server_nameconnection_pool_maxsizeproxyr   hostr'   urllib3ProxyManagerr,   r-   r/   pool_managerPoolManager)r   configuration
pools_sizer)   r*   r+   addition_pool_argss          r   r   zRESTClientObject.__init__5   s}    ##))II $$$00H }}H((44A4Q4Q01  ,,9,A,Ay)((4A4Q4Q01?44@'?? '<]=O=OZgZpZpZvtv'w ' 4 4 
!$#!'11&//'--+99
! %
!D !( 3 3 !$#!'11&//! %!Dr   c	           	         |j                         }|dv sJ |r|rt        d      |xs i }|xs i }d}	|rt        |t        j                  rt
        fnt
        t        f      rt        j                  |      }	n;t        |t              r+t        |      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(  rX|d	   dk(  rt        |t              sd|d	<   d}
|t!        j"                  |      }
| j$                  j'                  |||
||	|      }n|d	   dk(  r#| j$                  j'                  |||d||	|      }n|d	   dk(  r&|d	= | j$                  j'                  |||d||	|      }ntt        |t(              st        |t*              r$|}
| j$                  j'                  |||
||	|      }n0d}t-        d|      | j$                  j'                  |||||	|      }|r[t9        |      }t        j                  r |j:                  j=                  d      |_        t>        jA                  d|j:                         d|jB                  cxk  rdk  sn t-        |      |S # t        j.                  j0                  $ r@}dj3                  t5        |      j6                  t)        |            }t-        d|      d}~ww xY w) 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)rF   rG   rH   rI   rE   ?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_multipartrR   rS   rT   zmultipart/form-dataTzCannot prepare a request message for provided
                             arguments. Please check that your arguments match
                             declared content type.)r   r   )rU   rR   rS   rT   z{0}
{1}utf8zresponse body: %s   i+  )	http_resp)"upperr   
isinstancesixPY3intlongr;   Timeouttuplelenr   research
IGNORECASElistrP   dumpsr=   requeststrbytesr   
exceptionsSSLErrorformattyper   r	   r   decodeloggerdebugr   )r   methodurlquery_paramsrT   rQ   post_params_preload_content_request_timeoutrS   request_bodyrmsges                 r   rh   zRESTClientObject.requestq   sB   *  . . 	. . 4K  "'R-R*swwSGS$KP!//0@A-u5&'1,!//,Q/6Fq6IK (&8GN#B	5FF3<!888CIIfgn&=r}}M/3QQ~.2OO)$5 H $N3#'L''+zz$'7))11)(8 ' ' 2 )A ^,0SS))11*).(8 ' ' 2 )A ^,0EE  /))11*)-(8 ' ' 2 )A  c*ju.E#'L))11)(8 ' ' 2 )A7C 'a<< %%--fc5A>N6=6=	 . ? QA wwv. LL,aff5ahh%#%++% !!** 	5##DG$4$4c!f=Ca44	5s   ?E-J. .L;LLc                 0    | j                  d|||||      S )NrC   rT   rv   rw   rt   rh   r   rs   rT   rt   rv   rw   s         r   rC   zRESTClientObject.GET   s(    ||E3$+-=-=)5	  7 	7r   c                 0    | j                  d|||||      S )NrD   r}   r~   r   s         r   rD   zRESTClientObject.HEAD   s(    ||FC$+-=-=)5	  7 	7r   c           
      4    | j                  d|||||||      S )NrI   rT   rt   ru   rv   rw   rQ   r~   r   rs   rT   rt   ru   rQ   rv   rw   s           r   rI   zRESTClientObject.OPTIONS  s.    ||Is$+)5(3-=-=!%  ' 	'r   c           	      2    | j                  d||||||      S )NrE   )rT   rt   rv   rw   rQ   r~   )r   rs   rT   rt   rQ   rv   rw   s          r   rE   zRESTClientObject.DELETE  s+    ||Hc$+)5-=-=!%  ' 	'r   c           
      4    | j                  d|||||||      S )NrF   r   r~   r   s           r   rF   zRESTClientObject.POST  s.    ||FC$+)5(3-=-=!%  ' 	'r   c           
      4    | j                  d|||||||      S )NrG   r   r~   r   s           r   rG   zRESTClientObject.PUT  s.    ||E3$+)5(3-=-=!%  ' 	'r   c           
      4    | j                  d|||||||      S )NrH   r   r~   r   s           r   rH   zRESTClientObject.PATCH)  s.    ||GS$+)5(3-=-=!%  ' 	'r   )r%   N)NNNNTN)NNTN)NNNTN)r   r   r   r   rh   rC   rD   rI   rE   rF   rG   rH   r   r   r   r    r    3   s    :x ?C>B!%B JN!7 KO"7 IMCG' AE7;' FJ@D' EI?C' GKAE'r   r    )__doc__
__future__r   iorP   loggingrc   r1   r5   r\   six.moves.urllib.parser   r;   kubernetes.client.exceptionsr   r   requests.utilsr   	getLoggerr   rp   IOBaser	   objectr    r   r   r   <module>r      sb    ' 	   	 
  
 ,  D 0 
		8	$>299 >"~'v ~'r   