Package | Description |
---|---|
org.infinispan.client.hotrod.event |
Hot Rod client remote event API.
|
org.infinispan.client.hotrod.impl.operations | |
org.infinispan.client.hotrod.impl.protocol | |
org.infinispan.client.hotrod.impl.transport | |
org.infinispan.client.hotrod.impl.transport.tcp |
Modifier and Type | Method and Description |
---|---|
static ClientListenerNotifier |
ClientListenerNotifier.create(Codec codec,
Marshaller marshaller,
List<String> whitelist) |
Constructor and Description |
---|
ClientListenerNotifier(ExecutorService executor,
Codec codec,
Marshaller marshaller,
List<String> whitelist) |
Modifier and Type | Field and Description |
---|---|
protected Codec |
HotRodOperation.codec |
Constructor and Description |
---|
AbstractKeyOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
AbstractKeyValueOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit) |
AddClientListenerOperation(Codec codec,
TransportFactory transportFactory,
String cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
ClientListenerNotifier listenerNotifier,
Object listener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams) |
AuthMechListOperation(Codec codec,
AtomicInteger topologyId,
Configuration cfg,
Transport transport) |
AuthOperation(Codec codec,
AtomicInteger topologyId,
Configuration cfg,
Transport transport,
String saslMechanism,
byte[] response) |
BulkGetKeysOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
int scope) |
BulkGetOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
int entryCount) |
ClearOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
ContainsKeyOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
ExecuteOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
String taskName,
Map<String,byte[]> marshalledParams) |
FaultTolerantPingOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
GetAllOperation(Codec codec,
TransportFactory transportFactory,
Set<byte[]> keys,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
GetAllParallelOperation(Codec codec,
TransportFactory transportFactory,
Set<byte[]> keys,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
ExecutorService executorService) |
GetOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
GetWithMetadataOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
GetWithVersionOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg)
Deprecated.
|
HotRodOperation(Codec codec,
int flags,
Configuration cfg,
byte[] cacheName,
AtomicInteger topologyId) |
IterationEndOperation(Codec codec,
int flags,
Configuration cfg,
byte[] cacheName,
AtomicInteger topologyId,
String iterationId,
TransportFactory transportFactory,
Transport transport) |
IterationNextOperation(Codec codec,
int flags,
Configuration cfg,
byte[] cacheName,
AtomicInteger topologyId,
String iterationId,
Transport transport,
KeyTracker segmentKeyTracker,
List<String> whitelist) |
OperationsFactory(TransportFactory transportFactory,
Codec codec,
ExecutorService executorService,
Configuration cfg) |
OperationsFactory(TransportFactory transportFactory,
String cacheName,
boolean forceReturnValue,
Codec codec,
ClientListenerNotifier listenerNotifier,
ExecutorService executorService,
Configuration cfg) |
ParallelHotRodOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
ExecutorService executorService) |
PingOperation(Codec codec,
AtomicInteger topologyId,
Configuration cfg,
Transport transport) |
PingOperation(Codec codec,
AtomicInteger topologyId,
Configuration cfg,
Transport transport,
byte[] cacheName) |
PutAllOperation(Codec codec,
TransportFactory transportFactory,
Map<byte[],byte[]> map,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit) |
PutAllParallelOperation(Codec codec,
TransportFactory transportFactory,
Map<byte[],byte[]> map,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
ExecutorService executorService) |
PutIfAbsentOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdleTime,
TimeUnit maxIdleTimeUnit) |
PutOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit) |
QueryOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
RemoteQuery remoteQuery) |
RemoveClientListenerOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
ClientListenerNotifier listenerNotifier,
Object listener) |
RemoveIfUnmodifiedOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
long version) |
RemoveOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
ReplaceIfUnmodifiedOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
long version) |
ReplaceOperation(Codec codec,
TransportFactory transportFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit) |
RetryOnFailureOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
SizeOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
StatsOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg) |
Modifier and Type | Class and Description |
---|---|
class |
Codec10
A Hot Rod encoder/decoder for version 1.0 of the protocol.
|
class |
Codec11
A Hot Rod encoder/decoder for version 1.1 of the protocol.
|
class |
Codec12
A Hot Rod encoder/decoder for version 1.2 of the protocol.
|
class |
Codec13
A Hot Rod encoder/decoder for version 1.3 of the protocol.
|
class |
Codec20
A Hot Rod encoder/decoder for version 2.0 of the protocol.
|
class |
Codec21 |
class |
Codec22 |
class |
Codec23 |
class |
Codec24 |
class |
Codec25 |
Modifier and Type | Method and Description |
---|---|
static Codec |
CodecFactory.getCodec(String version) |
Modifier and Type | Method and Description |
---|---|
void |
TransportFactory.start(Codec codec,
Configuration configuration,
AtomicInteger topologyId,
ClientListenerNotifier listenerNotifier) |
Modifier and Type | Field and Description |
---|---|
protected Codec |
TransportObjectFactory.codec |
Modifier and Type | Method and Description |
---|---|
void |
TcpTransportFactory.start(Codec codec,
Configuration configuration,
AtomicInteger defaultCacheTopologyId,
ClientListenerNotifier listenerNotifier) |
Constructor and Description |
---|
SaslTransportObjectFactory(Codec codec,
TcpTransportFactory tcpTransportFactory,
AtomicInteger defaultCacheTopologyId,
boolean pingOnStartup,
AuthenticationConfiguration authConfiguration,
Configuration configuration) |
TransportObjectFactory(Codec codec,
TcpTransportFactory tcpTransportFactory,
AtomicInteger defaultCacheTopologyId,
boolean pingOnStartup,
Configuration configuration) |
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.