org.zodiac.actuate.loadbalancer.stats

类 StatsAppLoadBalancerLifecycle

java.lang.Object

org.zodiac.actuate.loadbalancer.stats.StatsAppLoadBalancerLifecycle

所有已实现的接口:

AppLoadBalancerLifecycle<Object,Object,AppInstance>

public class StatsAppLoadBalancerLifecycle
extends Object
implements AppLoadBalancerLifecycle<Object,Object,AppInstance>

字段概要

字段

限定符和类型	字段和说明
private ConcurrentHashMap<AppInstance,AtomicLong>	activeRequestsPerInstance
private io.micrometer.core.instrument.MeterRegistry	meterRegistry
private static String	REQUESTS_METRICS_PREFIX

构造器概要

构造器

构造器和说明
StatsAppLoadBalancerLifecycle(io.micrometer.core.instrument.MeterRegistry meterRegistry)

方法概要

限定符和类型	方法和说明
void	onComplete(AppCompletionContext<Object,AppInstance,Object> completionContext)
void	onStart(AppRequest<Object> request)
void	onStartRequest(AppRequest<Object> request, AppResponse<AppInstance> lbResponse)
private boolean	requestHasBeenTimed(Object loadBalancerRequestContext)
boolean	supports(Class requestContextClass, Class responseClass, Class serverTypeClass)

从类继承的方法 java.lang.Object

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

字段详细资料

REQUESTS_METRICS_PREFIX

private static final String REQUESTS_METRICS_PREFIX

meterRegistry

private final io.micrometer.core.instrument.MeterRegistry meterRegistry

activeRequestsPerInstance

private final ConcurrentHashMap<AppInstance,AtomicLong> activeRequestsPerInstance

构造器详细资料

StatsAppLoadBalancerLifecycle

public StatsAppLoadBalancerLifecycle(io.micrometer.core.instrument.MeterRegistry meterRegistry)

方法详细资料

supports

public boolean supports(Class requestContextClass,
                        Class responseClass,
                        Class serverTypeClass)

指定者:

supports 在接口中 AppLoadBalancerLifecycle<Object,Object,AppInstance>

onStart

public void onStart(AppRequest<Object> request)

指定者:

onStart 在接口中 AppLoadBalancerLifecycle<Object,Object,AppInstance>

onStartRequest

public void onStartRequest(AppRequest<Object> request,
                           AppResponse<AppInstance> lbResponse)

指定者:

onStartRequest 在接口中 AppLoadBalancerLifecycle<Object,Object,AppInstance>

onComplete

public void onComplete(AppCompletionContext<Object,AppInstance,Object> completionContext)

指定者:

onComplete 在接口中 AppLoadBalancerLifecycle<Object,Object,AppInstance>

requestHasBeenTimed

private boolean requestHasBeenTimed(Object loadBalancerRequestContext)