Uses of Class
net.rubyeye.xmemcached.command.Command
-
Packages that use Command Package Description net.rubyeye.xmemcached XMemcached's main classes and interfaces,use these classes/interfaces to interact with memcached servers.net.rubyeye.xmemcached.auth Memcached 1.4.3 or later version has supported SASL authentication,these classes are used for thatnet.rubyeye.xmemcached.command Memcached protocol implementationsnet.rubyeye.xmemcached.command.binary Memcached text protocol implementationsnet.rubyeye.xmemcached.command.kestrel Kestrel protocol implementationsnet.rubyeye.xmemcached.command.text Memcached text protocol implementationsnet.rubyeye.xmemcached.impl Manage tcp connection,memcached protocol optimized,and some MBeans for monitor.net.rubyeye.xmemcached.networking Networking layout to talk with memcached. -
-
Uses of Command in net.rubyeye.xmemcached
Methods in net.rubyeye.xmemcached that return Command Modifier and Type Method Description CommandCommandFactory. createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)create a add commandCommandCommandFactory. createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)create a append commandCommandCommandFactory. createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)Create a command for listing authentication mechanismsCommandCommandFactory. createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)Create command for starting authenticationCommandCommandFactory. createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)Create a command for stepping authenticationCommandCommandFactory. createAWSElasticCacheConfigCommand(java.lang.String subCommand, java.lang.String key)Create a AWS ElasticCache config command, only supports Cache Engine Version 1.4.14 or Higher.CommandCommandFactory. createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)Create a cas commandCommandCommandFactory. createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)create a delete commandCommandCommandFactory. createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int delay, boolean noreply)create a flush_all commandCommandCommandFactory. createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)Create a get-and-touch commandCommandCommandFactory. createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)create a get/gets command<T> CommandCommandFactory. createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)Create a multi-get commandCommandCommandFactory. createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long delta, long initial, int expTime, CommandType cmdType, boolean noreply)create a incr/decr commandCommandCommandFactory. createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)Create a prepend commandCommandCommandFactory. createQuitCommand()create a quit commandCommandCommandFactory. createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)create a replace commandCommandCommandFactory. createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)Create a set commandCommandCommandFactory. createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)create a stats commandCommandCommandFactory. createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)Create a touch commandCommandCommandFactory. createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)Create a verbosity commandCommandCommandFactory. createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)create a version commandCommandMemcachedOptimizer. optimize(Command currentCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)private <T> CommandXMemcachedClient. sendGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)Methods in net.rubyeye.xmemcached with parameters of type Command Modifier and Type Method Description protected voidXMemcachedClient. checkException(Command command)protected voidXMemcachedClient. latchWait(Command cmd, long timeout, Session session)CommandMemcachedOptimizer. optimize(Command currentCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)protected SessionXMemcachedClient. sendCommand(Command cmd)private <T> booleanXMemcachedClient. sendStoreCommand(Command command, long timeout)Method parameters in net.rubyeye.xmemcached with type arguments of type Command Modifier and Type Method Description private <T> java.util.Map<java.lang.String,T>XMemcachedClient. reduceResult(CommandType cmdType, Transcoder<T> transcoder, java.util.List<Command> commands) -
Uses of Command in net.rubyeye.xmemcached.auth
Methods in net.rubyeye.xmemcached.auth that return Command Modifier and Type Method Description private CommandAuthTask. startAuth()Methods in net.rubyeye.xmemcached.auth with parameters of type Command Modifier and Type Method Description private voidAuthTask. waitCommand(Command cmd, java.util.concurrent.atomic.AtomicBoolean done) -
Uses of Command in net.rubyeye.xmemcached.command
Subclasses of Command in net.rubyeye.xmemcached.command Modifier and Type Class Description classVerbosityCommandAbstract verbosity command for text protocolMethods in net.rubyeye.xmemcached.command that return Command Modifier and Type Method Description CommandBinaryCommandFactory. createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandKestrelCommandFactory. createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandTextCommandFactory. createAddCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandBinaryCommandFactory. createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandKestrelCommandFactory. createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandTextCommandFactory. createAppendCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandBinaryCommandFactory. createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)CommandKestrelCommandFactory. createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)CommandTextCommandFactory. createAuthListMechanismsCommand(java.util.concurrent.CountDownLatch latch)CommandBinaryCommandFactory. createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)CommandKestrelCommandFactory. createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)CommandTextCommandFactory. createAuthStartCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)CommandBinaryCommandFactory. createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)CommandKestrelCommandFactory. createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)CommandTextCommandFactory. createAuthStepCommand(java.lang.String mechanism, java.util.concurrent.CountDownLatch latch, byte[] authData)CommandBinaryCommandFactory. createAWSElasticCacheConfigCommand(java.lang.String subCommand, java.lang.String key)CommandKestrelCommandFactory. createAWSElasticCacheConfigCommand(java.lang.String subCommand, java.lang.String key)CommandTextCommandFactory. createAWSElasticCacheConfigCommand(java.lang.String subCommand, java.lang.String key)CommandBinaryCommandFactory. createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)CommandKestrelCommandFactory. createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)CommandTextCommandFactory. createCASCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, long cas, boolean noreply, Transcoder transcoder)CommandBinaryCommandFactory. createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)CommandKestrelCommandFactory. createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)CommandTextCommandFactory. createDeleteCommand(java.lang.String key, byte[] keyBytes, int time, long cas, boolean noreply)CommandBinaryCommandFactory. createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int delay, boolean noreply)CommandKestrelCommandFactory. createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int delay, boolean noreply)CommandTextCommandFactory. createFlushAllCommand(java.util.concurrent.CountDownLatch latch, int exptime, boolean noreply)CommandBinaryCommandFactory. createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)CommandKestrelCommandFactory. createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)CommandTextCommandFactory. createGetAndTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)CommandBinaryCommandFactory. createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)CommandKestrelCommandFactory. createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)CommandTextCommandFactory. createGetCommand(java.lang.String key, byte[] keyBytes, CommandType cmdType, Transcoder transcoder)<T> CommandBinaryCommandFactory. createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)<T> CommandKestrelCommandFactory. createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)<T> CommandTextCommandFactory. createGetMultiCommand(java.util.Collection<java.lang.String> keys, java.util.concurrent.CountDownLatch latch, CommandType cmdType, Transcoder<T> transcoder)CommandBinaryCommandFactory. createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long amount, long initial, int expTime, CommandType cmdType, boolean noreply)CommandKestrelCommandFactory. createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long amount, long initial, int expTime, CommandType cmdType, boolean noreply)CommandTextCommandFactory. createIncrDecrCommand(java.lang.String key, byte[] keyBytes, long amount, long initial, int exptime, CommandType cmdType, boolean noreply)CommandBinaryCommandFactory. createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandKestrelCommandFactory. createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandTextCommandFactory. createPrependCommand(java.lang.String key, byte[] keyBytes, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandBinaryCommandFactory. createQuitCommand()CommandKestrelCommandFactory. createQuitCommand()CommandTextCommandFactory. createQuitCommand()CommandBinaryCommandFactory. createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandKestrelCommandFactory. createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandTextCommandFactory. createReplaceCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandBinaryCommandFactory. createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandKestrelCommandFactory. createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandTextCommandFactory. createSetCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, boolean noreply, Transcoder transcoder)CommandTextCommandFactory. createStatsCachedumpCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, int slabId, int limit)CommandBinaryCommandFactory. createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)CommandKestrelCommandFactory. createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)CommandTextCommandFactory. createStatsCommand(java.net.InetSocketAddress server, java.util.concurrent.CountDownLatch latch, java.lang.String itemName)(package private) CommandBinaryCommandFactory. createStoreCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, CommandType cmdType, boolean noreply, Transcoder transcoder)(package private) CommandTextCommandFactory. createStoreCommand(java.lang.String key, byte[] keyBytes, int exp, java.lang.Object value, CommandType cmdType, boolean noreply, Transcoder transcoder)CommandBinaryCommandFactory. createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)CommandKestrelCommandFactory. createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)CommandTextCommandFactory. createTouchCommand(java.lang.String key, byte[] keyBytes, java.util.concurrent.CountDownLatch latch, int exp, boolean noreply)CommandBinaryCommandFactory. createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)CommandKestrelCommandFactory. createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)CommandTextCommandFactory. createVerbosityCommand(java.util.concurrent.CountDownLatch latch, int level, boolean noreply)Create verbosity commandCommandBinaryCommandFactory. createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)CommandKestrelCommandFactory. createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)CommandTextCommandFactory. createVersionCommand(java.util.concurrent.CountDownLatch latch, java.net.InetSocketAddress server)Methods in net.rubyeye.xmemcached.command that return types with arguments of type Command Modifier and Type Method Description java.util.List<Command>AssocCommandAware. getAssocCommands()java.util.Map<java.lang.Object,Command>MergeCommandsAware. getMergeCommands()Method parameters in net.rubyeye.xmemcached.command with type arguments of type Command Modifier and Type Method Description voidAssocCommandAware. setAssocCommands(java.util.List<Command> assocCommands)voidMergeCommandsAware. setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands) -
Uses of Command in net.rubyeye.xmemcached.command.binary
Subclasses of Command in net.rubyeye.xmemcached.command.binary Modifier and Type Class Description classBaseBinaryCommandBase Binary command.classBinaryAppendPrependCommandBinary protocol for append,prependclassBinaryAuthListMechanismsCommandList auth mechanisms commandclassBinaryAuthStartCommandAuth start commandclassBinaryAuthStepCommandAuth step commandclassBinaryAWSElasticCacheConfigCommandAWS ElasticCache config commandclassBinaryCASCommandCAS binary protocol implementationclassBinaryDeleteCommandBinary delete commandclassBinaryFlushAllCommandFlush command for binary protocolclassBinaryGetAndTouchCommandBinary GAT/GATQ commandclassBinaryGetCommandImplements get/getq,getk/getkq protocolclassBinaryGetMultiCommandA command for holding getkq commandsclassBinaryIncrDecrCommandBinary incr/decr commandclassBinaryNoopCommandImplement noop protocolclassBinaryQuitCommandQuit command for binary protocolclassBinarySetMultiCommandA command for holding getkq commandsclassBinaryStatsCommandStats command for binary protocolclassBinaryStoreCommandBase binary protocol implementationclassBinaryTouchCommandBinary touch commandclassBinaryVerbosityCommandBinary verbosity commandclassBinaryVersionCommandVersion command for binary protocolFields in net.rubyeye.xmemcached.command.binary with type parameters of type Command Modifier and Type Field Description private java.util.List<Command>BinaryGetCommand. assocCommandsprivate java.util.Map<java.lang.Object,Command>BinaryGetMultiCommand. mergeCommandsprivate java.util.Map<java.lang.Object,Command>BinarySetMultiCommand. mergeCommandsMethods in net.rubyeye.xmemcached.command.binary that return types with arguments of type Command Modifier and Type Method Description java.util.List<Command>BinaryGetCommand. getAssocCommands()java.util.Map<java.lang.Object,Command>BinaryGetMultiCommand. getMergeCommands()java.util.Map<java.lang.Object,Command>BinarySetMultiCommand. getMergeCommands()Method parameters in net.rubyeye.xmemcached.command.binary with type arguments of type Command Modifier and Type Method Description voidBinaryGetCommand. setAssocCommands(java.util.List<Command> assocCommands)voidBinaryGetMultiCommand. setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)voidBinarySetMultiCommand. setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands) -
Uses of Command in net.rubyeye.xmemcached.command.kestrel
Subclasses of Command in net.rubyeye.xmemcached.command.kestrel Modifier and Type Class Description classKestrelDeleteCommandclassKestrelFlushAllCommandKestrel flush commandclassKestrelGetCommandKestrel get commandclassKestrelSetCommandkestrel set command -
Uses of Command in net.rubyeye.xmemcached.command.text
Subclasses of Command in net.rubyeye.xmemcached.command.text Modifier and Type Class Description classTextAWSElasticCacheConfigCommandAWS ElasticCache config command, see Adding Auto Discovery To Your Client Library.classTextCacheDumpCommandclassTextCASCommandCAS command for text protocolclassTextDeleteCommandDelete command for text protocolclassTextFlushAllCommandFlushAll command for text protocolclassTextGetCommandAbstract get command for text protocolclassTextGetMultiCommandBulk-get command for text protocolclassTextGetOneCommandGet command for text protocolclassTextIncrDecrCommandIncr/Decr command for text protocolclassTextQuitCommandQuit command for text protocolclassTextStatsCachedumpCommandclassTextStatsCommandStats command for text protocolclassTextStoreCommandStore command for text protocolclassTextTouchCommandTouch command for touch protocol.classTextVerbosityCommandVerbosity command for text protocolclassTextVersionCommandVersion command for text protocolFields in net.rubyeye.xmemcached.command.text with type parameters of type Command Modifier and Type Field Description protected java.util.List<Command>TextGetCommand. assocCommandsWhen MemcachedClient merge get commands,those commans which have the same key will be merged into one get command.The result command's assocCommands contains all these commands with the same key.protected java.util.Map<java.lang.Object,Command>TextGetCommand. mergeCommandsMethods in net.rubyeye.xmemcached.command.text that return types with arguments of type Command Modifier and Type Method Description java.util.List<Command>TextGetCommand. getAssocCommands()java.util.Map<java.lang.Object,Command>TextGetCommand. getMergeCommands()Method parameters in net.rubyeye.xmemcached.command.text with type arguments of type Command Modifier and Type Method Description voidTextGetCommand. setAssocCommands(java.util.List<Command> assocCommands)voidTextGetCommand. setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands) -
Uses of Command in net.rubyeye.xmemcached.impl
Fields in net.rubyeye.xmemcached.impl declared as Command Modifier and Type Field Description (package private) CommandOptimizer.BinaryGetQCollector. prevCommandprivate CommandMemcachedHandler.CheckHeartResultThread. versionCommandFields in net.rubyeye.xmemcached.impl with type parameters of type Command Modifier and Type Field Description protected java.util.concurrent.BlockingQueue<Command>MemcachedTCPSession. commandAlreadySentCommand which are already sentprivate java.util.concurrent.atomic.AtomicReference<Command>MemcachedTCPSession. currentCommand(package private) java.util.Map<java.lang.Object,Command>Optimizer.BinarySetQCollector. mergeCommandsprivate java.lang.ThreadLocal<java.util.List<Command>>Optimizer. threadLocalMethods in net.rubyeye.xmemcached.impl that return Command Modifier and Type Method Description CommandMemcachedTCPSession. getCurrentCommand()private CommandOptimizer. mergeBuffer(Command firstCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)private CommandOptimizer. mergeGetCommands(Command currentCmd, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, CommandType expectedCommandType)private CommandOptimizer. mergeSetCommands(Command currentCmd, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, CommandType expectedCommandType, int sendBufferSize)private CommandOptimizer. newMergedCommand(java.util.Map<java.lang.Object,Command> mergeCommands, int mergeCount, Optimizer.CommandCollector commandCollector, CommandType commandType)CommandOptimizer. optimiezeGet(java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, Command optimiezeCommand)Merge get operation to multi-get operationCommandOptimizer. optimiezeMergeBuffer(Command optimiezeCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)merge buffers to fit socket's send buffer sizeCommandOptimizer. optimiezeSet(java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize)CommandOptimizer. optimize(Command currentCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)private CommandMemcachedTCPSession. takeExecutingCommand()get current command from queueMethods in net.rubyeye.xmemcached.impl that return types with arguments of type Command Modifier and Type Method Description java.util.List<Command>Optimizer. getLocalList()Methods in net.rubyeye.xmemcached.impl with parameters of type Command Modifier and Type Method Description voidMemcachedTCPSession. addCommand(Command command)private CommandOptimizer. mergeBuffer(Command firstCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)private CommandOptimizer. mergeGetCommands(Command currentCmd, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, CommandType expectedCommandType)private CommandOptimizer. mergeSetCommands(Command currentCmd, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, CommandType expectedCommandType, int sendBufferSize)CommandOptimizer. optimiezeGet(java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, Command optimiezeCommand)Merge get operation to multi-get operationCommandOptimizer. optimiezeMergeBuffer(Command optimiezeCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)merge buffers to fit socket's send buffer sizeCommandOptimizer. optimiezeSet(java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize)CommandOptimizer. optimize(Command currentCommand, java.util.Queue writeQueue, java.util.Queue<Command> executingCmds, int sendBufferSize)SessionMemcachedConnector. send(Command msg)voidMemcachedTCPSession. setCurrentCommand(Command cmd)voidOptimizer.BinaryGetQCollector. visit(Command command)voidOptimizer.BinarySetQCollector. visit(Command command)voidOptimizer.CommandCollector. visit(Command command)voidOptimizer.KeyStringCollector. visit(Command command)Method parameters in net.rubyeye.xmemcached.impl with type arguments of type Command Modifier and Type Method Description private CommandOptimizer. newMergedCommand(java.util.Map<java.lang.Object,Command> mergeCommands, int mergeCount, Optimizer.CommandCollector commandCollector, CommandType commandType)Constructors in net.rubyeye.xmemcached.impl with parameters of type Command Constructor Description CheckHeartResultThread(Command versionCommand, Session session) -
Uses of Command in net.rubyeye.xmemcached.networking
Methods in net.rubyeye.xmemcached.networking with parameters of type Command Modifier and Type Method Description SessionConnector. send(Command packet)
-