Package com.linkedin.venice.router.api

Class RouterExceptionAndTrackingUtils

java.lang.Object

com.linkedin.venice.router.api.RouterExceptionAndTrackingUtils

public class RouterExceptionAndTrackingUtils
extends Object

Right now, there is no simple way to capture all the exception cases with DDS Router. So we temporarily track all the error cases when throwing a exception. TODO: If later on DDS router could support a better way to register a handler to handle the exceptional cases, we should update the logic here.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	RouterExceptionAndTrackingUtils.FailureType

Constructor Summary

Constructors

Constructor	Description
RouterExceptionAndTrackingUtils()

Method Summary

Modifier and Type	Method	Description
static RouterException	newRouterExceptionAndTracking(String storeName, RequestType requestType, io.netty.handler.codec.http.HttpResponseStatus responseStatus, String msg)
static RouterException	newRouterExceptionAndTracking(String storeName, RequestType requestType, io.netty.handler.codec.http.HttpResponseStatus responseStatus, String msg, RouterExceptionAndTrackingUtils.FailureType failureType)
static RouterException	newRouterExceptionAndTrackingResourceNotFound(String storeName, RequestType requestType, io.netty.handler.codec.http.HttpResponseStatus responseStatus, String msg)
static VeniceException	newVeniceExceptionAndTracking(String storeName, RequestType requestType, io.netty.handler.codec.http.HttpResponseStatus responseStatus, String msg)	Deprecated.
static VeniceException	newVeniceExceptionAndTracking(String storeName, RequestType requestType, io.netty.handler.codec.http.HttpResponseStatus responseStatus, String msg, RouterExceptionAndTrackingUtils.FailureType failureType)	Deprecated.
static void	recordUnavailableReplicaStreamingRequest(String storeName, RequestType requestType)
static void	setRouterStats(RouterStats<AggRouterHttpRequestStats> routerStats)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RouterExceptionAndTrackingUtils

public RouterExceptionAndTrackingUtils()

Method Details

setRouterStats

public static void setRouterStats(RouterStats<AggRouterHttpRequestStats> routerStats)

newRouterExceptionAndTracking

public static RouterException newRouterExceptionAndTracking(String storeName,
 RequestType requestType,
 io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 String msg,
 RouterExceptionAndTrackingUtils.FailureType failureType)

newRouterExceptionAndTracking

public static RouterException newRouterExceptionAndTracking(String storeName,
 RequestType requestType,
 io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 String msg)

newRouterExceptionAndTrackingResourceNotFound

public static RouterException newRouterExceptionAndTrackingResourceNotFound(String storeName,
 RequestType requestType,
 io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 String msg)

newVeniceExceptionAndTracking

@Deprecated
public static VeniceException newVeniceExceptionAndTracking(String storeName,
 RequestType requestType,
 io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 String msg,
 RouterExceptionAndTrackingUtils.FailureType failureType)

Deprecated.

newVeniceExceptionAndTracking

@Deprecated
public static VeniceException newVeniceExceptionAndTracking(String storeName,
 RequestType requestType,
 io.netty.handler.codec.http.HttpResponseStatus responseStatus,
 String msg)

Deprecated.

recordUnavailableReplicaStreamingRequest

public static void recordUnavailableReplicaStreamingRequest(String storeName,
 RequestType requestType)