Package com.linkedin.venice.listener

Class StatsHandler

  • All Implemented Interfaces:
    io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler
    public class StatsHandler
extends io.netty.channel.ChannelDuplexHandler

    • Method Detail

      • setResponseStatus

        public void setResponseStatus​(io.netty.handler.codec.http.HttpResponseStatus status)

      • setStoreName

        public void setStoreName​(java.lang.String name)

      • setMetadataRequest

        public void setMetadataRequest​(boolean metadataRequest)

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

      • setMisroutedStoreVersionRequest

        public void setMisroutedStoreVersionRequest​(boolean misroutedStoreVersionRequest)

      • channelRead

        public void channelRead​(io.netty.channel.ChannelHandlerContext ctx,
                        java.lang.Object msg)
        Specified by:
        channelRead in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelRead in class io.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 interface io.netty.channel.ChannelOutboundHandler
        Overrides:
        write in class io.netty.channel.ChannelDuplexHandler
        Throws:
        VeniceException