Package com.tnsai.resilience

Class ResilienceRequest.Builder<T>

java.lang.Object

com.tnsai.resilience.ResilienceRequest.Builder<T>

Enclosing class:

ResilienceRequest<T>

public static final class ResilienceRequest.Builder<T>
extends Object

Method Summary

Modifier and Type	Method	Description
ResilienceRequest<T>	build()
ResilienceRequest.Builder<T>	bulkhead()	Enables bulkhead isolation with default concurrency (10).
ResilienceRequest.Builder<T>	bulkhead(int maxConcurrent)	Enables bulkhead isolation with specified concurrency limit.
ResilienceRequest.Builder<T>	fallbackStrategy(FallbackStrategy<T> fallbackStrategy)
ResilienceRequest.Builder<T>	metadata(String key, Object value)
ResilienceRequest.Builder<T>	metadata(Map<String,Object> metadata)
ResilienceRequest.Builder<T>	noBulkhead()	Disables bulkhead isolation.
ResilienceRequest.Builder<T>	noRateLimit()	Disables rate limiting.
ResilienceRequest.Builder<T>	operation(Callable<T> operation)
ResilienceRequest.Builder<T>	operationId(String operationId)
ResilienceRequest.Builder<T>	rateLimit()	Enables rate limiting with default limits (100 requests per minute).
ResilienceRequest.Builder<T>	rateLimit(int maxRequests, int windowMs)	Enables rate limiting with specified limits.
ResilienceRequest.Builder<T>	retryPolicy(RetryPolicy retryPolicy)
ResilienceRequest.Builder<T>	timeout(int timeoutMs)	Sets the timeout in milliseconds.

Methods inherited from class java.lang.Object

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

Method Details

operationId

public ResilienceRequest.Builder<T> operationId(String operationId)

operation

public ResilienceRequest.Builder<T> operation(Callable<T> operation)

retryPolicy

public ResilienceRequest.Builder<T> retryPolicy(RetryPolicy retryPolicy)

fallbackStrategy

public ResilienceRequest.Builder<T> fallbackStrategy(FallbackStrategy<T> fallbackStrategy)

metadata

public ResilienceRequest.Builder<T> metadata(String key,
 Object value)

metadata

public ResilienceRequest.Builder<T> metadata(Map<String,Object> metadata)

bulkhead

public ResilienceRequest.Builder<T> bulkhead(int maxConcurrent)

Enables bulkhead isolation with specified concurrency limit.

Parameters:

maxConcurrent - maximum concurrent calls

Returns:

this builder

bulkhead

public ResilienceRequest.Builder<T> bulkhead()

Enables bulkhead isolation with default concurrency (10).

Returns:

this builder

noBulkhead

public ResilienceRequest.Builder<T> noBulkhead()

Disables bulkhead isolation.

Returns:

this builder

rateLimit

public ResilienceRequest.Builder<T> rateLimit(int maxRequests,
 int windowMs)

Enables rate limiting with specified limits.

Parameters:

maxRequests - maximum requests per window

windowMs - time window in milliseconds

Returns:

this builder

rateLimit

public ResilienceRequest.Builder<T> rateLimit()

Enables rate limiting with default limits (100 requests per minute).

Returns:

this builder

noRateLimit

public ResilienceRequest.Builder<T> noRateLimit()

Disables rate limiting.

Returns:

this builder

timeout

public ResilienceRequest.Builder<T> timeout(int timeoutMs)

Sets the timeout in milliseconds.

0 means no timeout (default).

Parameters:

timeoutMs - timeout in milliseconds

Returns:

this builder

build

public ResilienceRequest<T> build()