Uses of Class
org.infinispan.server.hotrod.HotRodHeader
-
Packages that use HotRodHeader Package Description org.infinispan.server.hotrod org.infinispan.server.hotrod.tx.operation -
-
Uses of HotRodHeader in org.infinispan.server.hotrod
Subclasses of HotRodHeader in org.infinispan.server.hotrod Modifier and Type Class Description class
AccessLoggingHeader
Methods in org.infinispan.server.hotrod that return HotRodHeader Modifier and Type Method Description protected HotRodHeader
HotRodDecoder. getHeader()
Methods in org.infinispan.server.hotrod with parameters of type HotRodHeader Modifier and Type Method Description void
Authentication. auth(HotRodHeader header, String mech, byte[] response)
void
Authentication. authMechList(HotRodHeader header)
io.netty.buffer.ByteBuf
AbstractEncoder1x. authMechListResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Set<String> mechs)
io.netty.buffer.ByteBuf
VersionedEncoder. authMechListResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Set<String> mechs)
io.netty.buffer.ByteBuf
AbstractEncoder1x. authResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] challenge)
io.netty.buffer.ByteBuf
VersionedEncoder. authResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] challenge)
io.netty.buffer.ByteBuf
AbstractEncoder1x. booleanResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, boolean result)
io.netty.buffer.ByteBuf
VersionedEncoder. booleanResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, boolean result)
Metadata
HotRodServer. buildMetadata(HotRodHeader header, long lifespan, TimeUnitValue lifespanUnit, long maxIdle, TimeUnitValue maxIdleUnit)
io.netty.buffer.ByteBuf
AbstractEncoder1x. bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CloseableIterator<byte[]> iterator)
io.netty.buffer.ByteBuf
VersionedEncoder. bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CloseableIterator<byte[]> iterator)
io.netty.buffer.ByteBuf
AbstractEncoder1x. bulkGetResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int size, CacheSet<Map.Entry<byte[],byte[]>> entries)
io.netty.buffer.ByteBuf
VersionedEncoder. bulkGetResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int size, CacheSet<Map.Entry<byte[],byte[]>> entries)
AdvancedCache<byte[],byte[]>
HotRodServer. cache(HotRodHeader header, Subject subject)
AdvancedCache<byte[],byte[]>
HotRodServer. cache(HotRodHeader header, Subject subject, String cacheName)
io.netty.buffer.ByteBuf
AbstractEncoder1x. counterConfigurationResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CounterConfiguration configuration)
io.netty.buffer.ByteBuf
VersionedEncoder. counterConfigurationResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CounterConfiguration configuration)
io.netty.buffer.ByteBuf
AbstractEncoder1x. counterNamesResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Collection<String> counterNames)
io.netty.buffer.ByteBuf
VersionedEncoder. counterNamesResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Collection<String> counterNames)
io.netty.buffer.ByteBuf
AbstractEncoder1x. emptyResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status)
io.netty.buffer.ByteBuf
VersionedEncoder. emptyResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status)
default io.netty.buffer.ByteBuf
VersionedEncoder. emptyResponseWithMediaTypes(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status)
io.netty.buffer.ByteBuf
AbstractEncoder1x. errorResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, String message, OperationStatus status)
io.netty.buffer.ByteBuf
VersionedEncoder. errorResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, String message, OperationStatus status)
void
TaskRequestProcessor. exec(HotRodHeader header, Subject subject, String taskName, Map<String,byte[]> taskParams)
io.netty.buffer.ByteBuf
AbstractEncoder1x. getAllResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Map<byte[],byte[]> map)
io.netty.buffer.ByteBuf
VersionedEncoder. getAllResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Map<byte[],byte[]> map)
HotRodServer.CacheInfo
HotRodServer. getCacheInfo(AdvancedCache<byte[],byte[]> cache, HotRodHeader header)
io.netty.buffer.ByteBuf
AbstractEncoder1x. getStreamResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int offset, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf
VersionedEncoder. getStreamResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int offset, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf
AbstractEncoder1x. getWithMetadataResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf
VersionedEncoder. getWithMetadataResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf
AbstractEncoder1x. iterationNextResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, IterableIterationResult iterationResult)
io.netty.buffer.ByteBuf
VersionedEncoder. iterationNextResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, IterableIterationResult iterationResult)
io.netty.buffer.ByteBuf
AbstractEncoder1x. iterationStartResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, String iterationId)
io.netty.buffer.ByteBuf
VersionedEncoder. iterationStartResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, String iterationId)
io.netty.buffer.ByteBuf
AbstractEncoder1x. longResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, long value)
io.netty.buffer.ByteBuf
VersionedEncoder. longResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, long value)
org.infinispan.multimap.impl.EmbeddedMultimapCache<WrappedByteArray,WrappedByteArray>
HotRodServer. multimap(HotRodHeader header, Subject subject)
io.netty.buffer.ByteBuf
AbstractEncoder1x. multimapCollectionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, Collection<byte[]> values)
io.netty.buffer.ByteBuf
VersionedEncoder. multimapCollectionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, Collection<byte[]> values)
io.netty.buffer.ByteBuf
AbstractEncoder1x. multimapEntryResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, CacheEntry<WrappedByteArray,Collection<WrappedByteArray>> ce, Collection<byte[]> result)
io.netty.buffer.ByteBuf
VersionedEncoder. multimapEntryResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, CacheEntry<WrappedByteArray,Collection<WrappedByteArray>> ce, Collection<byte[]> result)
io.netty.buffer.ByteBuf
AbstractEncoder1x. notExecutedResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] prev)
io.netty.buffer.ByteBuf
VersionedEncoder. notExecutedResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] prev)
io.netty.buffer.ByteBuf
AbstractEncoder1x. notExistResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc)
io.netty.buffer.ByteBuf
VersionedEncoder. notExistResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc)
io.netty.buffer.ByteBuf
AbstractEncoder1x. recoveryResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Collection<Xid> xids)
io.netty.buffer.ByteBuf
VersionedEncoder. recoveryResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Collection<Xid> xids)
io.netty.buffer.ByteBuf
AbstractEncoder1x. statsResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Stats stats, NettyTransport transport, ComponentRegistry cacheRegistry)
io.netty.buffer.ByteBuf
VersionedEncoder. statsResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Stats stats, NettyTransport transport, ComponentRegistry cacheRegistry)
io.netty.buffer.ByteBuf
AbstractEncoder1x. successResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] result)
io.netty.buffer.ByteBuf
VersionedEncoder. successResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] result)
io.netty.buffer.ByteBuf
AbstractEncoder1x. transactionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int xaReturnCode)
io.netty.buffer.ByteBuf
VersionedEncoder. transactionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int xaReturnCode)
io.netty.buffer.ByteBuf
AbstractEncoder1x. unsignedLongResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, long value)
io.netty.buffer.ByteBuf
VersionedEncoder. unsignedLongResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, long value)
io.netty.buffer.ByteBuf
AbstractEncoder1x. valueResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, byte[] prev)
io.netty.buffer.ByteBuf
VersionedEncoder. valueResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, byte[] prev)
io.netty.buffer.ByteBuf
AbstractEncoder1x. valueWithVersionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] value, long version)
io.netty.buffer.ByteBuf
VersionedEncoder. valueWithVersionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] value, long version)
protected void
BaseRequestProcessor. writeResponse(HotRodHeader header, io.netty.buffer.ByteBuf buf)
Constructors in org.infinispan.server.hotrod with parameters of type HotRodHeader Constructor Description AccessLoggingHeader(HotRodHeader header, Subject subject, Object key, int requestBytes, Temporal requestStart)
HotRodHeader(HotRodHeader header)
-
Uses of HotRodHeader in org.infinispan.server.hotrod.tx.operation
Constructors in org.infinispan.server.hotrod.tx.operation with parameters of type HotRodHeader Constructor Description CommitTransactionOperation(HotRodHeader header, HotRodServer server, Subject subject, XidImpl xid, BiConsumer<HotRodHeader,Integer> reply)
RollbackTransactionOperation(HotRodHeader header, HotRodServer server, Subject subject, XidImpl xid, BiConsumer<HotRodHeader,Integer> reply)
Constructor parameters in org.infinispan.server.hotrod.tx.operation with type arguments of type HotRodHeader Constructor Description CommitTransactionOperation(HotRodHeader header, HotRodServer server, Subject subject, XidImpl xid, BiConsumer<HotRodHeader,Integer> reply)
RollbackTransactionOperation(HotRodHeader header, HotRodServer server, Subject subject, XidImpl xid, BiConsumer<HotRodHeader,Integer> reply)
-