Class Codec23
- 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
-
- All Implemented Interfaces:
Codec
,HotRodConstants
- Direct Known Subclasses:
Codec24
public class Codec23 extends Codec22
- Since:
- 8.0
- Author:
- gustavonalle
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants
HotRodConstants.Names
-
-
Field Summary
-
Fields inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants
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, 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, 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_COMPAT, NODE_SUSPECTED, NOT_EXECUTED_WITH_PREVIOUS, NOT_EXECUTED_WITH_PREVIOUS_COMPAT, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PREPARE_REQUEST, PREPARE_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_COMPAT, SWITCH_CLUSTER_TOPOLOGY, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_10, VERSION_11, VERSION_12, VERSION_13, VERSION_20, VERSION_21, VERSION_22, VERSION_23, VERSION_24, VERSION_25, VERSION_26, VERSION_27, VERSION_28
-
-
Constructor Summary
Constructors Constructor Description Codec23()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected <K,V>
org.infinispan.commons.util.CloseableIterator<Map.Entry<K,V>>castEntryIterator(org.infinispan.commons.util.CloseableIterator iterator)
<K,V>
org.infinispan.commons.util.CloseableIterator<Map.Entry<K,V>>entryIterator(RemoteCache<K,V> remoteCache, int batchSize)
Creates an entry iterator with the given batch size if applicable.<K> org.infinispan.commons.util.CloseableIterator<K>
keyIterator(RemoteCache<K,?> remoteCache, OperationsFactory operationsFactory, 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.void
writeIteratorStartOperation(io.netty.buffer.ByteBuf buf, Set<Integer> segments, String filterConverterFactory, int batchSize, boolean metadata, byte[][] filterParameters)
-
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, getLog, readCacheEvent, writeClientListenerParams
-
Methods inherited from class org.infinispan.client.hotrod.impl.protocol.Codec20
checkForErrorsInResponseStatus, createCreatedEvent, createCustomEvent, createModifiedEvent, createRemovedEvent, estimateHeaderSize, readCounterEvent, readHeader, readMessageId, readNewTopologyAndHash, readNewTopologyIfPresent, readOpCode, readUnmarshallByteArray, returnPossiblePrevValue, writeClientListenerInterests, writeHeader
-
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, readMeta, readProjectionSize
-
-
-
-
Method Detail
-
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 interfaceCodec
- Overrides:
writeHeader
in classCodec22
-
keyIterator
public <K> org.infinispan.commons.util.CloseableIterator<K> keyIterator(RemoteCache<K,?> remoteCache, OperationsFactory operationsFactory, 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 interfaceCodec
- Overrides:
keyIterator
in classCodec20
- Returns:
-
entryIterator
public <K,V> org.infinispan.commons.util.CloseableIterator<Map.Entry<K,V>> entryIterator(RemoteCache<K,V> remoteCache, int batchSize)
Description copied from interface:Codec
Creates an entry iterator with the given batch size if applicable. This iterator does not support removal.- Returns:
-
castEntryIterator
protected <K,V> org.infinispan.commons.util.CloseableIterator<Map.Entry<K,V>> castEntryIterator(org.infinispan.commons.util.CloseableIterator iterator)
-
-