IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

allow both count and counter in old and new versions of error handler

Browse Source
This commit is contained in:
Jonathan Shook
2021-03-10 13:00:45 -06:00
parent 63158fcdd1
commit 345877c0fa
2 changed files with 32 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
engine-api/src/main/java/io/nosqlbench/engine/api/activityapi/errorhandling/modular/handlers/CountErrorHandler.java
View File

@@ -1,26 +1,12 @@
package io.nosqlbench.engine.api.activityapi.errorhandling.modular.handlers;
import io.nosqlbench.engine.api.activityapi.errorhandling.ErrorMetrics;
import io.nosqlbench.engine.api.activityapi.errorhandling.modular.ErrorDetail;
import io.nosqlbench.engine.api.activityapi.errorhandling.modular.ErrorHandler;
import io.nosqlbench.engine.api.metrics.ExceptionCountMetrics;
import io.nosqlbench.nb.annotations.Service;
import java.util.function.Supplier;
@Service(value = ErrorHandler.class, selector = "counter")
public class CountErrorHandler implements ErrorHandler, ErrorMetrics.Aware {
private ExceptionCountMetrics exceptionCountMetrics;
@Override
public ErrorDetail handleError(Throwable t, long cycle, long durationInNanos, ErrorDetail detail) {
exceptionCountMetrics.count(t);
return detail;
}
@Override
public void setErrorMetricsSupplier(Supplier<ErrorMetrics> supplier) {
this.exceptionCountMetrics = supplier.get().getExceptionCountMetrics();
}
/**
* This is here to allow the classic name 'count' to work although the
* modern error handler scheme uses canonical metric type names.
*/
@Service(value = ErrorHandler.class, selector = "count")
public class CountErrorHandler extends CounterErrorHandler {
}

26
engine-api/src/main/java/io/nosqlbench/engine/api/activityapi/errorhandling/modular/handlers/CounterErrorHandler.java Normal file
View File

@@ -0,0 +1,26 @@
package io.nosqlbench.engine.api.activityapi.errorhandling.modular.handlers;
import io.nosqlbench.engine.api.activityapi.errorhandling.ErrorMetrics;
import io.nosqlbench.engine.api.activityapi.errorhandling.modular.ErrorDetail;
import io.nosqlbench.engine.api.activityapi.errorhandling.modular.ErrorHandler;
import io.nosqlbench.engine.api.metrics.ExceptionCountMetrics;
import io.nosqlbench.nb.annotations.Service;
import java.util.function.Supplier;
@Service(value = ErrorHandler.class, selector = "counter")
public class CounterErrorHandler implements ErrorHandler, ErrorMetrics.Aware {
private ExceptionCountMetrics exceptionCountMetrics;
@Override
public ErrorDetail handleError(Throwable t, long cycle, long durationInNanos, ErrorDetail detail) {
exceptionCountMetrics.count(t);
return detail;
}
@Override
public void setErrorMetricsSupplier(Supplier<ErrorMetrics> supplier) {
this.exceptionCountMetrics = supplier.get().getExceptionCountMetrics();
}
}