ZiDhddlZddlZddlmZddlmZdZdZdZdZ d Z Gd d e Z dd Z dS)N) Configuration)ConfigExceptionKUBERNETES_SERVICE_HOSTKUBERNETES_SERVICE_PORTz3/var/run/secrets/kubernetes.io/serviceaccount/tokenz4/var/run/secrets/kubernetes.io/serviceaccount/ca.crtc,d}d|vpd|v}|rd}|||fzS)z!Adapted golang's net.JoinHostPortz%s:%s:%z[%s]:%s)hostporttemplatehost_requires_bracketings ]/root/projects/butler/venv/lib/python3.11/site-packages/kubernetes/config/incluster_config.py_join_host_portrs6H"d{9cTk tTl ""c>eZdZdejfdZddZdZdZdZ dS) InClusterConfigLoaderTcr||_||_||_||_t jd|_dS)Nr)minutes)_token_filename_cert_filename_environ_try_refresh_tokendatetime timedelta_token_refresh_period)selftoken_filename cert_filenametry_refresh_tokenenvirons r__init__zInClusterConfigLoader.__init__&s? .+ "3%-%7%B%B%B"""rNcd}|!tt}d}||||rtj|dSdS)NFT)type__call__r _load_config _set_config set_default)rclient_configurationtry_set_defaults r load_and_setz"InClusterConfigLoader.load_and_set1su  '#'==#?#? "O  -...  <  %&: ; ; ; ; ; < !<>> >$% & & E!6688 E%&CDDD E E E E E E E E E E E E E E E E .s%$EEEcj|_j|_jj|jd<jsdSfd}||_dS)N authorizationcjtjkr|dSN)token_expires_atrnowr3r()r*rs r_refresh_api_keyz;InClusterConfigLoader._set_config.._refresh_api_key_sM$(9(=(=(?(???%%'''   1 2 2 2 2 2r)r r6tokenapi_keyrrefresh_api_key_hook)rr*r>s` rr(z!InClusterConfigLoader._set_configWsm$(I!+/+;( : !<@J ( 9&  F 3 3 3 3 3 5E111rct|j5}|}|stdd|z|_t j|jz|_ddddS#1swxYwYdS)NzToken file exists but empty.zbearer ) r4rr5rr?rr=rr<)rr7contents rr3z&InClusterConfigLoader._read_token_filefs $& ' ' +1ffhhG F%&DEEE"W,DJ$,$5$9$9%%*%+D !  + + + + + + + + + + + + + + + + + +sAA==BBr;) __name__ __module__ __qualname__r0r"r#r,r'r(r3r rrrr%sz$( C C C C<<<<///8 E E E+++++rrTcdttt||dS)a Use the service account kubernetes gives to pods to connect to kubernetes cluster. It's intended for clients that expect to be running inside a pod running on kubernetes. It will raise an exception if called from a process not running in a kubernetes environment.)rr r!N)rSERVICE_TOKEN_FILENAMESERVICE_CERT_FILENAMEr,)r*r!s rload_incluster_configrJps8 -++---.:\:N-O-O-O-O-Or)NT)rr0kubernetes.clientrconfig_exceptionrr.r/rHrIrobjectrrJr rrrNs ++++++------11NN###H+H+H+H+H+FH+H+H+V P P P P P Pr