Java 类io.vertx.core.spi.metrics.TCPMetrics 实例源码

@Override
public TCPMetrics<?> createMetrics(NetClientOptions options) {
  String baseName;
  if (options.getMetricsName() != null) {
    baseName = nameOf("net.clients", options.getMetricsName());
  } else {
   baseName = nameOf("net.clients");
  }
  return new TCPMetricsImpl(registry, baseName);
}

public DispatchingTcpMetrics(List<? extends TCPMetrics> delegates) {
    super(delegates);
}

@Override
default TCPMetrics<?> createMetrics(SocketAddress localAddress, NetServerOptions options) {
    return DummyVertxMetrics.DummyTCPMetrics.INSTANCE;
}

@Override
default TCPMetrics<?> createMetrics(NetClientOptions options) {
    return DummyVertxMetrics.DummyTCPMetrics.INSTANCE;
}

@Override
public TCPMetrics<?> createMetrics(SocketAddress localAddress, NetServerOptions options) {
    return this.<TCPMetrics<?>> createSubMetrics(v -> v.createMetrics(localAddress, options),
            d -> new DispatchingTcpMetrics(d));
}

@Override
public TCPMetrics<?> createMetrics(NetClientOptions options) {
    return this.<TCPMetrics<?>> createSubMetrics(v -> v.createMetrics(options),
            d -> new DispatchingTcpMetrics(d));
}

@Override
public TCPMetrics<?> createMetrics(SocketAddress localAddress, NetServerOptions options) {
    return new NetServerMetricsImpl(counterService, gaugeService, properties.getNet().getServer());
}

@Override
public TCPMetrics<?> createMetrics(NetClientOptions options) {
    return new NetClientMetricsImpl(counterService, gaugeService, properties.getNet().getClient());
}

@Override
public TCPMetrics createMetrics(SocketAddress localAddress, NetServerOptions options) {
  NetServerMetricsSupplier supplier = (NetServerMetricsSupplier) metricSuppliers.get(NET_SERVER);
  return supplier != null ? new NetServerMetricsImpl(localAddress, supplier) : super.createMetrics(localAddress, options);
}

@Override
public TCPMetrics createMetrics(NetClientOptions options) {
  NetClientMetricsSupplier supplier = (NetClientMetricsSupplier) metricSuppliers.get(NET_CLIENT);
  return supplier != null ? new NetClientMetricsImpl(supplier) : super.createMetrics(options);
}

@Override
public TCPMetrics<?> createMetrics(SocketAddress localAddress, NetServerOptions options) {
  String baseName = MetricRegistry.name(nameOf("net.servers"), TCPMetricsImpl.addressName(localAddress));
  return new TCPMetricsImpl(registry, baseName);
}