Home
last modified time | relevance | path

Searched refs:syncClient (Results 1 – 13 of 13) sorted by relevance

/external/aws-sdk-java-v2/services/s3/src/it/java/software/amazon/awssdk/services/s3/signer/
DPayloadSigningIntegrationTest.java75 S3Client syncClient = s3ClientBuilder() in standardSyncApacheHttpClient_unsignedPayload() local
78 assertThat(syncClient.putObject(b -> b.bucket(BUCKET).key(KEY), in standardSyncApacheHttpClient_unsignedPayload()
82 syncClient.close(); in standardSyncApacheHttpClient_unsignedPayload()
87 S3Client syncClient = s3ClientBuilder() in standardSyncApacheHttpClient_httpCauses_signedPayload() local
91 assertThat(syncClient.putObject(b -> b.bucket(BUCKET).key(KEY), in standardSyncApacheHttpClient_httpCauses_signedPayload()
95 syncClient.close(); in standardSyncApacheHttpClient_httpCauses_signedPayload()
100 S3Client syncClient = s3ClientBuilder() in standardSyncApacheHttpClient_manuallyEnabled_signedPayload() local
105 assertThat(syncClient.putObject(b -> b.bucket(BUCKET).key(KEY), in standardSyncApacheHttpClient_manuallyEnabled_signedPayload()
109 syncClient.close(); in standardSyncApacheHttpClient_manuallyEnabled_signedPayload()
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/
DOverrideConfigurationTest.java47 RestJsonEndpointProvidersClient syncClient = syncClientBuilder() in sync_clientOverrideConfiguration_isAddedToRequest() local
51 assertThatThrownBy(() -> syncClient.allTypes(r -> {})) in sync_clientOverrideConfiguration_isAddedToRequest()
59 RestJsonEndpointProvidersClient syncClient = syncClientBuilder().build(); in sync_requestOverrideConfiguration_isAddedToRequest() local
60 …assertThatThrownBy(() -> syncClient.allTypes(r -> r.overrideConfiguration(c -> c.putHeader("K1", "… in sync_requestOverrideConfiguration_isAddedToRequest()
70 RestJsonEndpointProvidersAsyncClient syncClient = asyncClientBuilder() in async_clientOverrideConfiguration_isAddedToRequest() local
74 assertThatThrownBy(() -> syncClient.allTypes(r -> {}).join()) in async_clientOverrideConfiguration_isAddedToRequest()
82 RestJsonEndpointProvidersAsyncClient syncClient = asyncClientBuilder().build(); in async_requestOverrideConfiguration_isAddedToRequest() local
83 …assertThatThrownBy(() -> syncClient.allTypes(r -> r.overrideConfiguration(c -> c.putHeader("K1", "… in async_requestOverrideConfiguration_isAddedToRequest()
DOverrideConfigurationPluginsTest.java48 RestJsonEndpointProvidersClient syncClient = syncClientBuilder() in sync_pluginsClientOverrideConfiguration_isAddedToRequest() local
52 assertThatThrownBy(() -> syncClient.allTypes(r -> { in sync_pluginsClientOverrideConfiguration_isAddedToRequest()
61 RestJsonEndpointProvidersClient syncClient = syncClientBuilder().build(); in sync_pluginsRequestOverrideConfiguration_isAddedToRequest() local
63 …assertThatThrownBy(() -> syncClient.allTypes(r -> r.overrideConfiguration(c -> c.addPlugin(plugin)… in sync_pluginsRequestOverrideConfiguration_isAddedToRequest()
71 RestJsonEndpointProvidersAsyncClient syncClient = asyncClientBuilder() in async_pluginsClientOverrideConfiguration_isAddedToRequest() local
75 assertThatThrownBy(() -> syncClient.allTypes(r -> { in async_pluginsClientOverrideConfiguration_isAddedToRequest()
84 RestJsonEndpointProvidersAsyncClient syncClient = asyncClientBuilder().build(); in async_pluginsRequestOverrideConfiguration_isAddedToRequest() local
86 …assertThatThrownBy(() -> syncClient.allTypes(r -> r.overrideConfiguration(c -> c.addPlugin(plugin)… in async_pluginsRequestOverrideConfiguration_isAddedToRequest()
DRequestCompressionTest.java53 private ProtocolRestJsonClient syncClient; field in RequestCompressionTest
60 syncClient = ProtocolRestJsonClient.builder() in setUp()
88 syncClient.putOperationWithRequestCompression(request); in syncNonStreamingOperation_compressionEnabledThresholdOverridden_compressesCorrectly()
108 syncClient.putOperationWithRequestCompression(request); in syncNonStreamingOperation_payloadSizeLessThanCompressionThreshold_doesNotCompress()
124syncClient.putOperationWithStreamingRequestCompression(request, requestBody, ResponseTransformer.t… in syncStreamingOperation_compressionEnabled_compressesCorrectly()
147 syncClient.putOperationWithRequestCompression(request); in syncNonStreamingOperation_compressionEnabledThresholdOverriddenWithRetry_compressesCorrectly()
166syncClient.putOperationWithStreamingRequestCompression(request, requestBody, ResponseTransformer.t… in syncStreamingOperation_compressionEnabledWithRetry_compressesCorrectly()
DSraIdentityResolutionTest.java54 ProtocolQueryClient syncClient = ProtocolQueryClient in testIdentityPropertyBasedResolutionIsUsedAndNotAnotherIdentityResolution() local
62 assertThatThrownBy(() -> syncClient.allTypes(r -> {})).hasMessageContaining("boom"); in testIdentityPropertyBasedResolutionIsUsedAndNotAnotherIdentityResolution()
DSraIdentityResolutionUsingRequestPluginsTest.java58 ProtocolQueryClient syncClient = ProtocolQueryClient in testIdentityBasedPluginsResolutionIsUsedAndNotAnotherIdentityResolution() local
66 assertThatThrownBy(() -> syncClient.allTypes(request)) in testIdentityBasedPluginsResolutionIsUsedAndNotAnotherIdentityResolution()
DSraIdentityResolutionUsingPluginsTest.java60 ProtocolQueryClient syncClient = ProtocolQueryClient in testIdentityBasedPluginsResolutionIsUsedAndNotAnotherIdentityResolution() local
68 assertThatThrownBy(() -> syncClient.allTypes(r -> {})).hasMessageContaining("boom"); in testIdentityBasedPluginsResolutionIsUsedAndNotAnotherIdentityResolution()
/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/
DEndpointOverrideConfigurationTest.java52 S3Client syncClient = syncClientBuilder() in testClientEndpointOverrideIsUsed() local
56 assertThatThrownBy(() -> syncClient.getObject(r -> { in testClientEndpointOverrideIsUsed()
67 S3Client syncClient = syncClientBuilder() in testRequestEndpointOverrideIsUsed() local
70 assertThatThrownBy(() -> syncClient.getObject(r -> { in testRequestEndpointOverrideIsUsed()
82 S3AsyncClient syncClient = asyncClientBuilder() in testAsyncClientEndpointOverrideIsUsed() local
86 assertThatThrownBy(() -> syncClient.getObject(r -> { in testAsyncClientEndpointOverrideIsUsed()
97 S3AsyncClient syncClient = asyncClientBuilder() in testAsyncRequestEndpointOverrideIsUsed() local
101 assertThatThrownBy(() -> syncClient.getObject(r -> { in testAsyncRequestEndpointOverrideIsUsed()
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/protocolquery/
DMoveQueryParamsToBodyTest.java63 private ProtocolQueryClient syncClient; field in MoveQueryParamsToBodyTest
78 if (syncClient != null) { in teardown()
79 syncClient.close(); in teardown()
81 syncClient = null; in teardown()
105 syncClient = ProtocolQueryClient.builder() in customInterceptor_syncClient_additionalQueryParamsAdded_paramsAlsoMovedToBody()
114 assertThatThrownBy(() -> syncClient.membersInQueryParams(r -> r.stringQueryParam("hello"))) in customInterceptor_syncClient_additionalQueryParamsAdded_paramsAlsoMovedToBody()
140 syncClient = ProtocolQueryClient.builder() in requestOverrideConfiguration_syncClient_additionalQueryParamsAdded_paramsAlsoMovedToBody()
148 assertThatThrownBy(() -> syncClient.membersInQueryParams(r -> r.stringQueryParam("hello") in requestOverrideConfiguration_syncClient_additionalQueryParamsAdded_paramsAlsoMovedToBody()
174 syncClient = ProtocolQueryClient.builder() in syncClient_noQueryParamsAdded_onlyContainsOriginalContent()
182 assertThatThrownBy(() -> syncClient.allTypes(r -> r.stringMember("hello"))) in syncClient_noQueryParamsAdded_onlyContainsOriginalContent()
/external/aws-sdk-java-v2/test/protocol-tests/src/test/java/software/amazon/awssdk/protocol/tests/
DXmlPayloadStringTest.java45 private ProtocolRestXmlClient syncClient; field in XmlPayloadStringTest
51 syncClient = ProtocolRestXmlClient.builder() in setUp()
70 …OperationWithExplicitPayloadStringResponse response = syncClient.operationWithExplicitPayloadStrin… in operationWithExplicitPayloadString_xml_marshallsAndUnmarshallsCorrectly()
87 …OperationWithExplicitPayloadStringResponse response = syncClient.operationWithExplicitPayloadStrin… in operationWithExplicitPayloadString_nonXml_marshallsAndUnmarshallsCorrectly()
104 …OperationWithExplicitPayloadBlobResponse response = syncClient.operationWithExplicitPayloadBlob(re… in operationWithExplicitPayloadBlob_xml_marshallsAndUnmarshallsCorrectly()
121 …OperationWithExplicitPayloadBlobResponse response = syncClient.operationWithExplicitPayloadBlob(re… in operationWithExplicitPayloadBlob_nonXml_marshallsAndUnmarshallsCorrectly()
/external/aws-sdk-java-v2/services/mediastoredata/src/it/java/software/amazon/awssdk/services/mediastoredata/
DRequestCompressionStreamingIntegrationTest.java52 private static MediaStoreDataClient syncClient; field in RequestCompressionStreamingIntegrationTest
71 syncClient = MediaStoreDataClient.builder() in setup()
110 syncClient.deleteObject(deleteObjectRequest); in tearDown()
121syncClient.putObject(putObjectRequest, RequestBody.fromContentProvider(provider, "binary/octet-str… in putObject_withSyncStreamingRequestCompression_compressesPayloadAndSendsCorrectly()
126 ResponseInputStream<GetObjectResponse> response = syncClient.getObject(getObjectRequest); in putObject_withSyncStreamingRequestCompression_compressesPayloadAndSendsCorrectly()
141 ResponseInputStream<GetObjectResponse> response = syncClient.getObject(getObjectRequest); in putObject_withAsyncStreamingRequestCompression_compressesPayloadAndSendsCorrectly()
/external/aws-sdk-java-v2/codegen/src/main/java/software/amazon/awssdk/codegen/model/intermediate/
DMetadata.java40 private String syncClient; field in Metadata
221 return syncClient; in getSyncClient()
224 public void setSyncClient(String syncClient) { in setSyncClient() argument
225 this.syncClient = syncClient; in setSyncClient()
228 public Metadata withSyncClient(String syncClient) { in withSyncClient() argument
229 setSyncClient(syncClient); in withSyncClient()
/external/aws-sdk-java-v2/services/s3/src/test/java/software/amazon/awssdk/services/s3/functionaltests/
DS3ExpressTest.java148 S3Client syncClient = getSyncClient(protocol, wm, s3ExpressSessionAuth); in operation_withChecksumRequired_CalculatesCrc32InsteadOfMD5() local
154 syncClient.deleteObjects(requestBuilder.build()); in operation_withChecksumRequired_CalculatesCrc32InsteadOfMD5()
180 S3Client syncClient = getSyncClient(protocol, wm, s3ExpressSessionAuth); in operation_withoutChecksumTrait() local
182 syncClient.createBucket(request); in operation_withoutChecksumTrait()