|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use AdminClient | |
|---|---|
| voldemort.client.rebalance | All classes associated with the rebalance controller tool. |
| voldemort.server.gossip | Classes associated with the Gossip feature. |
| voldemort.store.readonly.swapper | Classes used for fetching and swapping read-only stores. |
| voldemort.utils | Basic helper functions. |
| Uses of AdminClient in voldemort.client.rebalance |
|---|
| Methods in voldemort.client.rebalance that return AdminClient | |
|---|---|
AdminClient |
RebalanceController.getAdminClient()
|
| Uses of AdminClient in voldemort.server.gossip |
|---|
| Constructors in voldemort.server.gossip with parameters of type AdminClient | |
|---|---|
Gossiper(MetadataStore metadataStore,
AdminClient adminClient,
int gossipInterval)
Create a Gossiper object, which implements Runnable allowing it to be
run as a thread or be submitted to an Executor. |
|
| Uses of AdminClient in voldemort.store.readonly.swapper |
|---|
| Constructors in voldemort.store.readonly.swapper with parameters of type AdminClient | |
|---|---|
AdminStoreSwapper(Cluster cluster,
java.util.concurrent.ExecutorService executor,
AdminClient adminClient,
long timeoutMs)
|
|
AdminStoreSwapper(Cluster cluster,
java.util.concurrent.ExecutorService executor,
AdminClient adminClient,
long timeoutMs,
boolean deleteFailedFetch,
boolean rollbackFailedSwap)
|
|
| Uses of AdminClient in voldemort.utils |
|---|
| Methods in voldemort.utils that return AdminClient | |
|---|---|
static AdminClient |
RebalanceUtils.createTempAdminClient(VoldemortConfig voldemortConfig,
Cluster cluster,
int numConnPerNode)
|
| Methods in voldemort.utils with parameters of type AdminClient | |
|---|---|
static Versioned<Cluster> |
RebalanceUtils.getLatestCluster(java.util.List<java.lang.Integer> requiredNodes,
AdminClient adminClient)
Get the latest cluster from all available nodes in the cluster Throws exception if: A) Any node in the required nodes list fails to respond. B) Cluster is in inconsistent state with concurrent versions for cluster metadata on any two nodes. |
static java.util.List<StoreDefinition> |
RebalanceUtils.getStoreDefinition(Cluster cluster,
AdminClient adminClient)
Given the cluster metadata and admin client, retrieves the list of store definitions. |
static void |
RebalanceUtils.propagateCluster(AdminClient adminClient,
Cluster cluster)
Attempt to propagate a cluster definition to all nodes. |
static void |
RebalanceUtils.validateClusterState(Cluster cluster,
AdminClient adminClient)
Check the execution state of the server by checking the state of MetadataStore.VoldemortState This function checks if the nodes are all in normal state ( MetadataStore.VoldemortState.NORMAL_SERVER). |
static void |
RebalanceUtils.validateReadOnlyStores(Cluster cluster,
java.util.List<StoreDefinition> storeDefs,
AdminClient adminClient)
Given a list of store definitions, cluster and admin client returns a boolean indicating if all RO stores are in the correct format. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||