Package org.springframework.cloud.circuitbreaker.resilience4j

Class Resilience4jBulkheadProvider

java.lang.Object

org.springframework.cloud.circuitbreaker.resilience4j.Resilience4jBulkheadProvider

public class Resilience4jBulkheadProvider
extends Object

Author:

Andrii Bohutskyi

Constructor Summary

Constructors

Constructor	Description
Resilience4jBulkheadProvider(io.github.resilience4j.bulkhead.ThreadPoolBulkheadRegistry threadPoolBulkheadRegistry, io.github.resilience4j.bulkhead.BulkheadRegistry bulkheadRegistry)	Deprecated.
Resilience4jBulkheadProvider(io.github.resilience4j.bulkhead.ThreadPoolBulkheadRegistry threadPoolBulkheadRegistry, io.github.resilience4j.bulkhead.BulkheadRegistry bulkheadRegistry, Resilience4JConfigurationProperties resilience4JConfigurationProperties)

Method Summary

Modifier and Type	Method	Description
void	addBulkheadCustomizer(org.springframework.cloud.client.circuitbreaker.Customizer<io.github.resilience4j.bulkhead.Bulkhead> customizer, String... ids)
void	addThreadPoolBulkheadCustomizer(org.springframework.cloud.client.circuitbreaker.Customizer<io.github.resilience4j.bulkhead.ThreadPoolBulkhead> customizer, String... ids)
void	configure(Consumer<Resilience4jBulkheadConfigurationBuilder> consumer, String... ids)
void	configureDefault(Function<String,Resilience4jBulkheadConfigurationBuilder.BulkheadConfiguration> defaultConfiguration)
protected io.github.resilience4j.bulkhead.BulkheadRegistry	getBulkheadRegistry()
protected io.github.resilience4j.bulkhead.ThreadPoolBulkheadRegistry	getThreadPoolBulkheadRegistry()
<T> T	run(String id, Supplier<T> toRun, Function<Throwable,T> fallback, io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker, io.github.resilience4j.timelimiter.TimeLimiter timeLimiter, io.vavr.collection.Map<String,String> tags)

Methods inherited from class java.lang.Object

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

Constructor Detail

Resilience4jBulkheadProvider

@Deprecated
public Resilience4jBulkheadProvider(io.github.resilience4j.bulkhead.ThreadPoolBulkheadRegistry threadPoolBulkheadRegistry,
                                    io.github.resilience4j.bulkhead.BulkheadRegistry bulkheadRegistry)

Deprecated.

Resilience4jBulkheadProvider

public Resilience4jBulkheadProvider(io.github.resilience4j.bulkhead.ThreadPoolBulkheadRegistry threadPoolBulkheadRegistry,
                                    io.github.resilience4j.bulkhead.BulkheadRegistry bulkheadRegistry,
                                    Resilience4JConfigurationProperties resilience4JConfigurationProperties)

Method Detail

configureDefault

public void configureDefault(Function<String,Resilience4jBulkheadConfigurationBuilder.BulkheadConfiguration> defaultConfiguration)

configure

public void configure(Consumer<Resilience4jBulkheadConfigurationBuilder> consumer,
                      String... ids)

addBulkheadCustomizer

public void addBulkheadCustomizer(org.springframework.cloud.client.circuitbreaker.Customizer<io.github.resilience4j.bulkhead.Bulkhead> customizer,
                                  String... ids)

addThreadPoolBulkheadCustomizer

public void addThreadPoolBulkheadCustomizer(org.springframework.cloud.client.circuitbreaker.Customizer<io.github.resilience4j.bulkhead.ThreadPoolBulkhead> customizer,
                                            String... ids)

getBulkheadRegistry

protected io.github.resilience4j.bulkhead.BulkheadRegistry getBulkheadRegistry()

getThreadPoolBulkheadRegistry

protected io.github.resilience4j.bulkhead.ThreadPoolBulkheadRegistry getThreadPoolBulkheadRegistry()

run

public <T> T run(String id,
                 Supplier<T> toRun,
                 Function<Throwable,T> fallback,
                 io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker,
                 io.github.resilience4j.timelimiter.TimeLimiter timeLimiter,
                 io.vavr.collection.Map<String,String> tags)