voldemort.client
Class AbstractStoreClientFactory

java.lang.Object
  voldemort.client.AbstractStoreClientFactory

All Implemented Interfaces:

StoreClientFactory

Direct Known Subclasses:

HttpStoreClientFactory, SocketStoreClientFactory

public abstract class AbstractStoreClientFactory
extends java.lang.Object
implements StoreClientFactory

A base class for various StoreClientFactory implementations

Field Summary

protected static ClusterMapper	clusterMapper
static int	DEFAULT_ROUTING_TIMEOUT_MS
protected FailureDetector	failureDetector
protected java.lang.String	identifierString
protected static org.apache.log4j.Logger	logger
static int	MAX_METADATA_REFRESH_ATTEMPTS

Constructor Summary

AbstractStoreClientFactory(ClientConfig config)

Method Summary

java.lang.String	bootstrapMetadataWithRetries(java.lang.String key)
java.lang.String	bootstrapMetadataWithRetries(java.lang.String key, java.net.URI[] urls)
void	close() Close the store client
protected java.lang.String	getClientContext()
Cluster	getCluster()
protected ClientConfig	getConfig()
int	getCurrentJmxId()
FailureDetector	getFailureDetector() Returns the FailureDetector specific to the cluster against which this client factory is based.
int	getNextJmxId()
protected abstract int	getPort(Node node)
<K,V,T> Store<K,V,T>	getRawStore(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver) Get the underlying store, not the public StoreClient interface
<K,V,T> Store<K,V,T>	getRawStore(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver, java.lang.String customStoresXml, java.lang.String clusterXmlString, FailureDetector fd)
protected java.util.List<Versioned<java.lang.String>>	getRemoteMetadata(java.lang.String key, java.net.URI url)
RequestFormatType	getRequestFormatType()
SerializerFactory	getSerializerFactory()
protected abstract Store<ByteArray,byte[],byte[]>	getStore(java.lang.String storeName, java.lang.String host, int port, RequestFormatType type)
<K,V> StoreClient<K,V>	getStoreClient(java.lang.String storeName) Get a StoreClient for the given store.
<K,V> StoreClient<K,V>	getStoreClient(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver) Get a StoreClient for the given store.
java.util.List<StoreDefinition>	getStoreDefs()
protected abstract FailureDetector	initFailureDetector(ClientConfig config, Cluster cluster)
protected abstract void	validateUrl(java.net.URI url)
java.net.URI[]	validateUrls(java.lang.String[] urls)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_ROUTING_TIMEOUT_MS

public static final int DEFAULT_ROUTING_TIMEOUT_MS

See Also:

Constant Field Values

MAX_METADATA_REFRESH_ATTEMPTS

public static final int MAX_METADATA_REFRESH_ATTEMPTS

See Also:

Constant Field Values

clusterMapper

protected static final ClusterMapper clusterMapper

logger

protected static final org.apache.log4j.Logger logger

identifierString

protected final java.lang.String identifierString

failureDetector

protected volatile FailureDetector failureDetector

Constructor Detail

AbstractStoreClientFactory

public AbstractStoreClientFactory(ClientConfig config)

Method Detail

getNextJmxId

public int getNextJmxId()

getCurrentJmxId

public int getCurrentJmxId()

getStoreClient

public <K,V> StoreClient<K,V> getStoreClient(java.lang.String storeName)

Description copied from interface: StoreClientFactory

Get a StoreClient for the given store.

Specified by:

getStoreClient in interface StoreClientFactory

Type Parameters:

K - The type of the key of the StoreClient

V - The type of the value of the StoreClient

Parameters:

storeName - The name of the store

Returns:

A fully constructed StoreClient

getStoreClient

public <K,V> StoreClient<K,V> getStoreClient(java.lang.String storeName,
                                             InconsistencyResolver<Versioned<V>> resolver)

Description copied from interface: StoreClientFactory

Get a StoreClient for the given store.

Specified by:

getStoreClient in interface StoreClientFactory

Type Parameters:

K - The type of the key of the StoreClient

V - The type of the value of the StoreClient

Parameters:

storeName - The name of the store

resolver - The InconsistencyResolver that should be used to resolve inconsistencies.

Returns:

A fully constructed StoreClient

getRawStore

public <K,V,T> Store<K,V,T> getRawStore(java.lang.String storeName,
                                        InconsistencyResolver<Versioned<V>> resolver)

Description copied from interface: StoreClientFactory

Get the underlying store, not the public StoreClient interface

Specified by:

getRawStore in interface StoreClientFactory

Parameters:

storeName - The name of the store

resolver - The inconsistency resolver

Returns:

The appropriate store

getRawStore

public <K,V,T> Store<K,V,T> getRawStore(java.lang.String storeName,
                                        InconsistencyResolver<Versioned<V>> resolver,
                                        java.lang.String customStoresXml,
                                        java.lang.String clusterXmlString,
                                        FailureDetector fd)

getConfig

protected ClientConfig getConfig()

initFailureDetector

protected abstract FailureDetector initFailureDetector(ClientConfig config,
                                                       Cluster cluster)

getFailureDetector

public FailureDetector getFailureDetector()

Description copied from interface: StoreClientFactory

Returns the FailureDetector specific to the cluster against which this client factory is based.

Specified by:

getFailureDetector in interface StoreClientFactory

Returns:

FailureDetector

bootstrapMetadataWithRetries

public java.lang.String bootstrapMetadataWithRetries(java.lang.String key,
                                                     java.net.URI[] urls)

bootstrapMetadataWithRetries

public java.lang.String bootstrapMetadataWithRetries(java.lang.String key)

getRemoteMetadata

protected java.util.List<Versioned<java.lang.String>> getRemoteMetadata(java.lang.String key,
                                                                        java.net.URI url)

validateUrls

public java.net.URI[] validateUrls(java.lang.String[] urls)

getStore

protected abstract Store<ByteArray,byte[],byte[]> getStore(java.lang.String storeName,
                                                           java.lang.String host,
                                                           int port,
                                                           RequestFormatType type)

getPort

protected abstract int getPort(Node node)

validateUrl

protected abstract void validateUrl(java.net.URI url)

getSerializerFactory

public SerializerFactory getSerializerFactory()

getRequestFormatType

public RequestFormatType getRequestFormatType()

close

public void close()

Description copied from interface: StoreClientFactory

Close the store client

Specified by:

close in interface StoreClientFactory

getClientContext

protected java.lang.String getClientContext()

getCluster

public Cluster getCluster()

getStoreDefs

public java.util.List<StoreDefinition> getStoreDefs()