!SSKJr SSKrSSKrSSKrSSKrSSKJrJrJ r SSK r SSK r SSK J r JrJrJr SrSrSrSrSr"S S 5r\R."S S /5rS rSrg)) ApiExceptionN) WebSocketABNF enableTrace) urlencode quote_plusurlparse urlunparsec\rSrSrSrSSjrSSjrSSjrSrSSjr SS jr SS jr SS jr SS jr SS jrSrSrSrSSjrSSjrSrSrg)WSClient#c[S5 /nSUl0UlSUlU(aSU;aUR SUS-5 U(aSU;aUR SUS-5 OUR S5 UR S5(agUR (aV[RUR=(d [R"5S .nURbURUS 'OS [R0nUR(aURUS 'UR(aURUS'[!USS9UlUR"R%X$S9 SUlg )a A websocket client with support for channels. Exec command uses different channels for different streams. for example, 0 is stdin, 1 is stdout and 2 is stderr. Some other API calls like port forwarding can forward different pods' streams to different channels. F authorizationzauthorization: %szsec-websocket-protocolzsec-websocket-protocol: %sz)sec-websocket-protocol: v4.channel.k8s.iozwss://) cert_reqsca_certsNcheck_hostnamercertfilekeyfile)ssloptskip_utf8_validation)headerT)r _connected _channels_allappend startswith verify_sslssl CERT_REQUIRED ssl_ca_certcertifiwhereassert_hostname CERT_NONE cert_filekey_filersockconnect)self configurationurlheadersrssl_optss .lib/third_party/kubernetes/stream/ws_client.py__init__WSClient.__init__%sE FDODNDI?g- mm''/*BBC+w6 mm04567 mm?@ ~~hM$<$<((#//B7==?h  & & 2%2%B%B!"s}}-h*44hz)22hyFDIIIc)DOc^URUS9 XR;aURU$g)zFPeek a channel and return part of the input, empty string otherwise. timeoutr)updater)r.channelr9s r3 peek_channelWSClient.peek_channelQs.  KKK .. ^^G $$ r6cXR;aURX5nOURUnXR;a URU U$)zRead data from a channel.)rr<)r.r;r9rets r3 read_channelWSClient.read_channel[sEnn$   g /c NN7 #c.. .. ! Jr6Nc6Uc [S5n[R"5nUR5(a[R"5U- U:aXR;aXURUnSU;aCUR S5nUSUnXES-SnU(aX@RU'U$URU U$UR U[R"5- U-S9 UR5(a[R"5U- U:aMgggg)zRead a line from a channel.Ninf r r8)floattimeis_openrfindr:)r.r;r9startdataindexr?s r3readline_channelWSClient.readline_channelese g IIKE ,,..TYY[507: NN "~~g& 4<))D/%Ve #aij!$ &*NN7 #*w'* kk7TYY[058k: ,,..TYY[507:.:.r6cRURR[U5U-5 g)zWrite data to a channel.N)r,sendchr)r.r;rJs r3 write_channelWSClient.write_channelxsIINN3w<$&'r6c*UR[US9$)z$Same as peek_channel with channel=1.r8)r<STDOUT_CHANNELr.r9s r3 peek_stdoutWSClient.peek_stdout|   ^W  ==r6c*UR[US9$)z$Same as read_channel with channel=1.r8)r@rTrUs r3 read_stdoutWSClient.read_stdoutrXr6c*UR[US9$)z(Same as readline_channel with channel=1.r8)rLrTrUs r3readline_stdoutWSClient.readline_stdout   AAr6c*UR[US9$)z$Same as peek_channel with channel=2.r8)r<STDERR_CHANNELrUs r3 peek_stderrWSClient.peek_stderrrXr6c*UR[US9$)z$Same as read_channel with channel=2.r8)r@rarUs r3 read_stderrWSClient.read_stderrrXr6c*UR[US9$)z(Same as readline_channel with channel=2.r8)rLrarUs r3readline_stderrWSClient.readline_stderrr_r6c:URnSUl0UlU$)adReturn buffered data received on stdout and stderr channels. This is useful for non-interactive call where a set of command passed to the API call and their result is needed after the call is concluded. Should be called after run_forever() or update() TODO: Maybe we can process this and return a more meaningful map with channels mapped for each input. r)rr)r.outs r3read_allWSClient.read_alls  ))CDIDN Jr6cUR$)z&True if the connection is still alive.)r)r.s r3rGWSClient.is_opens ??r6c0UR[U5 g)z)The same as write_channel with channel=0.N)rQ STDIN_CHANNEL)r.rJs r3 write_stdinWSClient.write_stdins}d+r6c UR5(dgURR(dSUlg[R"URR4SSU5un nU(GaURR S5upEU[ R:XaSUlgU[ R:XdU[ R:XaURn[R(aURSS5n[U5S:av[US5nUSSnU(a[U[ ["4;aU=R$U- slXpR&;aX`R&U'gUR&U==U- ss'ggggg) z@Update channel buffers with at most one complete frame of input.NFTzutf-8replacer r)rGr, connectedrselectrecv_data_framer OPCODE_CLOSE OPCODE_BINARY OPCODE_TEXTrJsixPY3decodelenordrTrarr)r.r9r_op_codeframerJr;s r3r:WSClient.updates: <<>> 99  do mmTYY^^-r2w?GAq!yy006ng D%% % d(( (Gt7G7G,Gzz 77Wi0$ t9q=QL'ab$ >>::ii4inn,(,nnW%nnW%-%  -H  r6cU(a[R"5nUR5(az[R"5U- U:a]URU[R"5- U-S9 UR5(a[R"5U- U:aM[ggggUR5(a'URSS9 UR5(aM&gg)zdWait till connection is closed or timeout reached. Buffer any input received during this time. r8N)rFrGr:)r.r9rIs r3 run_foreverWSClient.run_forevers iike LLNNtyy{U2W< Wtyy{2U: < LLNNtyy{U2W>B>>B ,.< " r6r WSResponserJc[U5n[U5nURS:XaSUS'OURS:XaSUS'[U5$)Nhttpwsrhttpswss)r listschemer )r0 parsed_urlpartss r3get_websocket_urlrsN}* z %& E!HG#E!H E r6cUSnURSS5nURSS5nURS5n/nURS05HOupUS:Xa2[U [5(aU Hn URX45 M M=URX45 MQ U(aUS [ U5-- n[ U[ U5U5n U(dU $U RUS 9 [S S RU R55-5$![[[4an [S [U 5S9eSn A ff=f)zAn internal function to be called in api-client when a websocket connection is required. args and kwargs are the parameters of apiClient.request method. r _request_timeout<_preload_contentTr1 query_paramscommand?r8z%srr)statusreasonN)get isinstancerr rrrrrjoinrl ExceptionKeyboardInterrupt SystemExitrstr) r/argsrr0rrr1rkeyvaluerclientes r3websocket_callrs2 Q#ZZ 2B7ZZ 2D9 JJy !',JJ~r2jc iJud33'SN+3,' 33<( ((C0 m%6s%;W EF  m /0 dRWWV__%677 88 & 30 aA //0s;D9DE)D<<E)kubernetes.client.restrrxr&rF collections websocketrrrr}r#six.moves.urllib.parserrr r rqrTra ERROR_CHANNELRESIZE_CHANNELr namedtuplerrrrur6r3rsn"0  22 NN  z z z # #L6( ; 0r6