public class S3RestClientModule<S extends S3Client,A extends S3AsyncClient> extends AWSRestClientModule<S,A>
asyncClientType, authException, delegates, syncClientType, URI_SUPPLIER_TYPE
Constructor and Description |
---|
S3RestClientModule(Class<S> sync,
Class<A> async) |
Modifier and Type | Method and Description |
---|---|
protected void |
bindErrorHandlers()
overrides this to change the default error handlers for the http engine
ex.
|
protected void |
bindRetryHandlers()
overrides this to change the default retry handlers for the http engine
ex.
|
protected Map<String,String> |
bucketToRegion() |
protected void |
configure() |
static S3RestClientModule<S3Client,S3AsyncClient> |
create() |
protected com.google.common.base.Supplier<String> |
defaultRegionForBucket(com.google.common.base.Supplier<String> defaultRegion) |
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
|
bindAsyncClient, bindClient, installLocations
addError, addError, addError, bind, bind, bind, bindConstant, binder, bindInterceptor, bindListener, bindScope, configure, convertToTypes, currentStage, getMembersInjector, getMembersInjector, getProvider, getProvider, install, requestInjection, requestStaticInjection, requireBinding, requireBinding
public static S3RestClientModule<S3Client,S3AsyncClient> create()
@Provides @Singleton protected Map<String,String> bucketToRegion()
@Provides @Singleton protected com.google.common.base.Supplier<String> defaultRegionForBucket(com.google.common.base.Supplier<String> defaultRegion)
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>
@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-2012 jclouds. All Rights Reserved.