| Package | Description |
|---|---|
| alluxio.proxy.s3 | |
| alluxio.proxy.s3.auth | |
| alluxio.proxy.s3.signature | |
| alluxio.proxy.s3.signature.utils |
| Modifier and Type | Method and Description |
|---|---|
static S3Exception |
S3RestUtils.toBucketS3Exception(java.lang.Exception exception,
java.lang.String resource)
Convert an exception to instance of
S3Exception. |
static S3Exception |
S3RestUtils.toBucketS3Exception(java.lang.Exception exception,
java.lang.String resource,
S3AuditContext auditContext)
Convert an exception to instance of
S3Exception. |
static S3Exception |
S3RestUtils.toObjectS3Exception(java.lang.Exception exception,
java.lang.String resource)
Convert an exception to instance of
S3Exception. |
static S3Exception |
S3RestUtils.toObjectS3Exception(java.lang.Exception exception,
java.lang.String resource,
S3AuditContext auditContext)
Convert an exception to instance of
S3Exception. |
| Modifier and Type | Method and Description |
|---|---|
CompleteMultipartUploadResult |
CompleteMultipartUploadHandler.CompleteMultipartUploadTask.call() |
T |
S3RestUtils.RestCallable.call()
The REST endpoint implementation.
|
static void |
S3RestUtils.checkPathIsAlluxioDirectory(FileSystem fs,
java.lang.String bucketPath,
S3AuditContext auditContext)
Check if a path in alluxio is a directory.
|
static void |
S3RestUtils.checkPathIsAlluxioDirectory(FileSystem fs,
java.lang.String bucketPath,
S3AuditContext auditContext,
com.google.common.cache.Cache<java.lang.String,java.lang.Boolean> bucketPathCache)
Check if a path in alluxio is a directory.
|
static java.lang.String |
ListBucketResult.decodeToken(java.lang.String token)
Decode a continuation token which is used in get Bucket.
|
static TaggingData |
S3RestUtils.deserializeTaggingHeader(java.lang.String taggingHeader,
int maxHeaderMetadataSize)
Given a URL-encoded Tagging header, parses and deserializes the Tagging metadata
into a
TaggingData object. |
static java.lang.String |
S3RestUtils.getUser(java.lang.String authorization,
javax.ws.rs.container.ContainerRequestContext requestContext)
Get username from header info.
|
static java.lang.String |
S3RestUtils.getUser(java.lang.String authorization,
javax.servlet.http.HttpServletRequest request)
Get username from header info from HttpServletRequest.
|
static java.lang.String |
S3RestUtils.getUserFromAuthorization(java.lang.String authorization,
AlluxioConfiguration conf)
Gets the user from the authorization header string for AWS Signature Version 4.
|
CompleteMultipartUploadRequest |
S3ObjectTask.CompleteMultipartUploadTask.parseCompleteMultipartUploadRequest(java.lang.String objectPath)
Parse xml http body for CompleteMultipartUploadRequest.
|
CompleteMultipartUploadRequest |
CompleteMultipartUploadHandler.CompleteMultipartUploadTask.parseCompleteMultipartUploadRequest(java.lang.String objectPath)
Parse xml http body for CompleteMultipartUploadRequest.
|
static void |
S3RestUtils.populateTaggingInXAttr(java.util.Map<java.lang.String,com.google.protobuf.ByteString> xattrMap,
java.lang.String taggingHeader,
S3AuditContext auditContext,
java.lang.String objectPath)
Populate xattr map with tagging info from tagging header.
|
void |
S3Handler.rejectUnsupportedResources()
Reject unsupported request from the given subresources from request.
|
java.util.List<URIStatus> |
S3ObjectTask.CompleteMultipartUploadTask.validateParts(CompleteMultipartUploadRequest request,
java.lang.String objectPath,
AlluxioURI multipartTemporaryDir)
Validate the parts as part of this multipart uplaod request.
|
java.util.List<URIStatus> |
CompleteMultipartUploadHandler.CompleteMultipartUploadTask.validateParts(CompleteMultipartUploadRequest request,
java.lang.String objectPath,
AlluxioURI multipartTemporaryDir)
Validate the parts as part of this multipart uplaod request.
|
| Constructor and Description |
|---|
ListBucketResult(java.lang.String bucketName,
java.util.List<URIStatus> children,
ListBucketOptions options)
Creates an
ListBucketResult. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
Authenticator.isAuthenticated(AwsAuthInfo authInfo)
Check if the AwsAuthInfo is legal.
|
boolean |
PassAllAuthenticator.isAuthenticated(AwsAuthInfo authInfo) |
| Modifier and Type | Method and Description |
|---|---|
static java.lang.String |
StringToSignProducer.buildCanonicalRequest(java.lang.String schema,
java.lang.String method,
java.lang.String uri,
java.lang.String signedHeaders,
java.util.Map<java.lang.String,java.lang.String> headers,
java.util.Map<java.lang.String,java.lang.String> queryParams,
boolean unsignedPayload)
Convert request info to a format string.
|
static AwsCredential |
AwsCredential.create(java.lang.String credential)
Parse credential value.
|
AwsAuthInfo |
AwsSignatureProcessor.getAuthInfo()
Convert SignatureInfo to AwsAuthInfo.
|
SignatureInfo |
AwsSignatureProcessor.parseSignature()
Extract signature info from request.
|
static void |
AwsCredential.validateDateRange(java.lang.String credential,
java.lang.String dateString)
validate credential info.
|
| Modifier and Type | Method and Description |
|---|---|
static SignatureInfo |
AwsAuthV4QueryParserUtils.parseSignature(java.util.Map<java.lang.String,java.lang.String> queryParameters)
Function to parse signature.
|
static SignatureInfo |
AwsAuthV2HeaderParserUtils.parseSignature(java.lang.String authHeader)
Function to parse signature.
|
static SignatureInfo |
AwsAuthV4HeaderParserUtils.parseSignature(java.lang.String authHeader,
java.lang.String dateHeader)
Function to parse signature.
|
Copyright © 2024. All Rights Reserved.