/*
* Copyright 2014 Red Hat, Inc.
*
* Red Hat licenses this file to you under the Apache License, version 2.0
* (the "License"); you may not use this file except in compliance with the
* License. You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
* License for the specific language governing permissions and limitations
* under the License.
*/
package io.vertx.reactivex.ext.dropwizard;
import io.vertx.reactivex.RxHelper;
import io.vertx.reactivex.ObservableHelper;
import io.vertx.reactivex.FlowableHelper;
import io.vertx.reactivex.impl.AsyncResultMaybe;
import io.vertx.reactivex.impl.AsyncResultSingle;
import io.vertx.reactivex.impl.AsyncResultCompletable;
import io.vertx.reactivex.WriteStreamObserver;
import io.vertx.reactivex.WriteStreamSubscriber;
import java.util.Map;
import java.util.Set;
import java.util.List;
import java.util.Iterator;
import java.util.function.Function;
import java.util.stream.Collectors;
import io.vertx.core.Handler;
import io.vertx.core.AsyncResult;
import io.vertx.core.json.JsonObject;
import io.vertx.core.json.JsonArray;
import io.vertx.lang.rx.RxGen;
import io.vertx.lang.rx.TypeArg;
import io.vertx.lang.rx.MappingIterator;
The metrics service mainly allows to return a snapshot of measured objects.
NOTE: This class has been automatically generated from the original
non RX-ified interface using Vert.x codegen. /**
* The metrics service mainly allows to return a snapshot of measured objects.
*
* <p/>
* NOTE: This class has been automatically generated from the {@link io.vertx.ext.dropwizard.MetricsService original} non RX-ified interface using Vert.x codegen.
*/
@RxGen(io.vertx.ext.dropwizard.MetricsService.class)
public class MetricsService {
@Override
public String toString() {
return delegate.toString();
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
MetricsService that = (MetricsService) o;
return delegate.equals(that.delegate);
}
@Override
public int hashCode() {
return delegate.hashCode();
}
public static final TypeArg<MetricsService> __TYPE_ARG = new TypeArg<>( obj -> new MetricsService((io.vertx.ext.dropwizard.MetricsService) obj),
MetricsService::getDelegate
);
private final io.vertx.ext.dropwizard.MetricsService delegate;
public MetricsService(io.vertx.ext.dropwizard.MetricsService delegate) {
this.delegate = delegate;
}
public MetricsService(Object delegate) {
this.delegate = (io.vertx.ext.dropwizard.MetricsService)delegate;
}
public io.vertx.ext.dropwizard.MetricsService getDelegate() {
return delegate;
}
Creates a metric service for a given Vertx
instance. Params: - vertx – the vertx instance
Returns: the metrics service
/**
* Creates a metric service for a given {@link io.vertx.reactivex.core.Vertx} instance.
* @param vertx the vertx instance
* @return the metrics service
*/
public static io.vertx.reactivex.ext.dropwizard.MetricsService create(io.vertx.reactivex.core.Vertx vertx) {
io.vertx.reactivex.ext.dropwizard.MetricsService ret = io.vertx.reactivex.ext.dropwizard.MetricsService.newInstance((io.vertx.ext.dropwizard.MetricsService)io.vertx.ext.dropwizard.MetricsService.create(vertx.getDelegate()));
return ret;
}
Params: - measured – the measure object
Returns: the base name of the measured object
/**
* @param measured the measure object
* @return the base name of the measured object
*/
public String getBaseName(io.vertx.reactivex.core.metrics.Measured measured) {
String ret = delegate.getBaseName(measured.getDelegate());
return ret;
}
Returns: the known metrics names by this service
/**
* @return the known metrics names by this service
*/
public Set<String> metricsNames() {
Set<String> ret = delegate.metricsNames();
return ret;
}
Will return the metrics that correspond with the measured
object, null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server.
Params: - measured –
Returns: the map of metrics where the key is the name of the metric (excluding the base name unless for the Vert.x object) and the value is the json data representing that metric
/**
* Will return the metrics that correspond with the <code>measured</code> object, null if no metrics is available.<p/>
*
* Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
* dropwizard backend reports to a single server.
* @param measured
* @return the map of metrics where the key is the name of the metric (excluding the base name unless for the Vert.x object) and the value is the json data representing that metric
*/
public JsonObject getMetricsSnapshot(io.vertx.reactivex.core.metrics.Measured measured) {
JsonObject ret = delegate.getMetricsSnapshot(measured.getDelegate());
return ret;
}
Will return the metrics that begins with the baseName
, null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server.
Params: - baseName –
Returns: the map of metrics where the key is the name of the metric and the value is the json data representing that metric
/**
* Will return the metrics that begins with the <code>baseName</code>, null if no metrics is available.<p/>
*
* Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
* dropwizard backend reports to a single server.
* @param baseName
* @return the map of metrics where the key is the name of the metric and the value is the json data representing that metric
*/
public JsonObject getMetricsSnapshot(String baseName) {
JsonObject ret = delegate.getMetricsSnapshot(baseName);
return ret;
}
public static MetricsService newInstance(io.vertx.ext.dropwizard.MetricsService arg) {
return arg != null ? new MetricsService(arg) : null;
}
}