Examples of AdminClient

com.dotcms.repackage.org.elasticsearch.client.AdminClient
com.ibm.websphere.management.AdminClient
net.greghaines.jesque.admin.AdminClient
An AdminClient publishes jobs to channels. @author Greg Haines
org.apache.axis.client.AdminClient
An admin client object that can be used both from the command line and programmatically. The admin client supports simple logging that allows the output of its operations to be inspected in environments where System.out and System.err should not be used. @author Rob Jellinghaus (robj@unrealities.com) @author Doug Davis (dug@us.ibm.com) @author Simeon Simeonov (simeons@macromedia.com)
org.elasticsearch.client.AdminClient
Administrative actions/operations against the cluster or the indices. @author kimchy (Shay Banon) @see org.elasticsearch.client.Client#admin()
voldemort.client.protocol.admin.AdminClient
AdminClient is intended for administrative functionality that is useful and often needed, but should be used sparingly (if at all) at the application level.
Some of the uses of AdminClient include
- Extraction of data for backups
- Extraction of all keys
- Bulk loading entries
- Migrating partitions
- Get/Update metadata info from selective Nodes
- Used extensively by rebalancing (dynamic node addition/deletion) feature (presently in development).

Examples of voldemort.client.protocol.admin.AdminClient

    }


    public static AdminClient getAdminClient(Cluster cluster) {


        AdminClientConfig config = new AdminClientConfig();
        return new AdminClient(cluster, config, new ClientConfig());
    }

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient

        return new AdminClient(cluster, config, new ClientConfig());
    }


    public static AdminClient getAdminClient(String bootstrapURL) {
        AdminClientConfig config = new AdminClientConfig();
        return new AdminClient(bootstrapURL, config, new ClientConfig());
    }

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient

                               int progressOps,
                               List<String> storesList,
                               List<Integer> partitions,
                               ForkLiftTaskMode mode) {
        // set up AdminClient on source cluster
        this.srcAdminClient = new AdminClient(srcBootstrapUrl,
                                              new AdminClientConfig(),
                                              new ClientConfig());


        // set up streaming client to the destination cluster
        Props props = new Props();

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient


            // execute command
            if(!AdminToolUtils.askConfirm(confirm, "remove metadata related to rebalancing")) {
                return;
            }
            AdminClient adminClient = AdminToolUtils.getAdminClient(url);


            if(allNodes) {
                nodeIds = AdminToolUtils.getAllNodeIds(adminClient);
            }

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient

                verbose = true;
            }


            // execute command
            File directory = AdminToolUtils.createDir(dir);
            AdminClient adminClient = AdminToolUtils.getAdminClient(url);


            if(allNodes) {
                nodeIds = AdminToolUtils.getAllNodeIds(adminClient);
            }

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient

            // execute command
            if(!AdminToolUtils.askConfirm(confirm, "set metadata")) {
                return;
            }


            AdminClient adminClient = AdminToolUtils.getAdminClient(url);


            if(allNodes) {
                nodeIds = AdminToolUtils.getAllNodeIds(adminClient);
            }

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient

                format = AdminParserUtils.ARG_FORMAT_JSON;
            }


            // execute command
            File directory = AdminToolUtils.createDir(dir);
            AdminClient adminClient = AdminToolUtils.getAdminClient(url);


            if(!orphaned && allParts) {
                partIds = AdminToolUtils.getAllPartitions(adminClient);
            }

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient

            dataDir = dataDir.replaceFirst(existingProtocol, this.hdfsFetcherProtocol);
            dataDir = dataDir.replaceFirst(existingPort, this.hdfsFetcherPort);
        }


        // Create admin client
        AdminClient client = new AdminClient(cluster,
                                             new AdminClientConfig().setMaxConnectionsPerNode(cluster.getNumberOfNodes())
                                                                    .setAdminConnectionTimeoutSec(httpTimeoutMs / 1000)
                                                                    .setMaxBackoffDelayMs(swapConf.getMaxBackoffDelayMs()),
                                             new ClientConfig());

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient

            // execute command
            if(!AdminToolUtils.askConfirm(confirm, "mirror stores")) {
                return;
            }


            AdminClient srcAdminClient = AdminToolUtils.getAdminClient(srcUrl);
            AdminClient destAdminClient = AdminToolUtils.getAdminClient(destUrl);


            if(allStores) {
                storeNames = AdminToolUtils.getAllUserStoreNamesOnNode(srcAdminClient, srcNodeId);
            } else {
                AdminToolUtils.validateUserStoreNamesOnNode(srcAdminClient, srcNodeId, storeNames);

View Full Code Here

Examples of voldemort.client.protocol.admin.AdminClient

            // execute command
            if(!AdminToolUtils.askConfirm(confirm, "update entries")) {
                return;
            }


            AdminClient adminClient = AdminToolUtils.getAdminClient(url);
            File inDir = new File(dir);


            if(!inDir.exists()) {
                throw new FileNotFoundException("Input directory " + dir + " doesn't exist");
            }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.