public class Optimizer extends Object implements OptimizerMBean, MemcachedOptimizer
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MERGE_FACTOR |
Modifier and Type | Method and Description |
---|---|
List<Command> |
getLocalList() |
int |
getMergeFactor() |
boolean |
isOptimizeGet() |
boolean |
isOptimizeMergeBuffer() |
Command |
optimiezeGet(Queue writeQueue,
Queue<Command> executingCmds,
Command optimiezeCommand)
Merge get operation to multi-get operation
|
Command |
optimiezeMergeBuffer(Command optimiezeCommand,
Queue writeQueue,
Queue<Command> executingCmds,
int sendBufferSize)
merge buffers to fit socket's send buffer size
|
Command |
optimiezeSet(Queue writeQueue,
Queue<Command> executingCmds,
Command optimiezeCommand,
int sendBufferSize) |
Command |
optimize(Command currentCommand,
Queue writeQueue,
Queue<Command> executingCmds,
int sendBufferSize) |
void |
setBufferAllocator(BufferAllocator bufferAllocator) |
void |
setMergeFactor(int mergeFactor) |
void |
setOptimizeGet(boolean optimiezeGet) |
void |
setOptimizeMergeBuffer(boolean optimiezeMergeBuffer) |
public static final int DEFAULT_MERGE_FACTOR
public Optimizer(Protocol protocol)
public void setBufferAllocator(BufferAllocator bufferAllocator)
setBufferAllocator
in interface MemcachedOptimizer
public int getMergeFactor()
getMergeFactor
in interface OptimizerMBean
public void setMergeFactor(int mergeFactor)
setMergeFactor
in interface OptimizerMBean
public boolean isOptimizeGet()
isOptimizeGet
in interface OptimizerMBean
public void setOptimizeGet(boolean optimiezeGet)
setOptimizeGet
in interface OptimizerMBean
public boolean isOptimizeMergeBuffer()
isOptimizeMergeBuffer
in interface OptimizerMBean
public void setOptimizeMergeBuffer(boolean optimiezeMergeBuffer)
setOptimizeMergeBuffer
in interface OptimizerMBean
public Command optimize(Command currentCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)
optimize
in interface MemcachedOptimizer
public final Command optimiezeMergeBuffer(Command optimiezeCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)
currentCommand
- InterruptedException
public final Command optimiezeGet(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand)
currentCmd
- mergeCommands
- InterruptedException
public final Command optimiezeSet(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize)
Copyright © 2021. All rights reserved.