Modifier and Type | Method and Description |
---|---|
DataFormat |
DataFormat.Builder.build() |
DataFormat |
RemoteCache.getDataFormat()
Return the currently
DataFormat being used. |
DataFormat |
DataFormat.withoutValueType() |
Modifier and Type | Method and Description |
---|---|
DataFormat.Builder |
DataFormat.Builder.from(DataFormat dataFormat) |
<T,U> RemoteCache<T,U> |
RemoteCache.withDataFormat(DataFormat dataFormat)
Return a new instance of
RemoteCache using the supplied DataFormat . |
Modifier and Type | Method and Description |
---|---|
DataFormat |
ClientListenerNotifier.getCacheDataFormat(byte[] listenerId) |
protected DataFormat |
ClientEventDispatcher.getDataFormat() |
Modifier and Type | Method and Description |
---|---|
DataFormat |
DelegatingRemoteCache.getDataFormat() |
DataFormat |
RemoteCacheImpl.getDataFormat() |
Modifier and Type | Method and Description |
---|---|
<T,U> InternalRemoteCache<T,U> |
DelegatingRemoteCache.withDataFormat(DataFormat dataFormat) |
<T,U> InternalRemoteCache<T,U> |
InternalRemoteCache.withDataFormat(DataFormat dataFormat) |
<T,U> InternalRemoteCache<T,U> |
RemoteCacheImpl.withDataFormat(DataFormat newDataFormat) |
Constructor and Description |
---|
RemotePublisher(OperationsFactory operationsFactory,
Marshaller marshaller,
String filterConverterFactory,
byte[][] filterParams,
Set<Integer> segments,
int batchSize,
boolean metadata,
DataFormat dataFormat) |
Constructor and Description |
---|
GetKeyMultimapOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
GetKeyWithMetadataMultimapOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
MultimapOperationsFactory(ChannelFactory channelFactory,
String cacheName,
Codec codec,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
PutKeyValueMultimapOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
Modifier and Type | Field and Description |
---|---|
protected DataFormat |
HotRodOperation.dataFormat |
Modifier and Type | Method and Description |
---|---|
DataFormat |
AddClientListenerOperation.getDataFormat() |
Modifier and Type | Method and Description |
---|---|
AddClientListenerOperation |
OperationsFactory.newAddClientListenerOperation(Object listener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams,
DataFormat dataFormat) |
AddClientListenerOperation |
OperationsFactory.newAddClientListenerOperation(Object listener,
DataFormat dataFormat) |
<K> BulkGetKeysOperation<K> |
OperationsFactory.newBulkGetKeysOperation(int scope,
DataFormat dataFormat) |
ContainsKeyOperation |
OperationsFactory.newContainsKeyOperation(Object key,
byte[] keyBytes,
DataFormat dataFormat) |
<T> ExecuteOperation<T> |
OperationsFactory.newExecuteOperation(String taskName,
Map<String,byte[]> marshalledParams,
Object key,
DataFormat dataFormat) |
<K,V> GetAllParallelOperation<K,V> |
OperationsFactory.newGetAllOperation(Set<byte[]> keys,
DataFormat dataFormat) |
<V> GetOperation<V> |
OperationsFactory.newGetKeyOperation(Object key,
byte[] keyBytes,
DataFormat dataFormat) |
<V> GetWithMetadataOperation<V> |
OperationsFactory.newGetWithMetadataOperation(Object key,
byte[] keyBytes,
DataFormat dataFormat) |
<K,E> IterationNextOperation<K,E> |
OperationsFactory.newIterationNextOperation(byte[] iterationId,
io.netty.channel.Channel channel,
KeyTracker segmentKeyTracker,
DataFormat dataFormat) |
IterationStartOperation |
OperationsFactory.newIterationStartOperation(String filterConverterFactory,
byte[][] filterParameters,
IntSet segments,
int batchSize,
boolean metadata,
DataFormat dataFormat,
SocketAddress targetAddress) |
PutAllParallelOperation |
OperationsFactory.newPutAllOperation(Map<byte[],byte[]> map,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat) |
<V> PutIfAbsentOperation<V> |
OperationsFactory.newPutIfAbsentOperation(Object key,
byte[] keyBytes,
byte[] value,
long lifespan,
TimeUnit lifespanUnit,
long maxIdleTime,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat) |
<V> PutOperation<V> |
OperationsFactory.newPutKeyValueOperation(Object key,
byte[] keyBytes,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat) |
QueryOperation |
OperationsFactory.newQueryOperation(RemoteQuery<?> remoteQuery,
DataFormat dataFormat) |
<V> RemoveIfUnmodifiedOperation<V> |
OperationsFactory.newRemoveIfUnmodifiedOperation(Object key,
byte[] keyBytes,
long version,
DataFormat dataFormat) |
<V> RemoveOperation<V> |
OperationsFactory.newRemoveOperation(Object key,
byte[] keyBytes,
DataFormat dataFormat) |
ReplaceIfUnmodifiedOperation |
OperationsFactory.newReplaceIfUnmodifiedOperation(Object key,
byte[] keyBytes,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
long version,
DataFormat dataFormat) |
<V> ReplaceOperation<V> |
OperationsFactory.newReplaceOperation(Object key,
byte[] keyBytes,
byte[] values,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat) |
Constructor and Description |
---|
AbstractKeyOperation(short requestCode,
short responseCode,
Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
AbstractKeyValueOperation(short requestCode,
short responseCode,
Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
AddClientListenerOperation(Codec codec,
ChannelFactory channelFactory,
String cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
ClientListenerNotifier listenerNotifier,
Object listener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams,
DataFormat dataFormat) |
BulkGetKeysOperation(Codec codec,
ChannelFactory channelFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
int scope,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
ContainsKeyOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
ExecuteOperation(Codec codec,
ChannelFactory channelFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
String taskName,
Map<String,byte[]> marshalledParams,
Object key,
DataFormat dataFormat) |
GetAllOperation(Codec codec,
ChannelFactory channelFactory,
Set<byte[]> keys,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
GetAllParallelOperation(Codec codec,
ChannelFactory channelFactory,
Set<byte[]> keys,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
GetOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
GetWithMetadataOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
HotRodOperation(short requestCode,
short responseCode,
Codec codec,
int flags,
Configuration cfg,
byte[] cacheName,
AtomicInteger topologyId,
ChannelFactory channelFactory,
DataFormat dataFormat) |
IterationNextOperation(Codec codec,
int flags,
Configuration cfg,
byte[] cacheName,
AtomicInteger topologyId,
byte[] iterationId,
io.netty.channel.Channel channel,
ChannelFactory channelFactory,
KeyTracker segmentKeyTracker,
DataFormat dataFormat) |
ParallelHotRodOperation(Codec codec,
ChannelFactory channelFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
PutAllOperation(Codec codec,
ChannelFactory channelFactory,
Map<byte[],byte[]> map,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
PutAllParallelOperation(Codec codec,
ChannelFactory channelFactory,
Map<byte[],byte[]> map,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
PutIfAbsentOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdleTime,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
PutOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
QueryOperation(Codec codec,
ChannelFactory channelFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
RemoteQuery<?> remoteQuery,
DataFormat dataFormat) |
RemoveIfUnmodifiedOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
long version,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
RemoveOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
ReplaceIfUnmodifiedOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
long version,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
ReplaceOperation(Codec codec,
ChannelFactory channelFactory,
Object key,
byte[] keyBytes,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
byte[] value,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
RetryOnFailureOperation(short requestCode,
short responseCode,
Codec codec,
ChannelFactory channelFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat) |
StatsAffectingHotRodOperation(short requestCode,
short responseCode,
Codec codec,
int flags,
Configuration cfg,
byte[] cacheName,
AtomicInteger topologyId,
ChannelFactory channelFactory,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
StatsAffectingRetryingOperation(short requestCode,
short responseCode,
Codec codec,
ChannelFactory channelFactory,
byte[] cacheName,
AtomicInteger topologyId,
int flags,
Configuration cfg,
DataFormat dataFormat,
ClientStatistics clientStatistics) |
Modifier and Type | Method and Description |
---|---|
HeaderParams |
HeaderParams.dataFormat(DataFormat dataFormat) |
Object |
Codec.returnPossiblePrevValue(io.netty.buffer.ByteBuf buf,
short status,
DataFormat dataFormat,
int flags,
ClassWhiteList whitelist,
Marshaller marshaller) |
Object |
Codec20.returnPossiblePrevValue(io.netty.buffer.ByteBuf buf,
short status,
DataFormat dataFormat,
int flags,
ClassWhiteList whitelist,
Marshaller marshaller) |
protected void |
Codec28.writeDataTypes(io.netty.buffer.ByteBuf buf,
DataFormat dataFormat) |
Modifier and Type | Method and Description |
---|---|
AbstractClientEvent |
Codec.readCacheEvent(io.netty.buffer.ByteBuf buf,
Function<byte[],DataFormat> listenerDataFormat,
short eventTypeId,
ClassWhiteList whitelist,
SocketAddress serverAddress) |
AbstractClientEvent |
Codec20.readCacheEvent(io.netty.buffer.ByteBuf buf,
Function<byte[],DataFormat> listenerDataFormat,
short eventTypeId,
ClassWhiteList whitelist,
SocketAddress serverAddress) |
AbstractClientEvent |
Codec21.readCacheEvent(io.netty.buffer.ByteBuf buf,
Function<byte[],DataFormat> listenerDataFormat,
short eventTypeId,
ClassWhiteList whitelist,
SocketAddress serverAddress) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.