public class S3RestClientModule<S extends S3Client,A extends S3AsyncClient> extends AWSRestClientModule<S,A>
asyncClientType, syncClientType
authException, URI_SUPPLIER_TYPE
Modifier | Constructor and Description |
---|---|
|
S3RestClientModule() |
protected |
S3RestClientModule(com.google.common.reflect.TypeToken<S> syncClientType,
com.google.common.reflect.TypeToken<A> asyncClientType) |
Modifier and Type | Method and Description |
---|---|
protected void |
bindErrorHandlers()
overrides this to change the default error handlers for the http engine
ex.
|
protected void |
bindRequestSigner() |
protected void |
bindRetryHandlers()
overrides this to change the default retry handlers for the http engine
ex.
|
protected com.google.common.cache.LoadingCache<String,com.google.common.base.Optional<String>> |
bucketToRegion(com.google.common.cache.CacheLoader<String,com.google.common.base.Optional<String>> loader) |
protected com.google.common.cache.CacheLoader<String,com.google.common.base.Optional<String>> |
bucketToRegion(com.google.common.base.Supplier<Set<String>> regionSupplier,
S3Client client) |
protected void |
configure() |
protected com.google.common.base.Supplier<String> |
defaultRegionForBucket(com.google.common.base.Supplier<String> defaultRegion) |
protected com.google.common.base.Supplier<URI> |
provideBucketURI(com.google.common.base.Supplier<String> defaultRegion,
RegionToEndpointOrProviderIfNull regionToEndpoint) |
protected RequestSigner |
provideRequestSigner(RequestAuthorizeSignature in) |
protected String |
provideTimeStamp(com.google.common.base.Supplier<String> cache) |
protected com.google.common.base.Supplier<String> |
provideTimeStampCache(long seconds,
DateService dateService)
borrowing concurrency code to ensure that caching takes place properly
|
provideRetryableCodes, provideRetryableServerCodes
installLocations
addError, addError, addError, bind, bind, bind, bindConstant, binder, bindInterceptor, bindListener, bindScope, configure, convertToTypes, currentStage, getMembersInjector, getMembersInjector, getProvider, getProvider, install, requestInjection, requestStaticInjection, requireBinding, requireBinding
@Provides @Singleton protected com.google.common.cache.CacheLoader<String,com.google.common.base.Optional<String>> bucketToRegion(com.google.common.base.Supplier<Set<String>> regionSupplier, S3Client client)
@Provides @Singleton protected com.google.common.cache.LoadingCache<String,com.google.common.base.Optional<String>> bucketToRegion(com.google.common.cache.CacheLoader<String,com.google.common.base.Optional<String>> loader)
@Provides @Singleton protected com.google.common.base.Supplier<String> defaultRegionForBucket(com.google.common.base.Supplier<String> defaultRegion)
@Provides @Singleton protected com.google.common.base.Supplier<URI> provideBucketURI(com.google.common.base.Supplier<String> defaultRegion, RegionToEndpointOrProviderIfNull regionToEndpoint)
protected void configure()
configure
in class RestClientModule<S extends S3Client,A extends S3AsyncClient>
protected void bindErrorHandlers()
RestClientModule
bind(HttpErrorHandler.class).annotatedWith(Redirection.class).to(ParseAWSErrorFromXmlContent.class); bind(HttpErrorHandler.class).annotatedWith(ClientError.class).to(ParseAWSErrorFromXmlContent.class); bind(HttpErrorHandler.class).annotatedWith(ServerError.class).to(ParseAWSErrorFromXmlContent.class);
bindErrorHandlers
in class AWSRestClientModule<S extends S3Client,A extends S3AsyncClient>
protected void bindRequestSigner()
@Provides @Singleton protected RequestSigner provideRequestSigner(RequestAuthorizeSignature in)
protected void bindRetryHandlers()
RestClientModule
bind(HttpRetryHandler.class).annotatedWith(Redirection.class).to(AWSRedirectionRetryHandler.class); bind(HttpRetryHandler.class).annotatedWith(ClientError.class).to(AWSClientErrorRetryHandler.class);
bindRetryHandlers
in class AWSRestClientModule<S extends S3Client,A extends S3AsyncClient>
@Provides protected String provideTimeStamp(com.google.common.base.Supplier<String> cache)
@Provides @Singleton protected com.google.common.base.Supplier<String> provideTimeStampCache(@Named(value="jclouds.session-interval") long seconds, DateService dateService)
Copyright © 2009-2014 The Apache Software Foundation. All Rights Reserved.