Package io.milvus.pool

Class PoolClientFactory<C,T>

java.lang.Object

org.apache.commons.pool2.BaseObject

org.apache.commons.pool2.BaseKeyedPooledObjectFactory<String,T>

io.milvus.pool.PoolClientFactory<C,T>

All Implemented Interfaces:

org.apache.commons.pool2.KeyedPooledObjectFactory<String,T>

public class PoolClientFactory<C,T>
extends org.apache.commons.pool2.BaseKeyedPooledObjectFactory<String,T>

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
PoolClientFactory(C configDefault, String clientClassName)

Method Summary

Modifier and Type	Method	Description
void	activateObject(String key, org.apache.commons.pool2.PooledObject<T> p)
void	configForKey(String key, C config)
Set<String>	configKeys()
T	create(String key)
void	destroyObject(String key, org.apache.commons.pool2.PooledObject<T> p)
C	getConfig(String key)
void	passivateObject(String key, org.apache.commons.pool2.PooledObject<T> p)
C	removeConfig(String key)
boolean	validateObject(String key, org.apache.commons.pool2.PooledObject<T> p)
org.apache.commons.pool2.PooledObject<T>	wrap(T client)

Methods inherited from class org.apache.commons.pool2.BaseKeyedPooledObjectFactory

makeObject

Methods inherited from class org.apache.commons.pool2.BaseObject

toString, toStringAppendFields

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.commons.pool2.KeyedPooledObjectFactory

destroyObject

Field Detail

logger

protected static final org.slf4j.Logger logger

Constructor Detail

PoolClientFactory

public PoolClientFactory(C configDefault,
                         String clientClassName)
                  throws ClassNotFoundException,
                         NoSuchMethodException

Throws:

ClassNotFoundException

NoSuchMethodException

Method Detail

configForKey

public void configForKey(String key,
                         C config)

removeConfig

public C removeConfig(String key)

configKeys

public Set<String> configKeys()

getConfig

public C getConfig(String key)

create

public T create(String key)
         throws Exception

Specified by:

create in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<String,T>

Throws:

Exception

wrap

public org.apache.commons.pool2.PooledObject<T> wrap(T client)

Specified by:

wrap in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<String,T>

destroyObject

public void destroyObject(String key,
                          org.apache.commons.pool2.PooledObject<T> p)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<C,T>

Overrides:

destroyObject in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<String,T>

Throws:

Exception

validateObject

public boolean validateObject(String key,
                              org.apache.commons.pool2.PooledObject<T> p)

Specified by:

validateObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<C,T>

Overrides:

validateObject in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<String,T>

activateObject

public void activateObject(String key,
                           org.apache.commons.pool2.PooledObject<T> p)
                    throws Exception

Specified by:

activateObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<C,T>

Overrides:

activateObject in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<String,T>

Throws:

Exception

passivateObject

public void passivateObject(String key,
                            org.apache.commons.pool2.PooledObject<T> p)
                     throws Exception

Specified by:

passivateObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<C,T>

Overrides:

passivateObject in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<String,T>

Throws:

Exception