Package voldemort.store.stats

Examples of voldemort.store.stats.StoreStatsJmx


        // TODO: Add identifierString to the Mbean name
        if(this.config.isEnableJmx()) {
            StatTrackingStore statStore = new StatTrackingStore(store, this.stats);
            store = statStore;
            JmxUtils.registerMbean(new StoreStatsJmx(statStore.getStats()),
                                   JmxUtils.createObjectName(JmxUtils.getPackageName(store.getClass()),
                                                             store.getName()));
        }

        // Add compression layer
View Full Code Here


        initializeMetadataVersions(storeDefs);

        // enable aggregate jmx statistics
        if(voldemortConfig.isStatTrackingEnabled())
            if(this.voldemortConfig.isEnableJmxClusterName())
                JmxUtils.registerMbean(new StoreStatsJmx(this.storeStats),
                                       JmxUtils.createObjectName(metadata.getCluster().getName()
                                                                         + ".voldemort.store.stats.aggregate",
                                                                 "aggregate-perf"));
            else
                JmxUtils.registerMbean(new StoreStatsJmx(this.storeStats),
                                       JmxUtils.createObjectName("voldemort.store.stats.aggregate",
                                                                 "aggregate-perf"));

        logger.info("All stores initialized.");
    }
View Full Code Here

                synchronized(mbeanServer) {
                    if(mbeanServer.isRegistered(name))
                        JmxUtils.unregisterMbean(mbeanServer, name);

                    JmxUtils.registerMbean(mbeanServer,
                                           JmxUtils.createModelMBean(new StoreStatsJmx(statStore.getStats())),
                                           name);
                }
            }
        }
View Full Code Here

                synchronized(mbeanServer) {
                    if(mbeanServer.isRegistered(name))
                        JmxUtils.unregisterMbean(mbeanServer, name);

                    JmxUtils.registerMbean(mbeanServer,
                                           JmxUtils.createModelMBean(new StoreStatsJmx(statStore.getStats())),
                                           name);
                }
            }

            // Wrap everything under the rate limiting store (barring the
View Full Code Here

        if(this.isJmxEnabled) {
            JmxUtils.registerMbean(threadPool,
                                   JmxUtils.createObjectName(JmxUtils.getPackageName(threadPool.getClass()),
                                                             JmxUtils.getClassName(threadPool.getClass())
                                                                     + identifierString));
            JmxUtils.registerMbean(new StoreStatsJmx(aggregateStats),
                                   JmxUtils.createObjectName("voldemort.store.stats.aggregate",
                                                             "aggregate-perf" + identifierString));

            JmxUtils.registerMbean(new StoreClientFactoryStatsJmx(storeClientFactoryStats),
                                   JmxUtils.createObjectName("voldemort.store.client.factory.stats",
View Full Code Here

        store = new LoggingStore(store);

        if(isJmxEnabled) {
            StatTrackingStore statStore = new StatTrackingStore(store, this.aggregateStats);
            store = statStore;
            JmxUtils.registerMbean(new StoreStatsJmx(statStore.getStats()),
                                   JmxUtils.createObjectName(JmxUtils.getPackageName(store.getClass()),
                                                             store.getName() + identifierString));
        }

        if(this.config.isEnableCompressionLayer()) {
View Full Code Here

            // Add to concurrentHashMap
            storeStatsMap.put(storeName, new StoreStats(storeName, aggregatedStoreStats));

            // Register storeStats MBeans for every store
            if(isJmxEnabled) {
                JmxUtils.registerMbean(new StoreStatsJmx(storeStatsMap.get(storeName)),
                                       JmxUtils.createObjectName(JmxUtils.getPackageName(this.getClass())
                                                                         + ".store.stats",
                                                                 storeName));
            }
        }

        // Register Mbean for aggregated server store stats
        if(isJmxEnabled) {
            JmxUtils.registerMbean(new StoreStatsJmx(aggregatedStoreStats),
                                   JmxUtils.createObjectName(JmxUtils.getPackageName(this.getClass())
                                                                     + ".store.stats",
                                                             JmxUtils.getClassName(this.aggregatedStoreStats.getClass())));
        }
    }
View Full Code Here

                    storeStatsMap.putIfAbsent(storeName, new StoreStats(storeName, aggregatedStoreStats));
                    performanceStats = storeStatsMap.get(storeName);

                    // Register MBeans for new store performance stats
                    if(isJmxEnabled) {
                        JmxUtils.registerMbean(new StoreStatsJmx(performanceStats),
                                               JmxUtils.createObjectName(JmxUtils.getPackageName(this.getClass())
                                                                                 + ".store.stats",
                                                                         storeName));
                    }
                }
View Full Code Here

TOP

Related Classes of voldemort.store.stats.StoreStatsJmx

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.