Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,6 @@ public final class AwsBasicCredentials implements AwsCredentials,
* <p>
* This should be accessed via {@link AnonymousCredentialsProvider#resolveCredentials()}.
*/
// TODO(sra-identity-and-auth): Check if this static member can be removed after cleanup
@SdkInternalApi
static final AwsBasicCredentials ANONYMOUS_CREDENTIALS = builder().validateCredentials(false).build();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -110,7 +110,7 @@ private static AwsCredentialsIdentity resolveCredentials(
MetricCollector metricCollector) {
Validate.notNull(credentialsProvider, "No credentials provider exists to resolve credentials from.");

// TODO(sra-identity-and-auth): internal issue SMITHY-1677. avoid join for async clients.
// TODO(technical-debt-reduction): internal issue JAVA-7739. avoid join for async clients.
Pair<? extends AwsCredentialsIdentity, Duration> measured =
MetricUtils.measureDuration(() -> CompletableFutureUtils.joinLikeSync(credentialsProvider.resolveIdentity()));

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ private static TokenIdentity resolveToken(IdentityProvider<? extends TokenIdenti
MetricCollector metricCollector) {
Validate.notNull(tokenProvider, "No token provider exists to resolve a token from.");

// TODO(sra-identity-and-auth): internal issue SMITHY-1677. avoid join for async clients.
// TODO(technical-debt-reduction): internal issue JAVA-7739. avoid join for async clients.
Pair<TokenIdentity, Duration> measured =
MetricUtils.measureDuration(() -> CompletableFutureUtils.joinLikeSync(tokenProvider.resolveIdentity()));
metricCollector.reportMetric(CoreMetric.TOKEN_FETCH_DURATION, measured.right());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,6 @@
* A container for data produced during and as a result of the SigV4 request signing process.
*/
@SdkInternalApi
// TODO(sra-identity-auth): This is currently not @Immutable because signedRequest is a Builder. Is Builder needed? If it could
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Rationale: immutable is acceptable here since it's an internal class IMO. Using immutable everywhere can help performance impact

// hold reference to SdkHttpRequest instead, this class would be @Immutable.
public final class V4RequestSigningResult {
private final String contentHash;
private final byte[] signingKey;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,9 @@
import software.amazon.awssdk.annotations.SdkInternalApi;

/**
* A subscriber that takes a collection of checksums, and updates each checksum when it receives data.
* A subscriber that takes a collection of checksums, and updates each checksum when it receives data. It buffers the entire data
* in memory. This should only be used by non-streaming operations. Use {@link UnbufferedChecksumSubscriber} instead to avoid
* buffering.
*/
@SdkInternalApi
public final class ChecksumSubscriber implements Subscriber<ByteBuffer> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,7 @@
import software.amazon.awssdk.utils.Validate;

/**
* Temporarily used for buffering all data into memory. TODO(sra-identity-auth): Remove this by supporting chunked encoding. We
* should not buffer everything into memory.
* Temporarily used for buffering all data into memory.
*/
@SdkInternalApi
public class InMemoryPublisher implements Publisher<ByteBuffer> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,10 +43,10 @@
import software.amazon.awssdk.utils.builder.SdkBuilder;

/**
* Wrapper class to wrap an AsyncRequestBody.
* This will read the data in chunk format and append Checksum as trailer at the end.
* TODO(sra-identity-and-auth): Checksum calculating logic for async client is still here and should be in
* "http-auth-aws", more specifically, AwsChunkedV4PayloadSigner#signAsync
* Wrapper class to wrap an AsyncRequestBody to calculate checksum as it reads data and append Checksum as trailer at the end.
*
* <p>
* This is only used by non-sra code path, i.e., when a custom legacy signer is provided.
*/
@SdkInternalApi
public class ChecksumCalculatingAsyncRequestBody implements AsyncRequestBody {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,13 +56,6 @@ void putObject(UploadConfig config) throws Exception {
Assumptions.assumeFalse(config.getBodyType() == BodyType.CONTENT_PROVIDER_WITH_LENGTH,
"No way to create AsyncRequestBody by giving both an Publisher and the content length");

// Payload signing doesn't work correctly for async java based
// TODO(sra-identity-auth) remove when chunked encoding support is added in async code path
// MRAP requires body signing
Assumptions.assumeFalse(
config.isPayloadSigning() || config.getBucketType() == BucketType.MRAP,
"Async payload signing doesn't work with Java based clients");

LOG.info(() -> "Running putObject with config: " + config);

BucketType bucketType = config.getBucketType();
Expand Down
Loading