Interface Connector

All Superinterfaces:
Controller
All Known Implementing Classes:
MemcachedConnector

public interface Connector extends Controller
Connector which is used to connect to memcached server.
  • Method Details

    • setOptimizeMergeBuffer

      void setOptimizeMergeBuffer(boolean optimiezeMergeBuffer)
    • setMergeFactor

      void setMergeFactor(int factor)
    • setOptimizeGet

      void setOptimizeGet(boolean optimizeGet)
    • removeSession

      void removeSession(Session session)
    • getSessionByAddress

      Queue<Session> getSessionByAddress(InetSocketAddress address)
    • getStandbySessionListByMainNodeAddr

      List<Session> getStandbySessionListByMainNodeAddr(InetSocketAddress address)
    • getSessionSet

      Set<Session> getSessionSet()
    • setHealSessionInterval

      void setHealSessionInterval(long interval)
    • getHealSessionInterval

      long getHealSessionInterval()
    • send

      Session send(Command packet) throws MemcachedException
      Throws:
      MemcachedException
    • setConnectionPoolSize

      void setConnectionPoolSize(int connectionPoolSize)
    • setBufferAllocator

      void setBufferAllocator(BufferAllocator bufferAllocator)
    • removeReconnectRequest

      void removeReconnectRequest(InetSocketAddress address)
    • setEnableHealSession

      void setEnableHealSession(boolean enableHealSession)
    • addToWatingQueue

      void addToWatingQueue(ReconnectRequest request)
    • setSocketOptions

      void setSocketOptions(Map<SocketOption,Object> options)
    • connect

      Future<Boolean> connect(InetSocketAddressWrapper addressWrapper) throws IOException
      Throws:
      IOException
    • updateSessions

      void updateSessions()
    • setSessionLocator

      void setSessionLocator(MemcachedSessionLocator sessionLocator)
    • setSessionComparator

      void setSessionComparator(MemcachedSessionComparator sessionComparator)
    • quitAllSessions

      void quitAllSessions()
      Make all connection sending a quit command to memcached
    • getReconnectRequestQueue

      Queue<ReconnectRequest> getReconnectRequestQueue()
    • setFailureMode

      void setFailureMode(boolean failureMode)
    • getNoReplyOpsFlowControl

      FlowControl getNoReplyOpsFlowControl()
      Returns the noreply operations flow control manager.
      Returns: