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