Class MemcachedServer

java.lang.Object

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

org.infinispan.server.memcached.MemcachedServer

All Implemented Interfaces:

AutoCloseable, ProtocolServer<MemcachedServerConfiguration>

public class MemcachedServer
extends AbstractProtocolServer<MemcachedServerConfiguration>

Memcached server defining its decoder/encoder settings. In fact, Memcached does not use an encoder since there's no really common headers between protocol operations.

Since:

4.1

Author:

Galder Zamarreño

Field Summary

Fields

Modifier and Type	Field	Description
protected final ScheduledExecutorService	scheduler

Fields inherited from class AbstractProtocolServer

adminEndpoint, cacheManager, configuration, server, transport

Constructor Summary

Constructors

Constructor	Description
MemcachedServer()

Method Summary

Modifier and Type	Method	Description
Cache<Object,Object>	getCache()	Returns the cache being used by the Memcached server
io.netty.channel.group.ChannelMatcher	getChannelMatcher()	Returns a ChannelMatcher which matches channels which belong to this protocol server
io.netty.channel.ChannelInboundHandler	getDecoder()	Invoked when the Memcached server has a dedicated transport
io.netty.channel.ChannelInboundHandler	getDecoder(MemcachedProtocol protocol)	Invoked when the Memcached server is part of a single-port router
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
io.netty.channel.ChannelInitializer<io.netty.channel.Channel>	getInitializer(MemcachedProtocol protocol)	This initializer is invoked by the detector
ScheduledExecutorService	getScheduler()
MemcachedStats	getStatistics()
CompletionStage<Void>	initializeDefaultCache()
void	installDetector(io.netty.channel.Channel ch)	Installs a protocol detector on the channel
void	installMemcachedInboundHandler(io.netty.channel.Channel ch, MemcachedBaseDecoder decoder)
protected String	protocolType()
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, internalPostStart, 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

scheduler

protected final ScheduledExecutorService scheduler

Constructor Details

MemcachedServer

public MemcachedServer()

Method Details

startCaches

protected void startCaches()

Overrides:

startCaches in class AbstractProtocolServer<MemcachedServerConfiguration>

initializeDefaultCache

public CompletionStage<Void> initializeDefaultCache()

Overrides:

initializeDefaultCache in class AbstractProtocolServer<MemcachedServerConfiguration>

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()

Invoked when the Memcached server has a dedicated transport

getDecoder

public io.netty.channel.ChannelInboundHandler getDecoder(MemcachedProtocol protocol)

Invoked when the Memcached server is part of a single-port router

installMemcachedInboundHandler

public void installMemcachedInboundHandler(io.netty.channel.Channel ch,
 MemcachedBaseDecoder decoder)

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

getInitializer

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

Description copied from interface: ProtocolServer

Returns a pipeline factory

getInitializer

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

This initializer is invoked by the detector

stop

public void stop()

Description copied from interface: ProtocolServer

Stops the server.

Specified by:

stop in interface ProtocolServer<MemcachedServerConfiguration>

Overrides:

stop in class AbstractProtocolServer<MemcachedServerConfiguration>

getCache

public Cache<Object,Object> getCache()

Returns the cache being used by the Memcached server

getScheduler

public ScheduledExecutorService getScheduler()

installDetector

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

Description copied from interface: ProtocolServer

Installs a protocol detector on the channel

Parameters:

ch -

getStatistics

public MemcachedStats getStatistics()

protocolType

protected String protocolType()

Specified by:

protocolType in class AbstractProtocolServer<MemcachedServerConfiguration>

toString

public String toString()

Overrides:

toString in class Object