VimUnDo5ãUoởD5$<%Hl4_s tjW~S_2'VN13D self.logger.info('cluster proxy not running -- starting launch')5_3VN57 }47 i36 355_5VN57 575_7VN8: }7: i69 }5_8VN8: 8:5_4< <HvVN36 var tasks = []455_5= =HvVN35P var tasks = [_.partial(self._startReplicationController.bind(self), token),]35O var tasks = [_.partial(self._startReplicationController.bind(self), token),]46]5_ ;;?vVN:< var tasks = [H _.partial(self._startReplicationController.bind(self), token),4 self._startRegistrationService.bind(self),- self._startLookupService.bind(self) ]/ async.parallel(tasks, function (err, ips) {5_ eVQ fh ieh tdg state: pod,5_ ffgvVQeg times: 20, interval: 20000, condition: function (pods) {5_ iffvVQik5_ jffvVQimjk5_  lffvVQkl5_ :OVj9;Q '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug'],5_:TVҚ 9;V '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug', '--],5_:WV\9;h '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug', '--no-include-prefix'],5_:_V` 9;h '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug', '--no-prepend-prefix'],5_:WVfa9;f '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug', '--no-prepend-path'],5_:_Vfe 9;f '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug', '--no-routing-path'],5_:WVf}9;h '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug', '--no-routing-prefix'],5_Vؑ4 5_:O:e:OvOVު9;h '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug', '--no-include-prefix'],5_] V^` }]` {\_ }5_^V`b }_b s^a ^`5_` V`b `b5_D VEG ]DG DF5_E VFH }EH EG5_F VGJ rFI FH5_HHHvV/GI readOnly: 'true',5_IHHvV1HI5_ H HHvV1HJ HJ5_! :OHHvV}:< ],9<Q '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug'],5_ "!L VKM ]5_!#"HVGI# name: 'binder-certs',5_"$#HHHvVGI" name: 'certs-certs',5_#%$HHHvVGI name: 'certss',5_$&%HHHvVGI name: 'certs',5_%'&HHHvVGI" name: 'certs-vlume',5_&(';;;vV):<H '/data/certs/app.key', '--ssl-cert', '/data/certs/app.crt'],5_')(;:;:;@v@V) :<D '/data/certs/key', '--ssl-cert', '/data/certs/app.crt'],5_(*) v VG this.logger = this._makeLogger(getLogger('binder-deploy-kubernetes'))5_)+*5 v V!6 this.logger = getLogger('binder-deploy-kubernetes'))5_*,+!vV5ProxyClient.prototype._makeLogger = function (base) {3 base.rewriters.push(function (level, msg, meta) {" meta.component = 'ProxyClient' return meta }) return base}5_+-,vV }P5_,.-vV 5_-/.vV 5_.0/vV# 5_/10"vV!"5_021vV 0ProxyClient.prototype.logInfo = function (msg) {5_132 vV"!5 this.logger.info(msg, { component: 'ProxyClient' })5_253"vV$!"5_3645$$$vV#%( this.logger.info('starting proxy pod')5_576} } }vV|~; self.logger.info('could not start proxy pod: ' + err)5_687  vV~+ self.logger.info('started proxy pod')5_798vV8 this.logger.info('starting service: {0}'.format(name))5_8:9  vVJ self.logger.info('could not start service {0}: '.format(name) + err)5_9;:  vVN self.logger.info('started service {0} -- ingressIP: {1}'.format(name, ip))5_:<;vV< self.logger.info('getting info on running proxy services')5_;=<   vV I self.logger.info('found ingress IP {0} for {1}'.format(ip, name))5_<>=  vV @ self.logger.info('pods: {0}'.format(JSON.stringify(pods)))5_=?>1 1 1vV02R self.logger.info('in _getRunningInfo, info: {0}'.format(JSON.stringify(info)))5_>@?777vV68G this.logger.info('checking if the cluster proxy needs to be started')5_?A@B B BvV#ACJ self.logger.info('cluster proxy not fully running -- starting launch')5_@BAR R RvV)QS^ self.logger.info('successfully launched cluster proxy -- lookupIP: {0}, registerIP: {1}'5_ACBZZZvV-Y[, this.logger.info('stopping cluster proxy')5_BDCl l lvV1kmQ this.logger.info('registering proxy route: {0} -> {1}'.format(route, target))5_CED  vV5? self.logger.info('removing proxy route: {0}'.format(route))5_DFE  vV;%F this.logger.info('getting proxy routes with age: {0}'.format(age))5_EGF  vVO& this.logger.error(msg) self.logger.error(msg)A self.logger.error('could not remove proxy route: ' + err)y{ self.logger.error(msg)LN: self.logger.error('in launchClusterProxy: ' + err)(*; self.logger.error('error in _getRunningInfo: ' + err)!6 this.logger.error(msg, { component: 'ProxyClient' })5_FHG!!vVh!$!#5_GIH#!vVh"'#$5_HJI&!vVi%&5_IKJ#!vVl"$1ProxyClient.prototype.logError = function (msg) {5_JLK !vVs!2 this.logError(msg, { component: 'ProxyClient' })5_KML$!vVv(#%2 this.logError(msg, { component: 'ProxyClient' })5_LNM$!vV*S this.logger.debug('full route query options: {0}'.format(JSON.stringify(opts)))9 this.logger.debug('route query url: {0}'.format(url))L self.logger.debug('sending request to {0}'.format(JSON.stringify(opts)))xzM self.logger.debug('sending request to: {0}'.format(JSON.stringify(opts)))#%6 this.logger.debug(msg, { component: 'ProxyClient' })5_MON$V,#%2 this.logDebug(msg, { component: 'ProxyClient' })5_NPO? V>?A '/data/certs/key', '--ssl-cert', '/data/certs/cert'],5_OQP>O>[>OvOV=?] '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug', '--ssl-key',5_PRQ>O>[>OvOV=?P '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug',5_QSR>O>[>OvOV-=?O '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug'5_RVS>PV4=?P '--api-port', '8081', '--api-ip', '0.0.0.0', '--log-level', 'debug']5_SWTVWÈ'var KubeClient = require('kube-stream')5_VXWWË'var kubeClient = require('kube-stream')5_WYXWÑ$var kubeClient = require('./client')5_XZYWÒ 5_Y[Z WÒ  5_Z\[ WÓ5 5_[_\vWÙ9 this.client = new KubeClient()5_\`]_iin vW&hj { name: 'certs-volume', secret: {& secretName: 'binder-certs' } } ],5__a`h ii vW&;gi },5_`baIIO vW'}=HJ volumeMounts: [ {# name: 'certs-volume', readOnly: true,& mountPath: '/data/certs' } ],# imagePullPolicy: 'Always'5_acbE W=DF } 5_bdcE W=DF } 5_cedE W=DF } 5_dfeE W=DF } 5_egfEW=DF } 5_fhgEW=>DF } 5_gihW=? s }5_hjiW=@! spec.sessionAffinity = 'None'5_ikjW=! spec.sessionAffinity = 'None'5_jmkW=D s }5_knlmWhJmEh var msg = 'could not register proxy route -- bad response: {0}'.format(JSON.stringify(response))5_monuW~ivx }ux uw5_npovW~yvx vx5_oqpwwW~xz }wz }vy async.retry5_prqxwW~y{ }x{ xz5_qsrywW~ y{ y{5_rtszwW~!y{K self.logErr('FINAL -- could not register proxy route after retrying5_sutzMwW~#Fy{M self.logError('FINAL -- could not register proxy route after retrying5_tvuzLwW~FGz| z|5_uwvzNwzNz]v]W~Ny{^ self.logError('FINAL -- could not register proxy route after retrying', route, target)5_vxwzNwzNz]v]W~NHy{N self.logError('FINAL -- could not register proxy route after retrying'5_wyxz>wzNz]v]W~UIy{O self.logError('FINAL -- could not register proxy route after retrying')5_xzy|wzNz]v]W~^J|~ |~5_y{z{wzNz]v]W~bz{ return cb(err)5_z|{|wzNz]v]W~dK{} return cb(null)5_{}|zwzNz]v]W~gxz if (err) {Uself.logError('FINAL -- could not register proxy route ' + route + ' after retrying')y{] self.logError('FINAL -- could not register proxy route ' + route + ' after retrying')5_|~}zwy^ymv]W~iLyz }5_}~wwy^ymv]W~mMwy wy5_~wz^zmv]W~ 5_wz^zmv]W~, register.bind(self)(route, target, cb)5_wz^zmv]W~* register.bind(self)(route, target, cb)5_wz^zmv]W~O 5_wwz^zmv]W~Qvx? async.retry({ time: 10, interval: 1000 }, function (next) {5_iBwW~hjB headers: { 'Authorization': 'token {0}'.format(self.token) }5_iBwW~Sik thkB headers: { 'Authorization': 'token {0}'.format(self.token) }5_kmlW=i }2jjkjkjkk5_\^_]Wʪ7 this.client = kubeClient(opts)5_]^Wʬ8% this.client = kubeClient(opts.kube)5_SUVTVv, if (true || this.provider === 'vagrant') {5_TUV3, if (true || this.provider === 'vagrant') {5_354!vV "nfo}5