net.bluemind.lib.vertx.utils

Class CircuitBreaker<T>

java.lang.Object

net.bluemind.lib.vertx.utils.CircuitBreaker<T>

public class CircuitBreaker<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
CircuitBreaker(java.lang.String name, java.util.function.Function<T,java.lang.String> partition)

Method Summary

Modifier and Type	Method and Description
<R> java.util.concurrent.CompletableFuture<R>	applyCall(io.vertx.core.Vertx vertx, T partitionable, java.util.concurrent.Callable<R> to)
<R> java.util.concurrent.CompletableFuture<R>	applyPromised(io.vertx.core.Vertx vertx, T partitionable, java.util.function.Supplier<java.util.concurrent.CompletableFuture<R>> to)
void	noticeError(T errorSource)
void	noticeSuccess(T errorSource)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CircuitBreaker

public CircuitBreaker(java.lang.String name,
                      java.util.function.Function<T,java.lang.String> partition)

Method Detail

noticeError

public void noticeError(T errorSource)

noticeSuccess

public void noticeSuccess(T errorSource)

applyCall

public <R> java.util.concurrent.CompletableFuture<R> applyCall(io.vertx.core.Vertx vertx,
                                                               T partitionable,
                                                               java.util.concurrent.Callable<R> to)

applyPromised

public <R> java.util.concurrent.CompletableFuture<R> applyPromised(io.vertx.core.Vertx vertx,
                                                                   T partitionable,
                                                                   java.util.function.Supplier<java.util.concurrent.CompletableFuture<R>> to)