public class StreamCountFilter
extends java.lang.Object
implements com.linkedin.r2.filter.message.stream.StreamFilter
| Constructor and Description |
|---|
StreamCountFilter() |
| Modifier and Type | Method and Description |
|---|---|
int |
getStreamErrCount() |
int |
getStreamReqCount() |
int |
getStreamResCount() |
void |
onStreamError(java.lang.Throwable ex,
com.linkedin.r2.message.RequestContext requestContext,
java.util.Map<java.lang.String,java.lang.String> wireAttrs,
com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter) |
void |
onStreamRequest(com.linkedin.r2.message.stream.StreamRequest req,
com.linkedin.r2.message.RequestContext requestContext,
java.util.Map<java.lang.String,java.lang.String> wireAttrs,
com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter) |
void |
onStreamResponse(com.linkedin.r2.message.stream.StreamResponse res,
com.linkedin.r2.message.RequestContext requestContext,
java.util.Map<java.lang.String,java.lang.String> wireAttrs,
com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter) |
void |
reset() |
public int getStreamReqCount()
public int getStreamResCount()
public int getStreamErrCount()
public void reset()
public void onStreamRequest(com.linkedin.r2.message.stream.StreamRequest req,
com.linkedin.r2.message.RequestContext requestContext,
java.util.Map<java.lang.String,java.lang.String> wireAttrs,
com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)
onStreamRequest in interface com.linkedin.r2.filter.message.stream.StreamFilterpublic void onStreamResponse(com.linkedin.r2.message.stream.StreamResponse res,
com.linkedin.r2.message.RequestContext requestContext,
java.util.Map<java.lang.String,java.lang.String> wireAttrs,
com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)
onStreamResponse in interface com.linkedin.r2.filter.message.stream.StreamFilterpublic void onStreamError(java.lang.Throwable ex,
com.linkedin.r2.message.RequestContext requestContext,
java.util.Map<java.lang.String,java.lang.String> wireAttrs,
com.linkedin.r2.filter.NextFilter<com.linkedin.r2.message.stream.StreamRequest,com.linkedin.r2.message.stream.StreamResponse> nextFilter)
onStreamError in interface com.linkedin.r2.filter.message.stream.StreamFilter