Package org.infinispan.server.memcached

Class MemcachedServer

java.lang.Object
org.infinispan.server.core.AbstractProtocolServer<MemcachedServerConfiguration>
org.infinispan.server.memcached.MemcachedServer
All Implemented Interfaces:
AutoCloseable, org.infinispan.server.core.ProtocolServer<MemcachedServerConfiguration>
public class MemcachedServer extends org.infinispan.server.core.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 org.infinispan.server.core.AbstractProtocolServer

    adminEndpoint, cacheManager, configuration, server, transport

  • Constructor Summary

    Constructors
    Constructor
    Description
    MemcachedServer()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.infinispan.Cache<Object,Object>
    getCache()
    Returns the cache being used by the Memcached server
    io.netty.channel.group.ChannelMatcher
    getChannelMatcher()
     
    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()
     
    io.netty.channel.ChannelInitializer<io.netty.channel.Channel>
    getInitializer()
     
    io.netty.channel.ChannelInitializer<io.netty.channel.Channel>
    getInitializer(MemcachedProtocol protocol)
    This initializer is invoked by the detector
    ScheduledExecutorService
    getScheduler()
     
    MemcachedStats
    getStatistics()
     
    void
    installDetector(io.netty.channel.Channel ch)
     
    void
    installMemcachedInboundHandler(io.netty.channel.Channel ch, MemcachedBaseDecoder decoder)
     
    protected void
    startInternal()
     
    void
    stop()
     

    Methods inherited from class org.infinispan.server.core.AbstractProtocolServer

    defaultCacheName, getBlockingManager, getCacheManager, getConfiguration, getEnclosingProtocolServer, getExecutor, getHost, getName, getPort, getQualifiedName, getServerStateManager, getTransport, isCacheIgnored, isTransportEnabled, registerMetrics, registerServerMBeans, setEnclosingProtocolServer, setServerManagement, start, startCaches, startTransport, unregisterMetrics, unregisterServerMBeans

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.infinispan.server.core.ProtocolServer

    close

  • Field Details

  • Constructor Details

    • MemcachedServer

      public MemcachedServer()

  • Method Details

    • startInternal

      protected void startInternal()
      Overrides:
      startInternal in class org.infinispan.server.core.AbstractProtocolServer<MemcachedServerConfiguration>

    • getEncoder

      public io.netty.channel.ChannelOutboundHandler getEncoder()

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

    • getInitializer

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

    • getInitializer

      public io.netty.channel.ChannelInitializer<io.netty.channel.Channel> getInitializer(MemcachedProtocol protocol)
      This initializer is invoked by the detector

    • stop

      public void stop()
      Specified by:
      stop in interface org.infinispan.server.core.ProtocolServer<MemcachedServerConfiguration>
      Overrides:
      stop in class org.infinispan.server.core.AbstractProtocolServer<MemcachedServerConfiguration>

    • getCache

      public org.infinispan.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)

    • getStatistics

      public MemcachedStats getStatistics()