voldemort.client
Class SocketStoreClientFactory

java.lang.Object
  voldemort.client.AbstractStoreClientFactory
      voldemort.client.SocketStoreClientFactory

All Implemented Interfaces:

StoreClientFactory

public class SocketStoreClientFactory
extends AbstractStoreClientFactory

A StoreClientFactory abstracts away the connection pooling, threading, and bootstrapping mechanism. It can be used to create any number of StoreClient instances for different stores.

Field Summary

static java.lang.String

URL_SCHEME

Fields inherited from class voldemort.client.AbstractStoreClientFactory

clusterMapper, DEFAULT_ROUTING_TIMEOUT_MS, failureDetector, jmxId, logger

Constructor Summary

SocketStoreClientFactory(ClientConfig config)

Method Summary

void	close() Close the store client
protected int	getPort(Node node)
protected java.util.List<Versioned<java.lang.String>>	getRemoteMetadata(java.lang.String key, java.net.URI url)
protected 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, InconsistencyResolver<Versioned<V>> resolver) Get a StoreClient for the given store.
<K,V,T> Store<K,V,T>	getSystemStore(java.lang.String storeName, java.lang.String clusterXml, FailureDetector fd)
protected FailureDetector	initFailureDetector(ClientConfig config, Cluster cluster)
protected void	validateUrl(java.net.URI url)

Methods inherited from class voldemort.client.AbstractStoreClientFactory

bootstrapMetadataWithRetries, bootstrapMetadataWithRetries, getClientContext, getConfig, getCurrentJmxId, getFailureDetector, getNextJmxId, getRawStore, getRawStore, getRequestFormatType, getSerializerFactory, getStoreClient, validateUrls

Methods inherited from class java.lang.Object

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

Field Detail

URL_SCHEME

public static final java.lang.String URL_SCHEME

See Also:

Constant Field Values

Constructor Detail

SocketStoreClientFactory

public SocketStoreClientFactory(ClientConfig config)

Method Detail

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

Overrides:

getStoreClient in class AbstractStoreClientFactory

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

getRemoteMetadata

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

Overrides:

getRemoteMetadata in class AbstractStoreClientFactory

getStore

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

Specified by:

getStore in class AbstractStoreClientFactory

initFailureDetector

protected FailureDetector initFailureDetector(ClientConfig config,
                                              Cluster cluster)

Specified by:

initFailureDetector in class AbstractStoreClientFactory

getPort

protected int getPort(Node node)

Specified by:

getPort in class AbstractStoreClientFactory

validateUrl

protected void validateUrl(java.net.URI url)

Specified by:

validateUrl in class AbstractStoreClientFactory

close

public void close()

Description copied from interface: StoreClientFactory

Close the store client

Specified by:

close in interface StoreClientFactory

Overrides:

close in class AbstractStoreClientFactory

getSystemStore

public <K,V,T> Store<K,V,T> getSystemStore(java.lang.String storeName,
                                           java.lang.String clusterXml,
                                           FailureDetector fd)