resilience

package

Go to main page

Versions in this module

v0

v0.3.0

Jan 5, 2024

v0.2.0

Dec 19, 2023

v0.1.1

Dec 13, 2023

Changes in this version

+ const BulkheadDefaultOrder

+ const CacheDefaultOrder

+ const CircuitBreakerDefaultOrder

+ const FallbackDefaultOrder

+ const RateLimiterDefaultOrder

+ const RetryDefaultOrder

+ const TimeLimiterDefaultOrder

type BulkheadConfig

+ Order string

type CacheConfig

+ Order string

type CircuitBreakerConfig

+ Order string

+ type Config struct

+ Bulkhead BulkheadConfig

+ Cache CacheConfig

+ CircuitBreaker CircuitBreakerConfig

+ Fallback FallbackConfig

+ RateLimiter RateLimiterConfig

+ Retry RetryConfig

+ TimeLimiter TimeLimiterConfig

+ type Decorator struct

+ Bulkhead bulkhead.Bulkhead

+ Cache cache.Cache[Req, Rsp]

+ CircuitBreaker circuitbreaker.CircuitBreaker

+ RateLimiter ratelimiter.RateLimiter

+ RegisterFn promhelper.RegisterFn

+ Retry retry.Retry

+ TimeLimiter timelimiter.TimeLimiter

+ UnregisterFn promhelper.UnregisterFn

+ func NewDecorator(name string, config *Config) *Decorator

+ func (e *Decorator) Decorate(rp ReverseProxy) ReverseProxy

type FallbackConfig

+ Order string

+ type OrderedDecorator struct

+ Decorator ReverseProxyDecorator

+ Order string

+ func (d *OrderedDecorator) Decorate(rp ReverseProxy) ReverseProxy

+ type OrderedDecoratorSlice []*OrderedDecorator

+ func (x OrderedDecoratorSlice) Len() int

+ func (x OrderedDecoratorSlice) Less(i, j int) bool

+ func (x OrderedDecoratorSlice) Sort()

+ func (x OrderedDecoratorSlice) Swap(i, j int)

type RateLimiterConfig

+ Order string

type RetryConfig

+ Order string

type TimeLimiterConfig

+ Order string

v0.1.0

Dec 12, 2023

Changes in this version

+ func DefaultRspCachePredicate(rsp Rsp, _ map[string]string) bool

+ func DefaultRspFailedPredicate(rsp Rsp, _ map[string]string) bool

+ func NewBulkheadPlugin(name string, config *BulkheadConfig) (bulkhead.Bulkhead, ReverseProxyDecorator)

+ func NewCachePlugin(name string, config *CacheConfig) (cache.Cache[Req, Rsp], ReverseProxyDecorator)

+ func NewCircuitBreakerPlugin(name string, config *CircuitBreakerConfig) (circuitbreaker.CircuitBreaker, ReverseProxyDecorator)

+ func NewFallbackPlugin(config *FallbackConfig) ReverseProxyDecorator

+ func NewRateLimiterPlugin(name string, config *RateLimiterConfig) (ratelimiter.RateLimiter, ReverseProxyDecorator)

+ func NewRetryPlugin(name string, config *RetryConfig) (retry.Retry, ReverseProxyDecorator)

+ func NewTimeLimiterPlugin(name string, config *TimeLimiterConfig) (timelimiter.TimeLimiter, ReverseProxyDecorator)

+ func RegisterFallbackFunction(name string, function FallbackFunction) error

+ func RegisterRspCachePredicate(name string, predicate RspCachePredicate) error

+ func RegisterRspFailedPredicate(name string, predicate RspFailedPredicate) error

+ type BulkheadConfig struct

+ Disabled string

+ MaxConcurrentCalls string

+ MaxWaitDuration string

+ WhenFullResponse string

+ type CacheConfig struct

+ Capacity string

+ Enabled string

+ ItemTTL string

+ ResponseCachePredicate string

+ ResponseCachePredicateContext map[string]string

+ type CircuitBreakerConfig struct

+ AutomaticTransitionFromOpenToHalfOpen string

+ Disabled string

+ FailureRateThreshold string

+ MaxWaitDurationInHalfOpenState string

+ MinimumNumberOfCalls string

+ PermittedNumberOfCallsInHalfOpenState string

+ ResponseFailedPredicate string

+ ResponseFailedPredicateContext map[string]string

+ SlidingWindowSize string

+ SlidingWindowType string

+ SlowCallDurationThreshold string

+ SlowCallRateThreshold string

+ WaitIntervalInOpenState string

+ WhenOverLoadResponse string

+ type FallbackConfig struct

+ Enabled string

+ FallbackFunction string

+ FallbackFunctionContext map[string]string

+ FallbackResponse string

+ ResponseFailedPredicate string

+ ResponseFailedPredicateContext map[string]string

+ type FallbackFunction = func(Req, map[string]string) (Rsp, error)

+ func GetFallbackFunction(name string) FallbackFunction

+ type RateLimiterConfig struct

+ Disabled string

+ LimitForPeriod string

+ LimitRefreshPeriod string

+ TimeoutDuration string

+ WhenOverRateResponse string

+ type RetryConfig struct

+ Disabled string

+ FailAfterMaxAttempts string

+ MaxAttempts string

+ ResponseFailedPredicate string

+ ResponseFailedPredicateContext map[string]string

+ WaitInterval string

+ WhenMaxRetriesResponse string

+ type RspCachePredicate = func(Rsp, map[string]string) bool

+ func GetRspCachePredicate(name string) RspCachePredicate

+ type RspFailedPredicate = func(Rsp, map[string]string) bool

+ func GetRspFailedPredicate(name string) RspFailedPredicate

+ type TimeLimiterConfig struct

+ Disabled string

+ TimeoutDuration string

+ WhenTimeoutResponse string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL