本文整理了Java中net.spy.memcached.MemcachedClient.getStats()
方法的一些代码示例,展示了MemcachedClient.getStats()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MemcachedClient.getStats()
方法的具体详情如下:
包路径:net.spy.memcached.MemcachedClient
类名称:MemcachedClient
方法名:getStats
[英]Get all of the stats from all of the connections.
[中]从所有连接获取所有统计信息。
代码示例来源:origin: Netflix/EVCache
public Map<SocketAddress, Map<String, String>> getStats(String cmd) {
if(config.isRendInstance()) {
List<InetSocketAddress> udsproxyInetSocketAddress = new ArrayList<InetSocketAddress>(memcachedNodesInZone.size());
for(InetSocketAddress address : memcachedNodesInZone) {
udsproxyInetSocketAddress.add(new InetSocketAddress(address.getHostName(), config.getUdsproxyMemcachedPort()));
}
MemcachedClient mc = null;
try {
mc = new MemcachedClient(connectionFactory, udsproxyInetSocketAddress);
return mc.getStats(cmd);
} catch(Exception ex) {
} finally {
if(mc != null) mc.shutdown();
}
return Collections.<SocketAddress, Map<String, String>>emptyMap();
} else {
return evcacheMemcachedClient.getStats(cmd);
}
}
代码示例来源:origin: net.spy/spymemcached
/**
* Get all of the stats from all of the connections.
*
* @return a Map of a Map of stats replies by SocketAddress
* @throws IllegalStateException in the rare circumstance where queue is too
* full to accept any more requests
*/
@Override
public Map<SocketAddress, Map<String, String>> getStats() {
return getStats(null);
}
代码示例来源:origin: com.google.code.maven-play-plugin.spy/spymemcached
/**
* Get all of the stats from all of the connections.
*
* @return a Map of a Map of stats replies by SocketAddress
* @throws IllegalStateException in the rare circumstance where queue
* is too full to accept any more requests
*/
public Map<SocketAddress, Map<String, String>> getStats() {
return getStats(null);
}
代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached
/**
* Get all of the stats from all of the connections.
*
* @return a Map of a Map of stats replies by SocketAddress
* @throws IllegalStateException in the rare circumstance where queue is too
* full to accept any more requests
*/
public Map<SocketAddress, Map<String, String>> getStats() {
return getStats(null);
}
代码示例来源:origin: naver/arcus-java-client
/**
* Get all of the stats from all of the connections.
*
* @return a Map of a Map of stats replies by SocketAddress
* @throws IllegalStateException in the rare circumstance where queue
* is too full to accept any more requests
*/
public Map<SocketAddress, Map<String, String>> getStats() {
return getStats(null);
}
代码示例来源:origin: com.amazonaws/elasticache-java-cluster-client
/**
* Get all of the stats from all of the connections.
*
* @return a Map of a Map of stats replies by SocketAddress
* @throws IllegalStateException in the rare circumstance where queue is too
* full to accept any more requests
*/
@Override
public Map<SocketAddress, Map<String, String>> getStats() {
return getStats(null);
}
代码示例来源:origin: com.google.code.maven-play-plugin.spy/memcached
/**
* Get all of the stats from all of the connections.
* @throws IllegalStateException in the rare circumstance where queue
* is too full to accept any more requests
*/
public Map<SocketAddress, Map<String, String>> getStats() {
return getStats(null);
}
代码示例来源:origin: indeedeng/lsmtree
public Map<String, String> getStats() {
final Map<String, String> retVal = memcache.getStats().get(host);
if (retVal != null) {
return retVal;
} else {
return Collections.emptyMap();
}
}
代码示例来源:origin: indeedeng/lsmtree
public void shutdown() {
if (log.isDebugEnabled()) {
log.debug("Memcached Stats: " + memcache.getStats());
}
memcache.shutdown();
}
代码示例来源:origin: io.snappydata/gemfire-junit
public void testStats() throws Exception {
MemcachedClient client = bootstrapClient();
Map stats = client.getStats();
logger.info("stats:"+stats+" val:"+stats.values().toArray()[0]);
assertEquals(1, stats.size());
assertTrue(((Map)stats.values().toArray()[0]).isEmpty());
assertTrue(client.add("keystats", 1, "stats").get());
}
代码示例来源:origin: OneBusAway/onebusaway-application-modules
public void logStatus() {
_log.info(getCache().stats().toString() + "; disabled=" + _disabled
+ "; useMemcached=" + useMemcached
+ "; Local Size=" + _cache.size()
+ "; Memcached Size=" + (memcache==null?"[null]":memcache.getStats("sizes")));
}
代码示例来源:origin: aurorafeint/jruby-memcached
@JRubyMethod
public IRubyObject stats(ThreadContext context) {
Ruby ruby = context.getRuntime();
RubyHash results = RubyHash.newHash(ruby);
for(Map.Entry<SocketAddress, Map<String, String>> entry : client.getStats().entrySet()) {
RubyHash serverHash = RubyHash.newHash(ruby);
for(Map.Entry<String, String> server : entry.getValue().entrySet()) {
serverHash.op_aset(context, ruby.newString(server.getKey()), ruby.newString(server.getValue()));
}
results.op_aset(context, ruby.newString(entry.getKey().toString()), serverHash);
}
return results;
}
内容来源于网络,如有侵权,请联系作者删除!