Package | Description |
---|---|
net.rubyeye.xmemcached |
XMemcached's main classes and interfaces,use these classes/interfaces to interact with memcached servers.
|
net.rubyeye.xmemcached.command |
Memcached protocol implementations
|
net.rubyeye.xmemcached.command.binary |
Memcached text protocol implementations
|
net.rubyeye.xmemcached.command.kestrel |
Kestrel protocol implementations
|
net.rubyeye.xmemcached.command.text |
Memcached text protocol implementations
|
net.rubyeye.xmemcached.transcoders |
Transcoders convert data to and from data and flags,from spymemcached
|
net.rubyeye.xmemcached.utils |
XMemcached Utilities
|
Modifier and Type | Field and Description |
---|---|
protected Transcoder |
XMemcachedClientBuilder.transcoder |
Modifier and Type | Method and Description |
---|---|
Transcoder |
MemcachedClientBuilder.getTranscoder()
Set xmemcached's transcoder,it is used for seriailizing
|
Transcoder |
MemcachedClient.getTranscoder()
return default transcoder,default is SerializingTranscoder
|
Transcoder |
XMemcachedClient.getTranscoder() |
Transcoder |
XMemcachedClientBuilder.getTranscoder() |
Modifier and Type | Method and Description |
---|---|
<T> boolean |
MemcachedClient.add(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> boolean |
XMemcachedClient.add(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> boolean |
MemcachedClient.add(String key,
int exp,
T value,
Transcoder<T> transcoder,
long timeout)
Add key-value item to memcached, success only when the key is not exists in memcached.
|
<T> boolean |
XMemcachedClient.add(String key,
int exp,
T value,
Transcoder<T> transcoder,
long timeout) |
<T> void |
MemcachedClient.addWithNoReply(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> void |
XMemcachedClient.addWithNoReply(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> boolean |
MemcachedClient.cas(String key,
int exp,
CASOperation<T> operation,
Transcoder<T> transcoder)
Cas is a check and set operation which means "store this data but only if no one else has
updated since I last fetched it."
|
<T> boolean |
XMemcachedClient.cas(String key,
int exp,
CASOperation<T> operation,
Transcoder<T> transcoder) |
<T> boolean |
MemcachedClient.cas(String key,
int exp,
GetsResponse<T> getsReponse,
CASOperation<T> operation,
Transcoder<T> transcoder)
cas is a check and set operation which means "store this data but only if no one else has
updated since I last fetched it."
|
<T> boolean |
XMemcachedClient.cas(String key,
int exp,
GetsResponse<T> getsReponse,
CASOperation<T> operation,
Transcoder<T> transcoder) |
<T> boolean |
MemcachedClient.cas(String key,
int exp,
T value,
Transcoder<T> transcoder,
long cas) |
<T> boolean |
XMemcachedClient.cas(String key,
int exp,
T value,
Transcoder<T> transcoder,
long cas) |
<T> boolean |
MemcachedClient.cas(String key,
int exp,
T value,
Transcoder<T> transcoder,
long timeout,
long cas)
Cas is a check and set operation which means "store this data but only if no one else has
updated since I last fetched it."
|
<T> boolean |
XMemcachedClient.cas(String key,
int exp,
T value,
Transcoder<T> transcoder,
long timeout,
long cas) |
Command |
CommandFactory.createAddCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder)
create a add command
|
Command |
CommandFactory.createAppendCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder)
create a append command
|
Command |
CommandFactory.createCASCommand(String key,
byte[] keyBytes,
int exp,
Object value,
long cas,
boolean noreply,
Transcoder transcoder)
Create a cas command
|
Command |
CommandFactory.createGetCommand(String key,
byte[] keyBytes,
CommandType cmdType,
Transcoder transcoder)
create a get/gets command
|
<T> Command |
CommandFactory.createGetMultiCommand(Collection<String> keys,
CountDownLatch latch,
CommandType cmdType,
Transcoder<T> transcoder)
Create a multi-get command
|
Command |
CommandFactory.createPrependCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder)
Create a prepend command
|
Command |
CommandFactory.createReplaceCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder)
create a replace command
|
Command |
CommandFactory.createSetCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder)
Create a set command
|
<T> Map<String,T> |
MemcachedClient.get(Collection<String> keyCollections,
long opTimeout,
Transcoder<T> transcoder)
Bulk get items
|
<T> Map<String,T> |
XMemcachedClient.get(Collection<String> keyCollections,
long timeout,
Transcoder<T> transcoder) |
<T> Map<String,T> |
MemcachedClient.get(Collection<String> keyCollections,
Transcoder<T> transcoder) |
<T> Map<String,T> |
XMemcachedClient.get(Collection<String> keyCollections,
Transcoder<T> transcoder) |
<T> T |
MemcachedClient.get(String key,
long timeout,
Transcoder<T> transcoder)
Get value by key
|
<T> T |
XMemcachedClient.get(String key,
long timeout,
Transcoder<T> transcoder) |
<T> T |
MemcachedClient.get(String key,
Transcoder<T> transcoder) |
<T> T |
XMemcachedClient.get(String key,
Transcoder<T> transcoder) |
<T> Map<String,GetsResponse<T>> |
MemcachedClient.gets(Collection<String> keyCollections,
long opTime,
Transcoder<T> transcoder)
Bulk gets items
|
<T> Map<String,GetsResponse<T>> |
XMemcachedClient.gets(Collection<String> keyCollections,
long timeout,
Transcoder<T> transcoder) |
<T> Map<String,GetsResponse<T>> |
MemcachedClient.gets(Collection<String> keyCollections,
Transcoder<T> transcoder) |
<T> Map<String,GetsResponse<T>> |
XMemcachedClient.gets(Collection<String> keyCollections,
Transcoder<T> transcoder) |
<T> GetsResponse<T> |
MemcachedClient.gets(String key,
long timeout,
Transcoder<T> transcoder)
Just like get,But it return a GetsResponse,include cas value for cas update.
|
<T> GetsResponse<T> |
XMemcachedClient.gets(String key,
long timeout,
Transcoder<T> transcoder) |
<T> GetsResponse<T> |
MemcachedClient.gets(String key,
Transcoder transcoder) |
<T> GetsResponse<T> |
XMemcachedClient.gets(String key,
Transcoder transcoder) |
<T> boolean |
MemcachedClient.replace(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> boolean |
XMemcachedClient.replace(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> boolean |
MemcachedClient.replace(String key,
int exp,
T value,
Transcoder<T> transcoder,
long timeout)
Replace the key's data item in memcached,success only when the key's data item is exists in
memcached.This method will wait for reply from server.
|
<T> boolean |
XMemcachedClient.replace(String key,
int exp,
T value,
Transcoder<T> transcoder,
long timeout) |
<T> void |
MemcachedClient.replaceWithNoReply(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> void |
XMemcachedClient.replaceWithNoReply(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> boolean |
MemcachedClient.set(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> boolean |
XMemcachedClient.set(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> boolean |
MemcachedClient.set(String key,
int exp,
T value,
Transcoder<T> transcoder,
long timeout)
Store key-value item to memcached
|
<T> boolean |
XMemcachedClient.set(String key,
int exp,
T value,
Transcoder<T> transcoder,
long timeout) |
void |
MemcachedClientBuilder.setTranscoder(Transcoder transcoder) |
void |
MemcachedClient.setTranscoder(Transcoder transcoder)
set transcoder
|
void |
XMemcachedClient.setTranscoder(Transcoder transcoder) |
void |
XMemcachedClientBuilder.setTranscoder(Transcoder transcoder) |
<T> void |
MemcachedClient.setWithNoReply(String key,
int exp,
T value,
Transcoder<T> transcoder) |
<T> void |
XMemcachedClient.setWithNoReply(String key,
int exp,
T value,
Transcoder<T> transcoder) |
Constructor and Description |
---|
XMemcachedClient(MemcachedSessionLocator locator,
MemcachedSessionComparator comparator,
BufferAllocator allocator,
Configuration conf,
Map<SocketOption,Object> socketOptions,
CommandFactory commandFactory,
Transcoder transcoder,
Map<InetSocketAddress,InetSocketAddress> addressMap,
List<MemcachedClientStateListener> stateListeners,
Map<InetSocketAddress,AuthInfo> map,
int poolSize,
long connectTimeout,
String name,
boolean failureMode,
boolean resolveInetAddresses)
XMemcachedClient constructor.Every server's weight is one by default.
|
Modifier and Type | Field and Description |
---|---|
protected Transcoder |
Command.transcoder |
Modifier and Type | Method and Description |
---|---|
Transcoder |
Command.getTranscoder() |
Modifier and Type | Method and Description |
---|---|
Command |
TextCommandFactory.createAddCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
KestrelCommandFactory.createAddCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
BinaryCommandFactory.createAddCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
TextCommandFactory.createAppendCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
KestrelCommandFactory.createAppendCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
BinaryCommandFactory.createAppendCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
TextCommandFactory.createCASCommand(String key,
byte[] keyBytes,
int exp,
Object value,
long cas,
boolean noreply,
Transcoder transcoder) |
Command |
KestrelCommandFactory.createCASCommand(String key,
byte[] keyBytes,
int exp,
Object value,
long cas,
boolean noreply,
Transcoder transcoder) |
Command |
BinaryCommandFactory.createCASCommand(String key,
byte[] keyBytes,
int exp,
Object value,
long cas,
boolean noreply,
Transcoder transcoder) |
Command |
TextCommandFactory.createGetCommand(String key,
byte[] keyBytes,
CommandType cmdType,
Transcoder transcoder) |
Command |
KestrelCommandFactory.createGetCommand(String key,
byte[] keyBytes,
CommandType cmdType,
Transcoder transcoder) |
Command |
BinaryCommandFactory.createGetCommand(String key,
byte[] keyBytes,
CommandType cmdType,
Transcoder transcoder) |
<T> Command |
TextCommandFactory.createGetMultiCommand(Collection<String> keys,
CountDownLatch latch,
CommandType cmdType,
Transcoder<T> transcoder) |
<T> Command |
KestrelCommandFactory.createGetMultiCommand(Collection<String> keys,
CountDownLatch latch,
CommandType cmdType,
Transcoder<T> transcoder) |
<T> Command |
BinaryCommandFactory.createGetMultiCommand(Collection<String> keys,
CountDownLatch latch,
CommandType cmdType,
Transcoder<T> transcoder) |
Command |
TextCommandFactory.createPrependCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
KestrelCommandFactory.createPrependCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
BinaryCommandFactory.createPrependCommand(String key,
byte[] keyBytes,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
TextCommandFactory.createReplaceCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
KestrelCommandFactory.createReplaceCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
BinaryCommandFactory.createReplaceCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
TextCommandFactory.createSetCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
KestrelCommandFactory.createSetCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
Command |
BinaryCommandFactory.createSetCommand(String key,
byte[] keyBytes,
int exp,
Object value,
boolean noreply,
Transcoder transcoder) |
void |
Command.setTranscoder(Transcoder transcoder) |
Modifier and Type | Method and Description |
---|---|
Transcoder |
BaseBinaryCommand.getTranscoder() |
Modifier and Type | Method and Description |
---|---|
void |
BaseBinaryCommand.setTranscoder(Transcoder transcoder) |
Constructor and Description |
---|
BaseBinaryCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
int exp,
long cas,
Object value,
boolean noreply,
Transcoder transcoder) |
BinaryAppendPrependCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
int exp,
long cas,
Object value,
boolean noreply,
Transcoder transcoder) |
BinaryCASCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
int exp,
long cas,
Object value,
boolean noreply,
Transcoder transcoder) |
BinaryStoreCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
int exp,
long cas,
Object value,
boolean noreply,
Transcoder transcoder) |
Constructor and Description |
---|
KestrelGetCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
Transcoder<?> transcoder) |
KestrelSetCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
int exp,
long cas,
Object value,
boolean noreply,
Transcoder transcoder) |
Modifier and Type | Method and Description |
---|---|
Transcoder |
TextStoreCommand.getTranscoder() |
Modifier and Type | Method and Description |
---|---|
void |
TextStoreCommand.setTranscoder(Transcoder transcoder) |
Constructor and Description |
---|
TextCASCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
int exp,
long cas,
Object value,
boolean noreply,
Transcoder transcoder) |
TextGetMultiCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
Transcoder transcoder) |
TextStoreCommand(String key,
byte[] keyBytes,
CommandType cmdType,
CountDownLatch latch,
int exp,
long cas,
Object value,
boolean noreply,
Transcoder transcoder) |
Modifier and Type | Class and Description |
---|---|
class |
IntegerTranscoder
Transcoder that serializes and unserializes longs.
|
class |
LongTranscoder
Transcoder that serializes and unserializes longs.
|
class |
PrimitiveTypeTranscoder<T> |
class |
SerializingTranscoder
Transcoder that serializes and compresses objects.
|
class |
StringTranscoder
String Transcoder
|
class |
TokyoTyrantTranscoder
Transcoder for TokyoTyrant.Add 4-bytes flag before value.
|
class |
WhalinTranscoder
Transcoder that provides compatibility with Greg Whalin's memcached client.
|
class |
WhalinV1Transcoder
Handles old whalin (tested with v1.6) encoding: data type is in the first byte of the value.
|
Modifier and Type | Method and Description |
---|---|
Transcoder |
XMemcachedClientFactoryBean.getTranscoder() |
Modifier and Type | Method and Description |
---|---|
void |
XMemcachedClientFactoryBean.setTranscoder(Transcoder transcoder) |
Copyright © 2021. All rights reserved.