voldemort.store.readonly.swapper
Class HttpStoreSwapper

java.lang.Object
  voldemort.store.readonly.swapper.StoreSwapper
      voldemort.store.readonly.swapper.HttpStoreSwapper

public class HttpStoreSwapper
extends StoreSwapper

Field Summary

Fields inherited from class voldemort.store.readonly.swapper.StoreSwapper

cluster, executor

Constructor Summary

HttpStoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor, org.apache.http.client.HttpClient httpClient, java.lang.String readOnlyMgmtPath)

HttpStoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor, org.apache.http.client.HttpClient httpClient, java.lang.String readOnlyMgmtPath, boolean deleteFailedFetch, boolean rollbackFailedSwap)

Method Summary

java.util.List<java.lang.String>	invokeFetch(java.lang.String storeName, java.lang.String basePath, long pushVersion)
void	invokeRollback(java.lang.String storeName, long pushVersion)
void	invokeSwap(java.lang.String storeName, java.util.List<java.lang.String> fetchFiles)

Methods inherited from class voldemort.store.readonly.swapper.StoreSwapper

main, swapStoreData

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpStoreSwapper

public HttpStoreSwapper(Cluster cluster,
                        java.util.concurrent.ExecutorService executor,
                        org.apache.http.client.HttpClient httpClient,
                        java.lang.String readOnlyMgmtPath,
                        boolean deleteFailedFetch,
                        boolean rollbackFailedSwap)

HttpStoreSwapper

public HttpStoreSwapper(Cluster cluster,
                        java.util.concurrent.ExecutorService executor,
                        org.apache.http.client.HttpClient httpClient,
                        java.lang.String readOnlyMgmtPath)

Method Detail

invokeFetch

public java.util.List<java.lang.String> invokeFetch(java.lang.String storeName,
                                                    java.lang.String basePath,
                                                    long pushVersion)

Specified by:

invokeFetch in class StoreSwapper

invokeSwap

public void invokeSwap(java.lang.String storeName,
                       java.util.List<java.lang.String> fetchFiles)

Specified by:

invokeSwap in class StoreSwapper

invokeRollback

public void invokeRollback(java.lang.String storeName,
                           long pushVersion)

Specified by:

invokeRollback in class StoreSwapper