Package com.linkedin.alpini.base.pool.impl

Class LifeCycleStatsCollector<T>

java.lang.Object

com.linkedin.alpini.base.pool.impl.LifeCycleFilter<T>

com.linkedin.alpini.base.pool.impl.LifeCycleStatsCollector<T>

All Implemented Interfaces:

AsyncPool.LifeCycle<T>

public class LifeCycleStatsCollector<T>
extends LifeCycleFilter<T>

Constructor Summary

Constructors

Constructor	Description
LifeCycleStatsCollector(AsyncPool.LifeCycle<T> lifeCycle)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<T>	create()
protected CallTracker	createCallTracker()
java.util.concurrent.CompletableFuture<java.lang.Void>	destroy(T entity)
CallTracker.CallStats	getCreateCallStats()
CallTracker.CallStats	getDestroyCallStats()
CallTracker.CallStats	getTestCallStats()
java.util.concurrent.CompletableFuture<java.lang.Boolean>	testAfterIdle(T entity)
java.util.concurrent.CompletableFuture<java.lang.Boolean>	testOnRelease(T entity)

Methods inherited from class com.linkedin.alpini.base.pool.impl.LifeCycleFilter

isWrapperFor, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.alpini.base.pool.AsyncPool.LifeCycle

shutdown

Constructor Detail

LifeCycleStatsCollector

public LifeCycleStatsCollector(@Nonnull
                               AsyncPool.LifeCycle<T> lifeCycle)

Method Detail

createCallTracker

protected CallTracker createCallTracker()

create

public java.util.concurrent.CompletableFuture<T> create()

Specified by:

create in interface AsyncPool.LifeCycle<T>

Overrides:

create in class LifeCycleFilter<T>

getCreateCallStats

public CallTracker.CallStats getCreateCallStats()

testOnRelease

public java.util.concurrent.CompletableFuture<java.lang.Boolean> testOnRelease(T entity)

Specified by:

testOnRelease in interface AsyncPool.LifeCycle<T>

Overrides:

testOnRelease in class LifeCycleFilter<T>

testAfterIdle

public java.util.concurrent.CompletableFuture<java.lang.Boolean> testAfterIdle(T entity)

Specified by:

testAfterIdle in interface AsyncPool.LifeCycle<T>

Overrides:

testAfterIdle in class LifeCycleFilter<T>

getTestCallStats

public CallTracker.CallStats getTestCallStats()

destroy

public java.util.concurrent.CompletableFuture<java.lang.Void> destroy(T entity)

Specified by:

destroy in interface AsyncPool.LifeCycle<T>

Overrides:

destroy in class LifeCycleFilter<T>

getDestroyCallStats

public CallTracker.CallStats getDestroyCallStats()