VddlZddlmZddlmZdZdZdZdZd Z Gd d e Z d Z y) N) Configuration)ConfigExceptionKUBERNETES_SERVICE_HOSTKUBERNETES_SERVICE_PORTz3/var/run/secrets/kubernetes.io/serviceaccount/tokenz4/var/run/secrets/kubernetes.io/serviceaccount/ca.crtc0d}d|vxsd|v}|rd}|||fzS)z!Adapted golang's net.JoinHostPortz%s:%s:%z[%s]:%s)hostporttemplatehost_requires_bracketings 5lib/third_party/kubernetes/config/incluster_config.py_join_host_portrs1 ( D[7C4KH T4L  c<eZdZejfdZdZdZdZy)InClusterConfigLoaderc.||_||_||_yN)_token_filename_cert_filename_environ)selftoken_filename cert_filenameenvirons r__init__zInClusterConfigLoader.__init__(s)D'DDMrcD|j|jyr) _load_config _set_config)rs r load_and_setz"InClusterConfigLoader.load_and_set-src\t|jvst|jvr td|jtr|jts tddt |jt|jtz|_t jj|js tdt|j5}|j|_ |js td dddt jj|js tdt|j5}|js td ddd|j|_y#1swYxYw#1swY'xYw)NzService host/port is not set.z#Service host/port is set but empty.zhttps://z#Service token file does not exists.zToken file exists but empty.z+Service certification file does not exists.zCert file exists but empty.)SERVICE_HOST_ENV_NAMErSERVICE_PORT_ENV_NAMErrr ospathisfileropenreadtokenr ssl_ca_cert)rfs rr z"InClusterConfigLoader._load_config1sNT]]2T]]2 ; << MM/ 0 MM/ 0 A BB /D!E!%/D!EGGDI 77>>$.. / A BB d"" #q668dj ZZ<== $ 77>>$-- . I JJ d!! "a VVX;<< #**D $ # # "s -FF"F"F+ct}|j|_|j|_d|jz|jd<tj |y)Nzbearer authorization)rr r,r+api_key set_default)r configurations rr!z!InClusterConfigLoader._set_configOsJ!OMM $ 0 0M-6-CM/*m,rN) __name__ __module__ __qualname__r&rrr"r r!r rrrr&s<>JJ +<-rrcJtttjy)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. )rrN)rSERVICE_TOKEN_FILENAMESERVICE_CERT_FILENAMEr"r rrload_incluster_configr9Ws+)++7<>r) r&kubernetes.clientrconfig_exceptionrr$r%r7r8robjectrr9r rrr=s?" +-11NN!.-F.-b :r