Class RespServer

java.lang.Object

org.infinispan.server.core.AbstractProtocolServer<RespServerConfiguration>

org.infinispan.server.resp.RespServer

All Implemented Interfaces:

AutoCloseable, ProtocolServer<RespServerConfiguration>

public class RespServer
extends AbstractProtocolServer<RespServerConfiguration>

Server that supports RESP protocol

Since:

14.0

Author:

William Burns

Field Summary

Fields

Modifier and Type	Field	Description
static final MediaType	RESP_KEY_MEDIA_TYPE
static final String	RESP_SERVER_FEATURE

Fields inherited from class AbstractProtocolServer

adminEndpoint, cacheManager, configuration, server, transport

Constructor Summary

Constructors

Constructor	Description
RespServer()

Method Summary

Modifier and Type	Method	Description
AdvancedCache<byte[],byte[]>	getCache()	Returns the cache being used by the Resp server
io.netty.channel.group.ChannelMatcher	getChannelMatcher()	Returns a ChannelMatcher which matches channels which belong to this protocol server
ExternalSourceIterationManager	getDataStructureIterationManager()
io.netty.channel.ChannelInboundHandler	getDecoder()	Gets the decoder for this protocol server.
io.netty.channel.ChannelOutboundHandler	getEncoder()	Gets the encoder for this protocol server.
io.netty.channel.ChannelInitializer<io.netty.channel.Channel>	getInitializer()	Returns a pipeline factory
DefaultIterationManager	getIterationManager()
TimeService	getTimeService()
CompletionStage<Void>	initializeDefaultCache()
void	installDetector(io.netty.channel.Channel ch)	Installs a protocol detector on the channel
protected void	internalPostStart()
LuaTaskEngine	luaEngine()
MetadataRepository	metadataRepository()
Resp3Handler	newHandler(AdvancedCache<byte[],byte[]> cache)
protected String	protocolType()
Random	random()
SegmentSlotRelation	segmentSlotRelation()
protected void	startCaches()
void	stop()	Stops the server.
String	toString()

Methods inherited from class AbstractProtocolServer

defaultCacheName, getBlockingManager, getCacheManager, getConfiguration, getEnclosingProtocolServer, getExecutor, getHost, getName, getPort, getQualifiedName, getServerStateManager, getTransport, isCacheIgnored, isDefaultCacheInitialized, isDefaultCacheRunning, isTransportEnabled, postStart, registerMetrics, registerServerMBeans, setEnclosingProtocolServer, setServerManagement, start, startInternal, startTransport, toString, unregisterMetrics, unregisterServerMBeans

Methods inherited from class Object

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

Methods inherited from interface ProtocolServer

close

Field Details

RESP_SERVER_FEATURE

public static final String RESP_SERVER_FEATURE

See Also:

• Constant Field Values

RESP_KEY_MEDIA_TYPE

public static final MediaType RESP_KEY_MEDIA_TYPE

Constructor Details

RespServer

public RespServer()

Method Details

internalPostStart

protected void internalPostStart()

Overrides:

internalPostStart in class AbstractProtocolServer<RespServerConfiguration>

initializeDefaultCache

public CompletionStage<Void> initializeDefaultCache()

Overrides:

initializeDefaultCache in class AbstractProtocolServer<RespServerConfiguration>

startCaches

protected void startCaches()

Overrides:

startCaches in class AbstractProtocolServer<RespServerConfiguration>

getEncoder

public io.netty.channel.ChannelOutboundHandler getEncoder()

Description copied from interface: ProtocolServer

Gets the encoder for this protocol server. The encoder is responsible for writing back common header responses back to client. This method can return null if the server has no encoder. You can find an example of the server that has no encoder in the Memcached server.

getDecoder

public io.netty.channel.ChannelInboundHandler getDecoder()

Description copied from interface: ProtocolServer

Gets the decoder for this protocol server. The decoder is responsible for reading client requests. This method cannot return null.

getInitializer

public io.netty.channel.ChannelInitializer<io.netty.channel.Channel> getInitializer()

Description copied from interface: ProtocolServer

Returns a pipeline factory

getChannelMatcher

public io.netty.channel.group.ChannelMatcher getChannelMatcher()

Description copied from interface: ProtocolServer

Returns a ChannelMatcher which matches channels which belong to this protocol server

luaEngine

public LuaTaskEngine luaEngine()

stop

public void stop()

Description copied from interface: ProtocolServer

Stops the server.

Specified by:

stop in interface ProtocolServer<RespServerConfiguration>

Overrides:

stop in class AbstractProtocolServer<RespServerConfiguration>

getCache

public AdvancedCache<byte[],byte[]> getCache()

Returns the cache being used by the Resp server

newHandler

public Resp3Handler newHandler(AdvancedCache<byte[],byte[]> cache)

installDetector

public void installDetector(io.netty.channel.Channel ch)

Description copied from interface: ProtocolServer

Installs a protocol detector on the channel

Parameters:

ch -

getIterationManager

public DefaultIterationManager getIterationManager()

getDataStructureIterationManager

public ExternalSourceIterationManager getDataStructureIterationManager()

getTimeService

public TimeService getTimeService()

segmentSlotRelation

public SegmentSlotRelation segmentSlotRelation()

metadataRepository

public MetadataRepository metadataRepository()

random

public Random random()

protocolType

protected String protocolType()

Specified by:

protocolType in class AbstractProtocolServer<RespServerConfiguration>

toString

public String toString()

Overrides:

toString in class Object