Package com.linkedin.venice.listener
Class StatsHandler
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.channel.ChannelDuplexHandler
-
- com.linkedin.venice.listener.StatsHandler
-
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
,io.netty.channel.ChannelOutboundHandler
public class StatsHandler extends io.netty.channel.ChannelDuplexHandler
-
-
Constructor Summary
Constructors Constructor Description StatsHandler(AggServerHttpRequestStats singleGetStats, AggServerHttpRequestStats multiGetStats, AggServerHttpRequestStats computeStats)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
channelRead(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg)
ServerStatsContext
getNewStatsContext()
long
getRequestStartTimeInNS()
ServerStatsContext
getServerStatsContext()
boolean
isAssembledMultiChunkLargeValue()
void
setCosineSimilarityCount(int count)
void
setCountOperatorCount(int count)
void
setDatabaseLookupLatency(double latency)
void
setDotProductCount(int count)
void
setHadamardProductCount(int count)
void
setHealthCheck(boolean healthCheck)
void
setKeySizeList(it.unimi.dsi.fastutil.ints.IntList keySizeList)
void
setMisroutedStoreVersionRequest(boolean misroutedStoreVersionRequest)
void
setMultiChunkLargeValueCount(int multiChunkLargeValueCount)
void
setReadComputeDeserializationLatency(double latency)
void
setReadComputeLatency(double latency)
void
setReadComputeOutputSize(int readComputeOutputSize)
void
setReadComputeSerializationLatency(double latency)
void
setRequestInfo(RouterRequest request)
void
setRequestKeyCount(int keyCount)
void
setRequestSize(int requestSizeInBytes)
void
setRequestTerminatedEarly()
void
setRequestType(RequestType requestType)
void
setResponseStatus(io.netty.handler.codec.http.HttpResponseStatus status)
void
setStorageExecutionHandlerSubmissionWaitTime(double storageExecutionSubmissionWaitTime)
void
setStorageExecutionQueueLen(int storageExecutionQueueLen)
void
setStoreName(java.lang.String name)
void
setSuccessRequestKeyCount(int successKeyCount)
void
setValueSize(int valueSize)
void
setValueSizeList(it.unimi.dsi.fastutil.ints.IntList valueSizeList)
void
write(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg, io.netty.channel.ChannelPromise promise)
-
Methods inherited from class io.netty.channel.ChannelDuplexHandler
bind, close, connect, deregister, disconnect, flush, read
-
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
-
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
-
-
-
-
Constructor Detail
-
StatsHandler
public StatsHandler(AggServerHttpRequestStats singleGetStats, AggServerHttpRequestStats multiGetStats, AggServerHttpRequestStats computeStats)
-
-
Method Detail
-
getNewStatsContext
public ServerStatsContext getNewStatsContext()
-
setResponseStatus
public void setResponseStatus(io.netty.handler.codec.http.HttpResponseStatus status)
-
setStoreName
public void setStoreName(java.lang.String name)
-
setHealthCheck
public void setHealthCheck(boolean healthCheck)
-
setRequestTerminatedEarly
public void setRequestTerminatedEarly()
-
setRequestType
public void setRequestType(RequestType requestType)
-
setRequestKeyCount
public void setRequestKeyCount(int keyCount)
-
setRequestInfo
public void setRequestInfo(RouterRequest request)
-
setRequestSize
public void setRequestSize(int requestSizeInBytes)
-
setSuccessRequestKeyCount
public void setSuccessRequestKeyCount(int successKeyCount)
-
setDatabaseLookupLatency
public void setDatabaseLookupLatency(double latency)
-
setReadComputeLatency
public void setReadComputeLatency(double latency)
-
setReadComputeDeserializationLatency
public void setReadComputeDeserializationLatency(double latency)
-
setReadComputeSerializationLatency
public void setReadComputeSerializationLatency(double latency)
-
setDotProductCount
public void setDotProductCount(int count)
-
setCosineSimilarityCount
public void setCosineSimilarityCount(int count)
-
setHadamardProductCount
public void setHadamardProductCount(int count)
-
setCountOperatorCount
public void setCountOperatorCount(int count)
-
setStorageExecutionHandlerSubmissionWaitTime
public void setStorageExecutionHandlerSubmissionWaitTime(double storageExecutionSubmissionWaitTime)
-
setStorageExecutionQueueLen
public void setStorageExecutionQueueLen(int storageExecutionQueueLen)
-
isAssembledMultiChunkLargeValue
public boolean isAssembledMultiChunkLargeValue()
-
setMultiChunkLargeValueCount
public void setMultiChunkLargeValueCount(int multiChunkLargeValueCount)
-
setKeySizeList
public void setKeySizeList(it.unimi.dsi.fastutil.ints.IntList keySizeList)
-
setValueSizeList
public void setValueSizeList(it.unimi.dsi.fastutil.ints.IntList valueSizeList)
-
setValueSize
public void setValueSize(int valueSize)
-
setReadComputeOutputSize
public void setReadComputeOutputSize(int readComputeOutputSize)
-
getRequestStartTimeInNS
public long getRequestStartTimeInNS()
-
getServerStatsContext
public ServerStatsContext getServerStatsContext()
-
setMisroutedStoreVersionRequest
public void setMisroutedStoreVersionRequest(boolean misroutedStoreVersionRequest)
-
channelRead
public void channelRead(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg)
- Specified by:
channelRead
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelRead
in classio.netty.channel.ChannelInboundHandlerAdapter
-
write
public void write(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg, io.netty.channel.ChannelPromise promise) throws VeniceException
- Specified by:
write
in interfaceio.netty.channel.ChannelOutboundHandler
- Overrides:
write
in classio.netty.channel.ChannelDuplexHandler
- Throws:
VeniceException
-
-