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

HTTPCLIENT-2202: MemcachedHttpCacheStorage to support MemcachedClientIF interface

This commit is contained in:
Oleg Kalnichevski 2022-02-10 20:33:05 +01:00
parent 8881ef4b3f
commit b9a6b5ed89
1 changed files with 34 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
httpclient5-cache/src/main/java/org/apache/hc/client5/http/impl/cache/memcached/MemcachedHttpCacheStorage.java vendored
View File

@ -42,6 +42,7 @@ import org.apache.hc.core5.util.Args;
import net.spy.memcached.CASResponse; import net.spy.memcached.CASResponse;
import net.spy.memcached.CASValue; import net.spy.memcached.CASValue;
import net.spy.memcached.MemcachedClient; import net.spy.memcached.MemcachedClient;
import net.spy.memcached.MemcachedClientIF;
import net.spy.memcached.OperationTimeoutException; import net.spy.memcached.OperationTimeoutException;
/** /**
@ -84,7 +85,7 @@ import net.spy.memcached.OperationTimeoutException;
*/ */
public class MemcachedHttpCacheStorage extends AbstractBinaryCacheStorage<CASValue<Object>> { public class MemcachedHttpCacheStorage extends AbstractBinaryCacheStorage<CASValue<Object>> {
private final MemcachedClient client; private final MemcachedClientIF client;
private final KeyHashingScheme keyHashingScheme; private final KeyHashingScheme keyHashingScheme;
/** /**
@ -108,6 +109,18 @@ public class MemcachedHttpCacheStorage extends AbstractBinaryCacheStorage<CASVal
this(cache, CacheConfig.DEFAULT, ByteArrayCacheEntrySerializer.INSTANCE, SHA256KeyHashingScheme.INSTANCE); this(cache, CacheConfig.DEFAULT, ByteArrayCacheEntrySerializer.INSTANCE, SHA256KeyHashingScheme.INSTANCE);
} }
/**
* Create a storage backend using the pre-configured given
* <i>memcached</i> client.
*
* @param cache client to use for communicating with <i>memcached</i>
*
* @since 5.2
*/
public MemcachedHttpCacheStorage(final MemcachedClientIF cache) {
this(cache, CacheConfig.DEFAULT, ByteArrayCacheEntrySerializer.INSTANCE, SHA256KeyHashingScheme.INSTANCE);
}
/** /**
* Create a storage backend using the given <i>memcached</i> client and * Create a storage backend using the given <i>memcached</i> client and
* applying the given cache configuration, serialization, and hashing * applying the given cache configuration, serialization, and hashing
@ -123,6 +136,26 @@ public class MemcachedHttpCacheStorage extends AbstractBinaryCacheStorage<CASVal
final CacheConfig config, final CacheConfig config,
final HttpCacheEntrySerializer<byte[]> serializer, final HttpCacheEntrySerializer<byte[]> serializer,
final KeyHashingScheme keyHashingScheme) { final KeyHashingScheme keyHashingScheme) {
this((MemcachedClientIF) client, config, serializer, keyHashingScheme);
}
/**
* Create a storage backend using the given <i>memcached</i> client and
* applying the given cache configuration, serialization, and hashing
* mechanisms.
*
* @param client how to talk to <i>memcached</i>
* @param config apply HTTP cache-related options
* @param serializer alternative serialization mechanism
* @param keyHashingScheme how to map higher-level logical "storage keys"
* onto "cache keys" suitable for use with memcached
* @since 5.2
*/
public MemcachedHttpCacheStorage(
final MemcachedClientIF client,
final CacheConfig config,
final HttpCacheEntrySerializer<byte[]> serializer,
final KeyHashingScheme keyHashingScheme) {
super((config != null ? config : CacheConfig.DEFAULT).getMaxUpdateRetries(), super((config != null ? config : CacheConfig.DEFAULT).getMaxUpdateRetries(),
serializer != null ? serializer : ByteArrayCacheEntrySerializer.INSTANCE); serializer != null ? serializer : ByteArrayCacheEntrySerializer.INSTANCE);
this.client = Args.notNull(client, "Memcached client"); this.client = Args.notNull(client, "Memcached client");