Package org.infinispan.client.hotrod.impl.protocol

Class Codec27

java.lang.Object

org.infinispan.client.hotrod.impl.protocol.Codec20

org.infinispan.client.hotrod.impl.protocol.Codec21

org.infinispan.client.hotrod.impl.protocol.Codec22

org.infinispan.client.hotrod.impl.protocol.Codec23

org.infinispan.client.hotrod.impl.protocol.Codec24

org.infinispan.client.hotrod.impl.protocol.Codec25

org.infinispan.client.hotrod.impl.protocol.Codec26

org.infinispan.client.hotrod.impl.protocol.Codec27

All Implemented Interfaces:

Codec, HotRodConstants

Direct Known Subclasses:

Codec28

public class Codec27
extends Codec26

Since:

9.2

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants

HotRodConstants.Names

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EMPTY_VALUE_CONVERTER

Fields inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants

ADD_BLOOM_FILTER_NEAR_CACHE_LISTENER_REQUEST, ADD_BLOOM_FILTER_NEAR_CACHE_LISTENER_RESPONSE, ADD_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, 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_AND_SET_REQUEST, COUNTER_GET_AND_SET_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, UPDATE_BLOOM_FILTER_REQUEST, UPDATE_BLOOM_FILTER_RESPONSE, VERSION_20, VERSION_21, VERSION_22, VERSION_23, VERSION_24, VERSION_25, VERSION_26, VERSION_27, VERSION_28, VERSION_29, VERSION_30, VERSION_31, VERSION_40

Constructor Summary

Constructors

Constructor	Description
Codec27()

Method Summary

Modifier and Type	Method	Description
<K> CloseableIterator<K>	keyIterator(RemoteCache<K,?> remoteCache, OperationsFactory operationsFactory, IntSet segments, int batchSize)	Creates a key iterator with the given batch size if applicable.
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.

Methods inherited from class org.infinispan.client.hotrod.impl.protocol.Codec26

writeClientListenerInterests

Methods inherited from class org.infinispan.client.hotrod.impl.protocol.Codec25

readMeta

Methods inherited from class org.infinispan.client.hotrod.impl.protocol.Codec24

isObjectStorageHinted, readProjectionSize, writeIteratorStartOperation

Methods inherited from class org.infinispan.client.hotrod.impl.protocol.Codec23

castEntryIterator, entryIterator

Methods inherited from class org.infinispan.client.hotrod.impl.protocol.Codec22

estimateExpirationSize, writeExpirationParams

Methods inherited from class org.infinispan.client.hotrod.impl.protocol.Codec21

createExpiredEvent, readCacheEvent, writeClientListenerParams

Methods inherited from class org.infinispan.client.hotrod.impl.protocol.Codec20

checkForErrorsInResponseStatus, createCreatedEvent, createCustomEvent, createModifiedEvent, createRemovedEvent, estimateHeaderSize, estimateSizeMultimapSupportsDuplicated, readCounterEvent, readHeader, readMessageId, readNewTopologyAndHash, readNewTopologyIfPresent, readOpCode, returnPossiblePrevValue, writeBloomFilter, writeHeader, writeMultimapSupportDuplicates

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.client.hotrod.impl.protocol.Codec

allowOperationsAndEvents, isUnsafeForTheHandshake, readKeyType, readValueType

Field Details

EMPTY_VALUE_CONVERTER

public static final String EMPTY_VALUE_CONVERTER

See Also:

• Constant Field Values

Constructor Details

Codec27

public Codec27()

Method Details

writeHeader

public HeaderParams writeHeader(io.netty.buffer.ByteBuf buf,
 HeaderParams params)

Description copied from interface: Codec

Writes a request header with the given parameters to the transport and returns an updated header parameters.

Specified by:

writeHeader in interface Codec

Overrides:

writeHeader in class Codec26

keyIterator

public <K> CloseableIterator<K> keyIterator(RemoteCache<K,?> remoteCache,
 OperationsFactory operationsFactory,
 IntSet segments,
 int batchSize)

Description copied from interface: Codec

Creates a key iterator with the given batch size if applicable. This iterator does not support removal.

Specified by:

keyIterator in interface Codec

Overrides:

keyIterator in class Codec23

Returns: