Package | Description |
---|---|
alluxio.proxy.s3 | |
alluxio.s3 | |
alluxio.s3.auth | |
alluxio.s3.signature | |
alluxio.s3.signature.utils | |
alluxio.worker.s3 |
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<String,Boolean> bucketPathCache)
Check if a path in alluxio is a directory.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static S3Exception |
NettyRestUtils.toBucketS3Exception(Exception exception,
String resource,
S3AuditContext auditContext)
Convert an exception to instance of
S3Exception . |
static S3Exception |
NettyRestUtils.toObjectS3Exception(Exception exception,
String resource,
S3AuditContext auditContext)
Convert an exception to instance of
S3Exception . |
Modifier and Type | Method and Description |
---|---|
static io.netty.handler.codec.http.HttpResponse |
S3ErrorResponse.createNettyErrorResponse(S3Exception e,
String resource)
Creates an error response using the given exception.
|
Modifier and Type | Method and Description |
---|---|
T |
NettyRestUtils.RestCallable.call()
The REST endpoint implementation.
|
static String |
ListBucketResult.decodeToken(String token)
Decode a continuation token which is used in get Bucket.
|
static String |
NettyRestUtils.getUser(io.netty.handler.codec.http.HttpRequest request)
Get username from header info from FullHttpRequest.
|
static String |
NettyRestUtils.getUserFromAuthorization(String authorization,
AlluxioConfiguration conf)
Gets the user from the authorization header string for AWS Signature Version 4.
|
Constructor and Description |
---|
ListBucketResult(String bucketName,
List<URIStatus> children,
ListBucketOptions options)
Creates an
ListBucketResult . |
Modifier and Type | Method and Description |
---|---|
boolean |
PassAllAuthenticator.isAuthenticated(AwsAuthInfo authInfo) |
boolean |
Authenticator.isAuthenticated(AwsAuthInfo authInfo)
Check if the AwsAuthInfo is legal.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static void |
S3NettyHandler.checkPathIsAlluxioDirectory(FileSystem fs,
String bucketPath,
S3AuditContext auditContext)
Check if a path in alluxio is a directory.
|
static S3NettyObjectTask |
S3NettyObjectTask.Factory.create(S3NettyHandler handler)
Marshall the request and create corresponding object level S3 task.
|
AlluxioURI |
S3NettyHandler.getUfsPath(AlluxioURI objectPath)
Gets UFS full path from Alluxio path.
|
void |
S3NettyHandler.rejectUnsupportedResources()
Reject unsupported request from the given subresources from request.
|
Copyright © 2023. All Rights Reserved.