Java 类org.apache.hadoop.fs.swift.auth.AuthenticationRequest 实例源码

项目：hadoop 文件：SwiftRestClient.java

/**
 * Authenticate to Openstack Keystone
 * As well as returning the access token, the member fields {@link #token},
 * {@link #endpointURI} and {@link #objectLocationURI} are set up for re-use.
 * <p>
 * This method is re-entrant -if more than one thread attempts to authenticate
 * neither will block -but the field values with have those of the last caller.
 *
 * @return authenticated access token
 */
public AccessToken authenticate() throws IOException {
  final AuthenticationRequest authenticationRequest;
  if (useKeystoneAuthentication) {
    authenticationRequest = keystoneAuthRequest;
  } else {
    authenticationRequest = authRequest;
  }

  LOG.debug("started authentication");
  return perform("authentication",
                 authUri,
                 new AuthenticationPost(authenticationRequest));
}

项目：hadoop 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：aliyun-oss-hadoop-fs 文件：SwiftRestClient.java

/**
 * Authenticate to Openstack Keystone
 * As well as returning the access token, the member fields {@link #token},
 * {@link #endpointURI} and {@link #objectLocationURI} are set up for re-use.
 * <p>
 * This method is re-entrant -if more than one thread attempts to authenticate
 * neither will block -but the field values with have those of the last caller.
 *
 * @return authenticated access token
 */
public AccessToken authenticate() throws IOException {
  final AuthenticationRequest authenticationRequest;
  if (useKeystoneAuthentication) {
    authenticationRequest = keystoneAuthRequest;
  } else {
    authenticationRequest = authRequest;
  }

  LOG.debug("started authentication");
  return perform("authentication",
                 authUri,
                 new AuthenticationPost(authenticationRequest));
}

项目：aliyun-oss-hadoop-fs 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：big-c 文件：SwiftRestClient.java

/**
 * Authenticate to Openstack Keystone
 * As well as returning the access token, the member fields {@link #token},
 * {@link #endpointURI} and {@link #objectLocationURI} are set up for re-use.
 * <p>
 * This method is re-entrant -if more than one thread attempts to authenticate
 * neither will block -but the field values with have those of the last caller.
 *
 * @return authenticated access token
 */
public AccessToken authenticate() throws IOException {
  final AuthenticationRequest authenticationRequest;
  if (useKeystoneAuthentication) {
    authenticationRequest = keystoneAuthRequest;
  } else {
    authenticationRequest = authRequest;
  }

  LOG.debug("started authentication");
  return perform("authentication",
                 authUri,
                 new AuthenticationPost(authenticationRequest));
}

项目：big-c 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：SwiftRestClient.java

/**
 * Authenticate to Openstack Keystone
 * As well as returning the access token, the member fields {@link #token},
 * {@link #endpointURI} and {@link #objectLocationURI} are set up for re-use.
 * <p/>
 * This method is re-entrant -if more than one thread attempts to authenticate
 * neither will block -but the field values with have those of the last caller.
 * <p/>
 *
 * @return authenticated access token
 */
public AccessToken authenticate() throws IOException {
  final AuthenticationRequest authenticationRequest;
  if (useKeystoneAuthentication) {
    authenticationRequest = keystoneAuthRequest;
  } else {
    authenticationRequest = authRequest;
  }

  LOG.debug("started authentication");
  return perform("authentication",
                 authUri,
                 new AuthenticationPost(authenticationRequest));
}

项目：hadoop-2.6.0-cdh5.4.3 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：hops 文件：SwiftRestClient.java

/**
 * Authenticate to Openstack Keystone
 * As well as returning the access token, the member fields {@link #token},
 * {@link #endpointURI} and {@link #objectLocationURI} are set up for re-use.
 * <p>
 * This method is re-entrant -if more than one thread attempts to authenticate
 * neither will block -but the field values with have those of the last caller.
 *
 * @return authenticated access token
 */
public AccessToken authenticate() throws IOException {
  final AuthenticationRequest authenticationRequest;
  if (useKeystoneAuthentication) {
    authenticationRequest = keystoneAuthRequest;
  } else {
    authenticationRequest = authRequest;
  }

  LOG.debug("started authentication");
  return perform("authentication",
                 authUri,
                 new AuthenticationPost(authenticationRequest));
}

项目：hops 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：hadoop-on-lustre2 文件：SwiftRestClient.java

/**
 * Authenticate to Openstack Keystone
 * As well as returning the access token, the member fields {@link #token},
 * {@link #endpointURI} and {@link #objectLocationURI} are set up for re-use.
 * <p/>
 * This method is re-entrant -if more than one thread attempts to authenticate
 * neither will block -but the field values with have those of the last caller.
 * <p/>
 *
 * @return authenticated access token
 */
public AccessToken authenticate() throws IOException {
  final AuthenticationRequest authenticationRequest;
  if (useKeystoneAuthentication) {
    authenticationRequest = keystoneAuthRequest;
  } else {
    authenticationRequest = authRequest;
  }

  LOG.debug("started authentication");
  return perform("authentication",
                 authUri,
                 new AuthenticationPost(authenticationRequest));
}

项目：hadoop-on-lustre2 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：sahara-extra 文件：SwiftRestClient.java

/**
 * Authenticate to Openstack Keystone
 * As well as returning the access token, the member fields {@link #token},
 * {@link #endpointURI} and {@link #objectLocationURI} are set up for re-use.
 * <p/>
 * This method is re-entrant -if more than one thread attempts to authenticate
 * neither will block -but the field values with have those of the last caller.
 * <p/>
 *
 * @return authenticated access token
 */
public AccessToken authenticate() throws IOException {
  final AuthenticationRequest authenticationRequest;
  if (useKeystoneAuthentication) {
    authenticationRequest = keystoneAuthRequest;
  } else {
    authenticationRequest = authRequest;
  }

  LOG.debug("started authentication");
  return perform("authentication",
                 authUri,
                 new AuthenticationPost(authenticationRequest));
}

项目：sahara-extra 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：hadoop 文件：SwiftRestClient.java

private AuthenticationPost(AuthenticationRequest authenticationRequest) {
  this.authenticationRequest = authenticationRequest;
}

项目：aliyun-oss-hadoop-fs 文件：SwiftRestClient.java

private AuthenticationPost(AuthenticationRequest authenticationRequest) {
  this.authenticationRequest = authenticationRequest;
}

项目：big-c 文件：SwiftRestClient.java

private AuthenticationPost(AuthenticationRequest authenticationRequest) {
  this.authenticationRequest = authenticationRequest;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：SwiftRestClient.java

private AuthenticationPost(AuthenticationRequest authenticationRequest) {
  this.authenticationRequest = authenticationRequest;
}

项目：hops 文件：SwiftRestClient.java

private AuthenticationPost(AuthenticationRequest authenticationRequest) {
  this.authenticationRequest = authenticationRequest;
}

项目：hadoop-on-lustre2 文件：SwiftRestClient.java

private AuthenticationPost(AuthenticationRequest authenticationRequest) {
  this.authenticationRequest = authenticationRequest;
}

项目：sahara-extra 文件：SwiftRestClient.java

private AuthenticationPost(AuthenticationRequest authenticationRequest) {
  this.authenticationRequest = authenticationRequest;
}