Package voldemort.client.protocol.admin

Examples of voldemort.client.protocol.admin.AdminClient$QuotaManagementOperations


                                                                                new Properties());
            VoldemortServer vs = ServerTestUtils.startVoldemortServer(ssf, config, cluster);
            vservers.put(node.getId(), vs);
            socketStoreFactories.put(node.getId(), ssf);
        }
        adminClient = new AdminClient(cluster, new AdminClientConfig(), new ClientConfig());
    }
View Full Code Here


            }
        }

        Properties adminProperties = new Properties();
        adminProperties.setProperty("max_connections", "2");
        adminClient = new AdminClient(servers[0].getMetadataStore().getCluster(),
                                      new AdminClientConfig(adminProperties),
                                      new ClientConfig());
    }
View Full Code Here

        setup();

        String[] argv = ("--url " + bsURL +" --drop-zoneid 0 --real-run").split(" ");
        ZoneShrinkageCLI.main(argv);

        AdminClient adminClient = new AdminClient(bsURL, new AdminClientConfig(), new ClientConfig());
        assertEquals(2, adminClient.getAdminClientCluster().getZoneIds().size());


        String bootstrapUrl = adminClient.getAdminClientCluster().getNodes().iterator().next().getSocketUrl().toString();
        StoreClientFactory factory = new SocketStoreClientFactory(new ClientConfig().setBootstrapUrls(bootstrapUrl));
        StoreClient<String, String> client = factory.getStoreClient(oldStores.get(0).getName());
        client.put("k1", "v1" );
        assertEquals("v1", client.get("k1").getValue());
    }
View Full Code Here

        setup();

        String[] argv = ("--url " + bsURL +" --drop-zoneid 1 --real-run").split(" ");
        ZoneShrinkageCLI.main(argv);

        AdminClient adminClient = new AdminClient(bsURL, new AdminClientConfig(), new ClientConfig());
        assertEquals(1, adminClient.getAdminClientCluster().getZoneIds().size());
    }
View Full Code Here

        try {
            sanityTestClientOps();
            // Get bootstraptime at start
            String bootstrapTime = getPropertyFromClientInfo("bootstrapTime");
            // Update cluster.xml metadata
            AdminClient adminClient = new AdminClient(bootStrapUrls[0],
                                                      new AdminClientConfig(),
                                                      new ClientConfig(),
                                                      CLIENT_ZONE_ID);
            for(Node node: cluster.getNodes()) {
                VoldemortAdminTool.executeSetMetadata(node.getId(),
View Full Code Here

        try {
            sanityTestClientOps();
            // Get bootstraptime at start
            String bootstrapTime = getPropertyFromClientInfo("bootstrapTime");
            // Update cluster.xml metadata
            AdminClient adminClient = new AdminClient(bootStrapUrls[0],
                                                      new AdminClientConfig(),
                                                      new ClientConfig(),
                                                      CLIENT_ZONE_ID);
            StoreDefinitionsMapper storeDefsMapper = new StoreDefinitionsMapper();
            List<StoreDefinition> storeDefs = storeDefsMapper.readStoreList(new File(storesXmlfile));
View Full Code Here

        storeDefs = new StoreDefinitionsMapper().readStoreList(new File(storesXmlfile));

        Properties adminProperties = new Properties();
        adminProperties.setProperty("max_connections", "20");
        adminClient = new AdminClient(cluster,
                                      new AdminClientConfig(adminProperties),
                                      new ClientConfig());

        Node node = cluster.getNodeById(0);
        String bootstrapUrl = "tcp://" + node.getHost() + ":" + node.getSocketPort();
View Full Code Here

        assertTrue(testOnlineTraffic());
    }

    @Test
    public void testStateTransitions() {
        AdminClient client = getAdminClient();
        assertTrue(testOnlineTraffic());
        assertTrue(testSlopStreaming());
        toOfflineState(client);
        assertFalse(testOnlineTraffic());
        assertFalse(testSlopStreaming());
View Full Code Here

     */
    @Test
    public void testClusterAndStoresAreSetAtomically() {
        try {

            AdminClient adminClient = new AdminClient(bootStrapUrls[0],
                                                      new AdminClientConfig(),
                                                      new ClientConfig());

            StoreDefinitionsMapper storeDefsMapper = new StoreDefinitionsMapper();
            List<StoreDefinition> storeDefs = storeDefsMapper.readStoreList(new File(newStoresXmlfile));
View Full Code Here

                                                                                new Properties());
            VoldemortServer vs = ServerTestUtils.startVoldemortServer(ssf, config, cluster);
            vservers.put(node.getId(), vs);
            socketStoreFactories.put(node.getId(), ssf);
        }
        adminClient = new AdminClient(cluster, new AdminClientConfig(), new ClientConfig());
    }
View Full Code Here

TOP

Related Classes of voldemort.client.protocol.admin.AdminClient$QuotaManagementOperations

Copyright © 2018 www.massapicom. All rights reserved.
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.