|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AdminClient | |
---|---|
voldemort | The root package. |
voldemort.client.protocol.admin | Classes that abstract admin based Voldemort requests. |
voldemort.client.rebalance | All classes associated with the rebalance controller tool. |
voldemort.client.rebalance.task | Classes that encapsulate a specific rebalance task (between a stealer-node and donor-node). |
voldemort.server.gossip | Classes associated with the Gossip feature. |
voldemort.server.rebalance.async | |
voldemort.store.readonly.swapper | Classes used for fetching and swapping read-only stores. |
voldemort.tools | Tools used for administrating a cluster. |
voldemort.tools.admin | |
voldemort.tools.admin.command | |
voldemort.utils | Basic helper functions. |
Uses of AdminClient in voldemort |
---|
Methods in voldemort with parameters of type AdminClient | |
---|---|
static void |
VoldemortAdminTool.executeGetMetadata(java.lang.Integer nodeId,
AdminClient adminClient,
java.lang.String metadataKey,
java.lang.String outputDir)
|
static void |
VoldemortAdminTool.executeSetMetadata(java.lang.Integer nodeId,
AdminClient adminClient,
java.lang.String key,
java.lang.Object value)
|
static void |
VoldemortAdminTool.executeSetMetadataPair(java.lang.Integer nodeId,
AdminClient adminClient,
java.lang.String clusterKey,
java.lang.Object clusterValue,
java.lang.String storesKey,
java.lang.Object storesValue)
|
Uses of AdminClient in voldemort.client.protocol.admin |
---|
Fields in voldemort.client.protocol.admin declared as AdminClient | |
---|---|
protected AdminClient |
BaseStreamingClient.adminClient
|
Methods in voldemort.client.protocol.admin that return AdminClient | |
---|---|
static AdminClient |
AdminClient.createTempAdminClient(VoldemortConfig voldemortConfig,
Cluster cluster,
int numConnPerNode)
Helper method to construct an AdminClient with "good" default settings based upon a VoldemortConfig. |
AdminClient |
BaseStreamingClient.getAdminClient()
|
Uses of AdminClient in voldemort.client.rebalance |
---|
Methods in voldemort.client.rebalance that return AdminClient | |
---|---|
AdminClient |
RebalanceController.getAdminClient()
|
Uses of AdminClient in voldemort.client.rebalance.task |
---|
Fields in voldemort.client.rebalance.task declared as AdminClient | |
---|---|
protected AdminClient |
RebalanceTask.adminClient
|
Constructors in voldemort.client.rebalance.task with parameters of type AdminClient | |
---|---|
RebalanceTask(int batchId,
int taskId,
java.util.List<RebalanceTaskInfo> stealInfos,
java.util.concurrent.Semaphore donorPermit,
AdminClient adminClient,
RebalanceBatchPlanProgressBar progressBar,
org.apache.log4j.Logger logger)
|
|
StealerBasedRebalanceTask(int batchId,
int taskId,
RebalanceTaskInfo stealInfo,
java.util.concurrent.Semaphore donorPermit,
AdminClient adminClient,
RebalanceBatchPlanProgressBar progressBar,
RebalanceScheduler scheduler)
|
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.server.rebalance.async |
---|
Fields in voldemort.server.rebalance.async declared as AdminClient | |
---|---|
protected AdminClient |
RebalanceAsyncOperation.adminClient
|
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.tools |
---|
Fields in voldemort.tools declared as AdminClient | |
---|---|
protected AdminClient |
ZoneShrinkageCLI.adminClient
|
Methods in voldemort.tools with parameters of type AdminClient | |
---|---|
protected static boolean |
ZoneShrinkageCLI.verifyMetadataConsistency(AdminClient adminClient,
java.util.Collection<Node> nodes,
java.lang.String clusterXml,
java.lang.String storesXml)
|
protected static boolean |
ZoneShrinkageCLI.verifyRebalanceState(AdminClient adminClient,
java.util.Collection<Node> nodes)
|
Uses of AdminClient in voldemort.tools.admin |
---|
Methods in voldemort.tools.admin that return AdminClient | |
---|---|
static AdminClient |
AdminToolUtils.getAdminClient(java.lang.String url)
Utility function that constructs AdminClient. |
Methods in voldemort.tools.admin with parameters of type AdminClient | |
---|---|
static void |
AdminToolUtils.assertServerInNormalState(AdminClient adminClient)
Utility function that checks the execution state of the server by checking the state of MetadataStore.VoldemortState This function checks if all nodes of the cluster are in normal state ( MetadataStore.VoldemortState.NORMAL_SERVER ). |
static void |
AdminToolUtils.assertServerInNormalState(AdminClient adminClient,
java.util.Collection<java.lang.Integer> nodeIds)
Utility function that checks the execution state of the server by checking the state of MetadataStore.VoldemortState This function checks if the nodes are in normal state ( MetadataStore.VoldemortState.NORMAL_SERVER ). |
static void |
AdminToolUtils.assertServerInNormalState(AdminClient adminClient,
java.lang.Integer nodeId)
Utility function that checks the execution state of the server by checking the state of MetadataStore.VoldemortState This function checks if a node is in normal state ( MetadataStore.VoldemortState.NORMAL_SERVER ). |
static java.util.List<java.lang.Integer> |
AdminToolUtils.getAllNodeIds(AdminClient adminClient)
Utility function that fetches node ids. |
static java.util.List<java.lang.Integer> |
AdminToolUtils.getAllPartitions(AdminClient adminClient)
Utility function that fetches partitions. |
static java.util.List<java.lang.String> |
AdminToolUtils.getAllUserStoreNamesOnNode(AdminClient adminClient,
java.lang.Integer nodeId)
Utility function that fetches all stores on a node. |
static java.util.Map<java.lang.String,StoreDefinition> |
AdminToolUtils.getUserStoreDefMapOnNode(AdminClient adminClient,
java.lang.Integer nodeId)
Utility function that fetches user defined store definitions |
static void |
AdminToolUtils.validateUserStoreNamesOnNode(AdminClient adminClient,
java.lang.Integer nodeId,
java.util.List<java.lang.String> storeNames)
Utility function that checks if store names are valid on a node. |
Uses of AdminClient in voldemort.tools.admin.command |
---|
Methods in voldemort.tools.admin.command with parameters of type AdminClient | |
---|---|
static void |
AdminCommandAsyncJob.SubCommandAsyncJobList.doAsyncJobList(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds)
Gets list of async jobs across multiple nodes. |
static void |
AdminCommandAsyncJob.SubCommandAsyncJobStop.doAsyncJobStop(AdminClient adminClient,
java.lang.Integer nodeId,
java.util.List<java.lang.Integer> jobIds)
Stop async jobs on a single nodes. |
static void |
AdminCommandCleanup.SubCommandCleanupOrphanedData.doCleanupOrphanedData(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds)
Removes orphaned data on a single node after rebalancing is done. |
static void |
AdminCommandCleanup.SubCommandCleanupVectorClocks.doCleanupVectorClocks(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds,
java.util.List<java.lang.String> storeNames)
Prunes data resulting from versioned puts during rebalancing |
static void |
AdminCommandDebug.SubCommandDebugQueryKeys.doDebugQueryKeys(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds,
java.util.List<java.lang.String> storeNames,
java.util.List<java.lang.String> keyStrings,
java.lang.String keyType)
Queries stores for a set of keys |
static void |
AdminCommandDebug.SubCommandDebugRoute.doDebugRoute(AdminClient adminClient,
java.lang.String storeName,
java.util.List<java.lang.String> keyStrings,
java.lang.String keyType)
Shows detailed routing information for a given set of keys on a store. |
static void |
AdminCommandMeta.SubCommandMetaCheck.doMetaCheck(AdminClient adminClient,
java.util.List<java.lang.String> metaKeys)
Checks if metadata is consistent across all nodes. |
static void |
AdminCommandMeta.SubCommandMetaCheckVersion.doMetaCheckVersion(AdminClient adminClient)
Verifies metadata versions for all the cluster nodes |
static void |
AdminCommandMeta.SubCommandMetaClearRebalance.doMetaClearRebalance(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds)
Removes metadata related to rebalancing. |
static void |
AdminCommandMeta.SubCommandMetaGet.doMetaGet(AdminClient adminClient,
java.util.Collection<java.lang.Integer> nodeIds,
java.util.List<java.lang.String> metaKeys,
java.io.File directory,
java.lang.Boolean verbose)
Gets metadata. |
static void |
AdminCommandMeta.doMetaSet(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds,
java.lang.String metaKey,
java.lang.Object metaValue)
Sets metadata. |
static void |
AdminCommandMeta.SubCommandMetaSet.doMetaSetPair(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds,
java.lang.Object clusterValue,
java.lang.Object storesValue)
Sets |
static void |
AdminCommandMeta.SubCommandMetaSyncVersion.doMetaSyncVersion(AdminClient adminClient,
java.lang.Integer nodeId)
Synchronizes metadata versions across all nodes. |
static void |
AdminCommandMeta.SubCommandMetaSet.doMetaUpdateVersionsOnStores(AdminClient adminClient,
java.util.List<StoreDefinition> oldStoreDefs,
java.util.List<StoreDefinition> newStoreDefs)
Updates metadata versions on stores. |
static void |
AdminCommandQuota.SubCommandQuotaGet.doQuotaGet(AdminClient adminClient,
java.util.List<java.lang.String> storeNames,
java.util.List<java.lang.String> quotaTypes)
Gets quota for given quota types on given stores. |
static void |
AdminCommandQuota.SubCommandQuotaSet.doQuotaSet(AdminClient adminClient,
java.util.List<java.lang.String> storeNames,
java.util.Map<java.lang.String,java.lang.String> quotaMap)
Sets quota for given quota types on given stores. |
static void |
AdminCommandQuota.SubCommandQuotaUnset.doQuotaUnset(AdminClient adminClient,
java.util.List<java.lang.String> storeNames,
java.util.List<java.lang.String> quotaTypes)
Unsets quota for given quota types on given stores. |
static void |
AdminCommandStore.SubCommandStoreAdd.doStoreAdd(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds,
java.lang.String storesFile)
Adds store on given nodes from a given stores.xml file. |
static void |
AdminCommandStore.SubCommandStoreDelete.doStoreDelete(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds,
java.util.List<java.lang.String> storeNames)
Deletes given list of stores on given nodes. |
static void |
AdminCommandStore.SubCommandStoreTruncatePartition.doStoreTruncatePartition(AdminClient adminClient,
java.lang.Integer nodeId,
java.util.List<java.lang.String> storeNames,
java.util.List<java.lang.Integer> partIds)
Removes contents of partitions on a single node. |
static void |
AdminCommandStore.SubCommandStoreTruncateStore.doStoreTruncateStore(AdminClient adminClient,
java.util.List<java.lang.Integer> nodeIds,
java.util.List<java.lang.String> storeNames)
Removes contents of stores. |
static void |
AdminCommandStream.SubCommandStreamFetchEntries.doStreamFetchEntries(AdminClient adminClient,
java.lang.Integer nodeId,
java.util.List<java.lang.String> storeNames,
java.util.List<java.lang.Integer> partIds,
java.lang.Boolean orphaned,
java.io.File directory,
java.lang.String format)
Fetches entries from a given node. |
static void |
AdminCommandStream.SubCommandStreamFetchKeys.doStreamFetchKeys(AdminClient adminClient,
java.lang.Integer nodeId,
java.util.List<java.lang.String> storeNames,
java.util.List<java.lang.Integer> partIds,
java.lang.Boolean orphaned,
java.io.File directory,
java.lang.String format)
Fetches keys from a given node. |
static void |
AdminCommandStream.SubCommandStreamUpdateEntries.doStreamUpdateEntries(AdminClient adminClient,
java.lang.Integer nodeId,
java.util.List<java.lang.String> storeNames,
java.io.File inDir)
Updates entries on a given node. |
Uses of AdminClient in voldemort.utils |
---|
Methods in voldemort.utils that return AdminClient | |
---|---|
AdminClient |
ConsistencyFix.getAdminClient()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |