Uses of Class
org.infinispan.server.hotrod.HotRodServer
Packages that use HotRodServer
-
Uses of HotRodServer in org.infinispan.server.hotrod
Fields in org.infinispan.server.hotrod declared as HotRodServerModifier and TypeFieldDescriptionprotected final HotRodServer
BaseDecoder.server
protected final HotRodServer
BaseRequestProcessor.server
Methods in org.infinispan.server.hotrod with parameters of type HotRodServerModifier and TypeMethodDescriptionio.netty.buffer.ByteBuf
VersionedEncoder.authMechListResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Set<String> mechs) io.netty.buffer.ByteBuf
VersionedEncoder.authResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, byte[] challenge) io.netty.buffer.ByteBuf
VersionedEncoder.booleanResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, boolean result) io.netty.buffer.ByteBuf
VersionedEncoder.bulkGetKeysResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CloseableIterator<byte[]> iterator) io.netty.buffer.ByteBuf
VersionedEncoder.bulkGetResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int size, CacheSet<Map.Entry<byte[], byte[]>> entries) io.netty.buffer.ByteBuf
VersionedEncoder.counterConfigurationResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CounterConfiguration configuration) io.netty.buffer.ByteBuf
VersionedEncoder.counterNamesResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Collection<String> counterNames) io.netty.buffer.ByteBuf
VersionedEncoder.emptyResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status) io.netty.buffer.ByteBuf
VersionedEncoder.errorResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, String message, OperationStatus status) io.netty.buffer.ByteBuf
VersionedEncoder.getAllResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Map<byte[], byte[]> map) io.netty.buffer.ByteBuf
VersionedEncoder.getStreamResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int offset, CacheEntry<byte[], byte[]> entry) io.netty.buffer.ByteBuf
VersionedEncoder.getWithMetadataResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[], byte[]> entry) io.netty.buffer.ByteBuf
VersionedEncoder.iterationNextResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, IterableIterationResult iterationResult) io.netty.buffer.ByteBuf
VersionedEncoder.iterationStartResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, String iterationId) io.netty.buffer.ByteBuf
VersionedEncoder.longResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, long value) io.netty.buffer.ByteBuf
VersionedEncoder.multimapCollectionResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, Collection<byte[]> values) io.netty.buffer.ByteBuf
VersionedEncoder.multimapEntryResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, CacheEntry<byte[], Collection<byte[]>> ce) io.netty.buffer.ByteBuf
VersionedEncoder.notExecutedResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[], byte[]> prev) io.netty.buffer.ByteBuf
VersionedEncoder.notExistResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel) default io.netty.buffer.ByteBuf
VersionedEncoder.pingResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status) io.netty.buffer.ByteBuf
VersionedEncoder.recoveryResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Collection<XidImpl> xids) io.netty.buffer.ByteBuf
VersionedEncoder.statsResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Stats stats, NettyTransport transport, ClusterCacheStats clusterCacheStats1) io.netty.buffer.ByteBuf
VersionedEncoder.successResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[], byte[]> result) io.netty.buffer.ByteBuf
VersionedEncoder.transactionResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int xaReturnCode) io.netty.buffer.ByteBuf
VersionedEncoder.unsignedLongResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, long value) io.netty.buffer.ByteBuf
Encoder4x.valueResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, CacheEntry<byte[], byte[]> prev) io.netty.buffer.ByteBuf
VersionedEncoder.valueResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, byte[] prev) io.netty.buffer.ByteBuf
VersionedEncoder.valueResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, CacheEntry<byte[], byte[]> prev) io.netty.buffer.ByteBuf
VersionedEncoder.valueWithVersionResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, byte[] value, long version) Constructors in org.infinispan.server.hotrod with parameters of type HotRodServerModifierConstructorDescriptionAuthentication
(io.netty.channel.Channel channel, Executor executor, HotRodServer server) HotRodDecoder
(EmbeddedCacheManager cacheManager, Executor executor, HotRodServer server) -
Uses of HotRodServer in org.infinispan.server.hotrod.tx.operation
Constructors in org.infinispan.server.hotrod.tx.operation with parameters of type HotRodServerModifierConstructorDescriptionCommitTransactionOperation
(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)