public class Codec20 extends Object implements Codec, HotRodConstants
HotRodConstants.NamesADD_CLIENT_LISTENER_REQUEST, ADD_CLIENT_LISTENER_RESPONSE, AUTH_MECH_LIST_REQUEST, AUTH_MECH_LIST_RESPONSE, AUTH_REQUEST, AUTH_RESPONSE, BULK_GET_KEYS_REQUEST, BULK_GET_KEYS_RESPONSE, BULK_GET_REQUEST, BULK_GET_RESPONSE, CACHE_ENTRY_CREATED_EVENT_RESPONSE, CACHE_ENTRY_EXPIRED_EVENT_RESPONSE, CACHE_ENTRY_MODIFIED_EVENT_RESPONSE, CACHE_ENTRY_REMOVED_EVENT_RESPONSE, CLEAR_REQUEST, CLEAR_RESPONSE, CLIENT_INTELLIGENCE_BASIC, CLIENT_INTELLIGENCE_HASH_DISTRIBUTION_AWARE, CLIENT_INTELLIGENCE_TOPOLOGY_AWARE, COMMAND_TIMEOUT_STATUS, COMMIT_REQUEST, COMMIT_RESPONSE, CONTAINS_KEY_REQUEST, CONTAINS_KEY_RESPONSE, COUNTER_ADD_AND_GET_REQUEST, COUNTER_ADD_AND_GET_RESPONSE, COUNTER_ADD_LISTENER_REQUEST, COUNTER_ADD_LISTENER_RESPONSE, COUNTER_CAS_REQUEST, COUNTER_CAS_RESPONSE, COUNTER_CREATE_REQUEST, COUNTER_CREATE_RESPONSE, COUNTER_EVENT_RESPONSE, COUNTER_GET_CONFIGURATION_REQUEST, COUNTER_GET_CONFIGURATION_RESPONSE, COUNTER_GET_NAMES_REQUEST, COUNTER_GET_NAMES_RESPONSE, COUNTER_GET_REQUEST, COUNTER_GET_RESPONSE, COUNTER_IS_DEFINED_REQUEST, COUNTER_IS_DEFINED_RESPONSE, COUNTER_REMOVE_LISTENER_REQUEST, COUNTER_REMOVE_LISTENER_RESPONSE, COUNTER_REMOVE_REQUEST, COUNTER_REMOVE_RESPONSE, COUNTER_RESET_REQUEST, COUNTER_RESET_RESPONSE, DEFAULT_CACHE_NAME_BYTES, DEFAULT_CACHE_TOPOLOGY, ERROR_RESPONSE, EXEC_REQUEST, EXEC_RESPONSE, FETCH_TX_RECOVERY_REQUEST, FETCH_TX_RECOVERY_RESPONSE, FORGET_TX_REQUEST, FORGET_TX_RESPONSE, GET_ALL_REQUEST, GET_ALL_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_STREAM_REQUEST, GET_STREAM_RESPONSE, GET_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, ILLEGAL_LIFECYCLE_STATE, ILLEGAL_OP_CODE, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INVALID_ITERATION, INVALID_MAGIC_OR_MESSAGE_ID_STATUS, ITERATION_END_REQUEST, ITERATION_END_RESPONSE, ITERATION_NEXT_REQUEST, ITERATION_NEXT_RESPONSE, ITERATION_START_REQUEST, ITERATION_START_RESPONSE, KEY_DOES_NOT_EXIST_STATUS, NO_ERROR_STATUS, NO_ERROR_STATUS_OBJ_STORAGE, NODE_SUSPECTED, NOT_EXECUTED_WITH_PREVIOUS, NOT_EXECUTED_WITH_PREVIOUS_OBJ_STORAGE, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PREPARE_REQUEST, PREPARE_RESPONSE, PREPARE_TX_2_REQUEST, PREPARE_TX_2_RESPONSE, PUT_ALL_REQUEST, PUT_ALL_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_RESPONSE, PUT_STREAM_REQUEST, PUT_STREAM_RESPONSE, QUERY_REQUEST, QUERY_RESPONSE, REMOVE_CLIENT_LISTENER_REQUEST, REMOVE_CLIENT_LISTENER_RESPONSE, REMOVE_IF_UNMODIFIED_REQUEST, REMOVE_IF_UNMODIFIED_RESPONSE, REMOVE_REQUEST, REMOVE_RESPONSE, REPLACE_IF_UNMODIFIED_REQUEST, REPLACE_IF_UNMODIFIED_RESPONSE, REPLACE_REQUEST, REPLACE_RESPONSE, REQUEST_MAGIC, REQUEST_PARSING_ERROR_STATUS, RESPONSE_MAGIC, ROLLBACK_REQUEST, ROLLBACK_RESPONSE, SERVER_ERROR_STATUS, SIZE_REQUEST, SIZE_RESPONSE, STATS_REQUEST, STATS_RESPONSE, SUCCESS_WITH_PREVIOUS, SUCCESS_WITH_PREVIOUS_OBJ_STORAGE, SWITCH_CLUSTER_TOPOLOGY, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_20, VERSION_21, VERSION_22, VERSION_23, VERSION_24, VERSION_25, VERSION_26, VERSION_27, VERSION_28, VERSION_29, VERSION_30| Constructor and Description |
|---|
Codec20() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
checkForErrorsInResponseStatus(io.netty.buffer.ByteBuf buf,
HeaderParams params,
short status,
SocketAddress serverAddress) |
protected AbstractClientEvent |
createCreatedEvent(byte[] listenerId,
Object key,
long dataVersion,
boolean isRetried) |
protected AbstractClientEvent |
createCustomEvent(byte[] listenerId,
Object eventData,
ClientEvent.Type eventType,
boolean isRetried) |
protected AbstractClientEvent |
createModifiedEvent(byte[] listenerId,
Object key,
long dataVersion,
boolean isRetried) |
protected AbstractClientEvent |
createRemovedEvent(byte[] listenerId,
Object key,
boolean isRetried) |
int |
estimateExpirationSize(long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit) |
int |
estimateHeaderSize(HeaderParams params) |
Log |
getLog()
Logger for Hot Rod client codec
|
boolean |
isObjectStorageHinted(PingResponse pingResponse)
Read the response code for hints of object storage in the server.
|
<K> CloseableIterator<K> |
keyIterator(RemoteCache<K,?> remoteCache,
OperationsFactory operationsFactory,
IntSet segments,
int batchSize)
Creates a key iterator with the given batch size if applicable.
|
AbstractClientEvent |
readCacheEvent(io.netty.buffer.ByteBuf buf,
Function<byte[],DataFormat> listenerDataFormat,
short eventTypeId,
ClassWhiteList whitelist,
SocketAddress serverAddress) |
HotRodCounterEvent |
readCounterEvent(io.netty.buffer.ByteBuf buf)
Reads a
HotRodCounterEvent with the listener-id. |
short |
readHeader(io.netty.buffer.ByteBuf buf,
double receivedOpCode,
HeaderParams params,
ChannelFactory channelFactory,
SocketAddress serverAddress)
Reads a response header from the transport and returns the status
of the response.
|
long |
readMessageId(io.netty.buffer.ByteBuf buf) |
protected void |
readNewTopologyAndHash(io.netty.buffer.ByteBuf buf,
HeaderParams params,
ChannelFactory channelFactory) |
protected void |
readNewTopologyIfPresent(io.netty.buffer.ByteBuf buf,
HeaderParams params,
ChannelFactory channelFactory) |
short |
readOpCode(io.netty.buffer.ByteBuf buf) |
Object |
returnPossiblePrevValue(io.netty.buffer.ByteBuf buf,
short status,
DataFormat dataFormat,
int flags,
ClassWhiteList whitelist,
Marshaller marshaller) |
void |
writeClientListenerInterests(io.netty.buffer.ByteBuf buf,
Set<Class<? extends Annotation>> classes) |
void |
writeClientListenerParams(io.netty.buffer.ByteBuf buf,
ClientListener clientListener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams)
Writes client listener parameters
|
void |
writeExpirationParams(io.netty.buffer.ByteBuf buf,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit)
Write lifespan/maxidle parameters.
|
HeaderParams |
writeHeader(io.netty.buffer.ByteBuf buf,
HeaderParams params)
Writes a request header with the given parameters to the transport and
returns an updated header parameters.
|
protected HeaderParams |
writeHeader(io.netty.buffer.ByteBuf buf,
HeaderParams params,
byte version) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitallowOperationsAndEvents, entryIterator, readKeyType, readMeta, readProjectionSize, readValueType, writeIteratorStartOperationhasPrevious, isInvalidIteration, isNotExecuted, isNotExist, isObjectStorage, isSuccesspublic void writeClientListenerInterests(io.netty.buffer.ByteBuf buf,
Set<Class<? extends Annotation>> classes)
writeClientListenerInterests in interface Codecpublic HeaderParams writeHeader(io.netty.buffer.ByteBuf buf, HeaderParams params)
CodecwriteHeader in interface Codecpublic void writeClientListenerParams(io.netty.buffer.ByteBuf buf,
ClientListener clientListener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams)
CodecwriteClientListenerParams in interface Codecpublic void writeExpirationParams(io.netty.buffer.ByteBuf buf,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit)
CodecwriteExpirationParams in interface Codecpublic int estimateExpirationSize(long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit)
estimateExpirationSize in interface Codecprotected HeaderParams writeHeader(io.netty.buffer.ByteBuf buf, HeaderParams params, byte version)
public int estimateHeaderSize(HeaderParams params)
estimateHeaderSize in interface Codecpublic long readMessageId(io.netty.buffer.ByteBuf buf)
readMessageId in interface Codecpublic short readOpCode(io.netty.buffer.ByteBuf buf)
readOpCode in interface Codecpublic short readHeader(io.netty.buffer.ByteBuf buf,
double receivedOpCode,
HeaderParams params,
ChannelFactory channelFactory,
SocketAddress serverAddress)
CodecreadHeader in interface Codecpublic HotRodCounterEvent readCounterEvent(io.netty.buffer.ByteBuf buf)
CodecHotRodCounterEvent with the listener-id.readCounterEvent in interface Codecpublic <K> CloseableIterator<K> keyIterator(RemoteCache<K,?> remoteCache, OperationsFactory operationsFactory, IntSet segments, int batchSize)
CodeckeyIterator in interface Codecpublic boolean isObjectStorageHinted(PingResponse pingResponse)
CodecisObjectStorageHinted in interface Codecpublic AbstractClientEvent readCacheEvent(io.netty.buffer.ByteBuf buf, Function<byte[],DataFormat> listenerDataFormat, short eventTypeId, ClassWhiteList whitelist, SocketAddress serverAddress)
readCacheEvent in interface Codecpublic Object returnPossiblePrevValue(io.netty.buffer.ByteBuf buf, short status, DataFormat dataFormat, int flags, ClassWhiteList whitelist, Marshaller marshaller)
returnPossiblePrevValue in interface Codecprotected AbstractClientEvent createRemovedEvent(byte[] listenerId, Object key, boolean isRetried)
protected AbstractClientEvent createModifiedEvent(byte[] listenerId, Object key, long dataVersion, boolean isRetried)
protected AbstractClientEvent createCreatedEvent(byte[] listenerId, Object key, long dataVersion, boolean isRetried)
protected AbstractClientEvent createCustomEvent(byte[] listenerId, Object eventData, ClientEvent.Type eventType, boolean isRetried)
protected void checkForErrorsInResponseStatus(io.netty.buffer.ByteBuf buf,
HeaderParams params,
short status,
SocketAddress serverAddress)
protected void readNewTopologyIfPresent(io.netty.buffer.ByteBuf buf,
HeaderParams params,
ChannelFactory channelFactory)
protected void readNewTopologyAndHash(io.netty.buffer.ByteBuf buf,
HeaderParams params,
ChannelFactory channelFactory)
Copyright © 2021 JBoss by Red Hat. All rights reserved.