Package net.bluemind.lib.vertx.utils

Class CircuitBreaker<T>

java.lang.Object

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

public class CircuitBreaker<T>
extends Object

Constructor Summary

Constructors

Constructor	Description
CircuitBreaker(String name, Function<T,String> partition)

Method Summary

Modifier and Type	Method	Description
<R> CompletableFuture<R>	applyCall(io.vertx.core.Vertx vertx, T partitionable, Callable<R> to)
<R> CompletableFuture<R>	applyPromised(io.vertx.core.Vertx vertx, T partitionable, Supplier<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 Details

CircuitBreaker

public CircuitBreaker(String name,
 Function<T,String> partition)

Method Details

noticeError

public void noticeError(T errorSource)

noticeSuccess

public void noticeSuccess(T errorSource)

applyCall

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

applyPromised

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