Apache
/
jclouds
mirror of https://github.com/apache/jclouds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Memoize Swift TempURL keys 

This avoids a round-trip to the server for every signed URL.
This commit is contained in:
Andrew Gaul 2013-03-12 17:22:00 -07:00
parent b82cf36018
commit 05b443fe4d
1 changed files with 26 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
apis/swift/src/main/java/org/jclouds/openstack/swift/blobstore/config/TemporaryUrlExtensionModule.java
View File

@ -19,6 +19,10 @@
package org.jclouds.openstack.swift.blobstore.config;
import static org.jclouds.rest.config.BinderUtils.bindClientAndAsyncClient;
import static org.jclouds.Constants.PROPERTY_SESSION_INTERVAL;
import java.util.concurrent.TimeUnit;
import javax.inject.Singleton;
import org.jclouds.blobstore.BlobRequestSigner;
import org.jclouds.date.TimeStamp;
@ -33,7 +37,10 @@ import org.jclouds.openstack.swift.extensions.TemporaryUrlKeyAsyncApi;
import org.jclouds.openstack.swift.suppliers.ReturnOrFetchTemporaryUrlKey;
import com.google.common.base.Supplier;
import com.google.common.base.Suppliers;
import com.google.inject.AbstractModule;
import com.google.inject.Inject;
import com.google.inject.name.Named;
import com.google.inject.Provides;
import com.google.inject.TypeLiteral;
@ -85,7 +92,24 @@ public abstract class TemporaryUrlExtensionModule<A extends CommonSwiftAsyncClie
bindRequestSigner();
bindTemporaryUrlKeyApi();
bind(new TypeLiteral<Supplier<String>>() {
}).annotatedWith(TemporaryUrlKey.class).to(ReturnOrFetchTemporaryUrlKey.class);
}).annotatedWith(TemporaryUrlKey.class).to(ReturnOrFetchTemporaryUrlKeyMemoized.class);
}
@Singleton
private static class ReturnOrFetchTemporaryUrlKeyMemoized implements Supplier<String> {
private final Supplier<String> delegate;
@Inject
private ReturnOrFetchTemporaryUrlKeyMemoized(TemporaryUrlKeyApi client,
@Named(PROPERTY_SESSION_INTERVAL) long sessionInterval) {
this.delegate = Suppliers.memoizeWithExpiration(
new ReturnOrFetchTemporaryUrlKey(client), sessionInterval, TimeUnit.SECONDS);
}
@Override
public String get() {
return delegate.get();
}
}
protected abstract void bindRequestSigner();
@ -94,4 +118,4 @@ public abstract class TemporaryUrlExtensionModule<A extends CommonSwiftAsyncClie
bindClientAndAsyncClient(binder(), TemporaryUrlKeyApi.class, TemporaryUrlKeyAsyncApi.class);
}
}
}