本文整理汇总了Java中io.vertx.core.spi.metrics.PoolMetrics类的典型用法代码示例。如果您正苦于以下问题:Java PoolMetrics类的具体用法?Java PoolMetrics怎么用?Java PoolMetrics使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
PoolMetrics类属于io.vertx.core.spi.metrics包,在下文中一共展示了PoolMetrics类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createMetrics
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public <P> PoolMetrics<?> createMetrics(final P pool, final String poolType, final String poolName, final int maxPoolSize) {
// When creating pool metrics we cannot create the sender because vertx is not completely initialized
// This is an hack and the reporter will need to be decoupled from the poolMetricsCollectors
PoolMetricsImpl poolMetrics = new PoolMetricsImpl(statfulMetricsOptions, vertx, poolType, poolName, maxPoolSize);
this.poolMetricsCollectors.add(poolMetrics);
return poolMetrics;
}
开发者ID:statful,项目名称:statful-client-vertx,代码行数:10,代码来源:VertxMetricsImpl.java
示例2: createMetrics
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public <P> PoolMetrics<?> createMetrics(P pool, String poolType, String poolName, int maxPoolSize) {
NamedPoolMetricsSupplier supplier = (NamedPoolMetricsSupplier) metricSuppliers.get(NAMED_POOLS);
PoolMetrics<?> poolMetrics;
if (supplier != null) {
poolMetrics = new PoolMetricsImpl(supplier, poolType, poolName, maxPoolSize);
} else {
poolMetrics = super.createMetrics(pool, poolType, poolName, maxPoolSize);
}
return poolMetrics;
}
开发者ID:vert-x3,项目名称:vertx-hawkular-metrics,代码行数:12,代码来源:VertxMetricsImpl.java
示例3: JDBCConnectionImpl
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
public JDBCConnectionImpl(Context context, JDBCStatementHelper helper, Connection conn, PoolMetrics metrics, Object metric) {
this.vertx = context.owner();
this.helper = helper;
this.conn = conn;
this.metrics = metrics;
this.metric = metric;
this.ctx = (ContextInternal) context;
}
开发者ID:vert-x3,项目名称:vertx-jdbc-client,代码行数:9,代码来源:JDBCConnectionImpl.java
示例4: getClient
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
private SQLClient getClient() {
if (client == null) {
Map<String, PoolMetrics> metricsMap = FakePoolMetrics.getPoolMetrics();
Set<String> keys = new HashSet<>(metricsMap.keySet());
client = JDBCClient.createNonShared(vertx, JDBCClientTestBase.config().
put("max_pool_size", 10));
Set<String> after = new HashSet<>(metricsMap.keySet());
after.removeAll(keys);
metrics = (FakePoolMetrics) metricsMap.get(after.iterator().next());
}
return client;
}
开发者ID:vert-x3,项目名称:vertx-jdbc-client,代码行数:13,代码来源:JDBCPoolMetricsTest.java
示例5: testLifecycle
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Test
public void testLifecycle() {
Map<String, PoolMetrics> metricsMap = FakePoolMetrics.getPoolMetrics();
assertEquals(Collections.emptySet(), metricsMap.keySet());
client = getClient();
assertEquals(1, metricsMap.size());
assertEquals(10, metrics.getPoolSize());
client.close();
client = null;
assertEquals(0, metricsMap.size());
}
开发者ID:vert-x3,项目名称:vertx-jdbc-client,代码行数:12,代码来源:JDBCPoolMetricsTest.java
示例6: createMetrics
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
default <P> PoolMetrics<?> createMetrics(P pool, String poolType, String poolName, int maxPoolSize) {
return DummyVertxMetrics.DummyWorkerPoolMetrics.INSTANCE;
}
开发者ID:unbroken-dome,项目名称:vertx-spring,代码行数:5,代码来源:VertxMetricsAdapter.java
示例7: DispatchingPoolMetrics
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
public DispatchingPoolMetrics(List<? extends PoolMetrics> delegates) {
super(delegates);
}
开发者ID:unbroken-dome,项目名称:vertx-spring,代码行数:4,代码来源:DispatchingPoolMetrics.java
示例8: submitted
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public Map<PoolMetrics, ?> submitted() {
return dispatchWithResult(m -> m.submitted());
}
开发者ID:unbroken-dome,项目名称:vertx-spring,代码行数:5,代码来源:DispatchingPoolMetrics.java
示例9: begin
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public Map<PoolMetrics, ?> begin(Map<PoolMetrics, ?> context) {
return unmapWithResult(context, (m, c) -> m.begin(c));
}
开发者ID:unbroken-dome,项目名称:vertx-spring,代码行数:5,代码来源:DispatchingPoolMetrics.java
示例10: rejected
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public void rejected(Map<PoolMetrics, ?> context) {
unmap(context, (m, c) -> m.rejected(c));
}
开发者ID:unbroken-dome,项目名称:vertx-spring,代码行数:5,代码来源:DispatchingPoolMetrics.java
示例11: end
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public void end(Map<PoolMetrics, ?> context, boolean succeeded) {
unmap(context, (m, c) -> m.end(c, succeeded));
}
开发者ID:unbroken-dome,项目名称:vertx-spring,代码行数:5,代码来源:DispatchingPoolMetrics.java
示例12: createMetrics
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public <P> PoolMetrics<?> createMetrics(P pool, String poolType, String poolName, int maxPoolSize) {
return this.<PoolMetrics<?>> createSubMetrics(v -> v.createMetrics(pool, poolType, poolName, maxPoolSize),
d -> new DispatchingPoolMetrics(d));
}
开发者ID:unbroken-dome,项目名称:vertx-spring,代码行数:6,代码来源:DispatchingVertxMetrics.java
示例13: createMetrics
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public <P> PoolMetrics<?> createMetrics(P pool, String poolType, String poolName, int maxPoolSize) {
return new PoolMetricsImpl(counterService, gaugeService, properties.getPool());
}
开发者ID:unbroken-dome,项目名称:vertx-spring,代码行数:5,代码来源:VertxActuatorMetrics.java
示例14: createMetrics
import io.vertx.core.spi.metrics.PoolMetrics; //导入依赖的package包/类
@Override
public <P> PoolMetrics<?> createMetrics(P pool, String poolType, String poolName, int maxPoolSize) {
String baseName = nameOf("pools", poolType, poolName);
return new PoolMetricsImpl(registry, baseName, maxPoolSize);
}
开发者ID:vert-x3,项目名称:vertx-dropwizard-metrics,代码行数:6,代码来源:VertxMetricsImpl.java
注:本文中的io.vertx.core.spi.metrics.PoolMetrics类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论