INNER CODE UNIT · JavaScript

Watch

astefanutti/kubebox · lib/client.js:138

const Watch = T => class extends T {

  watch(resourceVersion, { websocket = true } = {}) {
    const uri = URI('')
      .addQuery('watch', true)
      .addQuery('resourceVersion', resourceVersion);
    return new WatchListRequest(merge({}, this.options, {
      path    : uri.toString(),
      headers : websocket ? {
        // https://tools.ietf.org/html/rfc6455
        Origin                 : this.context.client.master_api.url,
        Connection             : 'upgrade',
        Upgrade                : 'websocket',
        'Sec-WebSocket-Key'    : crypto.createHash('SHA1').digest('base64'),
        'Sec-WebSocket-Version': 13,
      } : {},
    }), this.context);
  }

View source record →