List of addLocalStore() Examples

Examples of addLocalStore()

voldemort.server.StoreRepository.addLocalStore()

Examples of voldemort.server.StoreRepository.addLocalStore()

                                                 List<StoreDefinition> storeDefs,
                                                 StorageEngine<ByteArray, byte[], byte[]> storageEngine)
            throws IOException {
        StoreRepository storeRepository = new StoreRepository();
        storeRepository.addStorageEngine(storageEngine);
        storeRepository.addLocalStore(storageEngine);


        SocketRequestHandlerFactory requestHandlerFactory = new SocketRequestHandlerFactory(null,
                                                                                            storeRepository,
                                                                                            ServerTestUtils.createMetadataStore(cluster,
                                                                                                                                storeDefs),

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()


        Map<Integer, NonblockingStore> nonblockingSlopStores = Maps.newHashMap();
        for(Node node: cluster.getNodes()) {
            int nodeId = node.getId();
            StoreRepository storeRepo = new StoreRepository();
            storeRepo.addLocalStore(subStores.get(nodeId));


            for(int i = 0; i < NUM_NODES_TOTAL; i++) {
                storeRepo.addNodeStore(i, subStores.get(i));
            }

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()

        VoldemortService vsrv = vs.getService(ServiceType.STORAGE);
        StoreRepository sr = ((StorageService) vsrv).getStoreRepository();


        // storage engine injection
        sr.removeLocalStore(STORE_NAME);
        sr.addLocalStore(sleepyStores.get(nodeId));
        sr.removeStorageEngine(STORE_NAME);
        sr.addStorageEngine((StorageEngine<ByteArray, byte[], byte[]>) realStores.get(nodeId));


        // slop stores caching and injection
        if(!slopStorageEngines.containsKey(nodeId)) {

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()

            slopStorageEngines.put(nodeId, slopStorageEngine);
        } else {
            sr.removeStorageEngine("slop");
            sr.removeLocalStore("slop");
            sr.addStorageEngine(slopStorageEngines.get(nodeId));
            sr.addLocalStore(slopStorageEngines.get(nodeId));
            sr.setSlopStore(slopStorageEngines.get(nodeId));
        }
    }


    /**

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()

            serverMap.put(i, servers[i]);
            Store<ByteArray, byte[], byte[]> store = new InMemoryStorageEngine<ByteArray, byte[], byte[]>("test-sleepy");
            if(i < numSlowNodes)
                store = new SleepyStore<ByteArray, byte[], byte[]>(delay, store);
            StoreRepository storeRepository = servers[i].getStoreRepository();
            storeRepository.addLocalStore(store);
        }


        Map<Integer, Store<ByteArray, byte[], byte[]>> stores = new HashMap<Integer, Store<ByteArray, byte[], byte[]>>();
        for(Node node: cluster.getNodes()) {
            Store<ByteArray, byte[], byte[]> socketStore = ServerTestUtils.getSocketStore(socketStoreFactory,

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()


    public AbstractRequestFormatTest(RequestFormatType type) {
        this.storeName = "test";
        this.store = new InMemoryStorageEngine<ByteArray, byte[], byte[]>(storeName);
        StoreRepository repository = new StoreRepository();
        repository.addLocalStore(store);
        repository.addRoutedStore(store);
        this.clientWireFormat = new RequestFormatFactory().getRequestFormat(type);
        this.serverWireFormat = ServerTestUtils.getSocketRequestHandlerFactory(repository)
                                               .getRequestHandler(type);
    }

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()

        System.out.println();


        /** * Do Socket tests ** */
        String storeName = "test";
        StoreRepository repository = new StoreRepository();
        repository.addLocalStore(new InMemoryStorageEngine<ByteArray, byte[], byte[]>(storeName));
        SocketStoreFactory storeFactory = new ClientRequestExecutorPool(10, 1000, 1000, 32 * 1024);
        final Store<ByteArray, byte[], byte[]> socketStore = storeFactory.create(storeName,
                                                                                 "localhost",
                                                                                 6666,
                                                                                 RequestFormatType.VOLDEMORT_V1,

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()

        socketStore.close();
        storeFactory.close();
        socketService.stop();


        /** * Do HTTP tests ** */
        repository.addLocalStore(new InMemoryStorageEngine<ByteArray, byte[], byte[]>(storeName));
        HttpService httpService = new HttpService(null,
                                                  null,
                                                  repository,
                                                  RequestFormatType.VOLDEMORT_V0,
                                                  numThreads,

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()

    private static final Logger logger = Logger.getLogger(ServerTestUtils.class.getName());


    public static StoreRepository getStores(String storeName, String clusterXml, String storesXml) {
        StoreRepository repository = new StoreRepository();
        Store<ByteArray, byte[], byte[]> store = new InMemoryStorageEngine<ByteArray, byte[], byte[]>(storeName);
        repository.addLocalStore(store);
        repository.addRoutedStore(store);


        // create new metadata store.
        MetadataStore metadata = createMetadataStore(new ClusterMapper().readCluster(new StringReader(clusterXml)),
                                                     new StoreDefinitionsMapper().readStoreList(new StringReader(storesXml)));

View Full Code Here

Examples of voldemort.server.StoreRepository.addLocalStore()

        repository.addRoutedStore(store);


        // create new metadata store.
        MetadataStore metadata = createMetadataStore(new ClusterMapper().readCluster(new StringReader(clusterXml)),
                                                     new StoreDefinitionsMapper().readStoreList(new StringReader(storesXml)));
        repository.addLocalStore(metadata);
        return repository;
    }


    public static VoldemortConfig getVoldemortConfig() {
        File temp = TestUtils.createTempDir();

View Full Code Here

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.