otelfailsafe

Documentation

Index

• type FailsafeMetrics
• type PolicyEngine
  • func NewPolicyEngine[R any](name string) (PolicyEngine[R], error)
  • func (p PolicyEngine[R]) NewAdaptiveLimiterBuilder() adaptivelimiter.Builder[R]
  • func (p PolicyEngine[R]) NewAdaptiveThrottlerBuilder() adaptivethrottler.Builder[R]
  • func (p PolicyEngine[R]) NewBulkheadBuilder(maxConcurrency uint) bulkhead.Builder[R]
  • func (p PolicyEngine[R]) NewCacheBuilder(cache cachepolicy.Cache[R]) cachepolicy.Builder[R]
  • func (p PolicyEngine[R]) NewCircuitBreakerBuilder() circuitbreaker.Builder[R]
  • func (p PolicyEngine[R]) NewExecutor(policies ...failsafe.Policy[R]) failsafe.Executor[R]
  • func (p PolicyEngine[R]) NewFallbackWithErrorBuilder(err error) fallback.Builder[R]
  • func (p PolicyEngine[R]) NewFallbackWithFuncBuilder(f func(exec failsafe.Execution[R]) (R, error)) fallback.Builder[R]
  • func (p PolicyEngine[R]) NewFallbackWithResultBuilder(result R) fallback.Builder[R]
  • func (p PolicyEngine[R]) NewHedgeWithDelayBuilder(delay time.Duration) hedgepolicy.Builder[R]
  • func (p PolicyEngine[R]) NewHedgeWithDelayFuncBuilder(delayFunc failsafe.DelayFunc[R]) hedgepolicy.Builder[R]
  • func (p PolicyEngine[R]) NewRateLimiterBurstyBuilder(maxExecutions uint, period time.Duration) ratelimiter.Builder[R]
  • func (p PolicyEngine[R]) NewRateLimiterSmoothBuilder(maxExecutions uint, period time.Duration) ratelimiter.Builder[R]
  • func (p PolicyEngine[R]) NewRateLimiterSmoothWithMaxRateBuilder(maxRate time.Duration) ratelimiter.Builder[R]
  • func (p PolicyEngine[R]) NewRetryBuilder() retrypolicy.Builder[R]
  • func (p PolicyEngine[R]) NewTimeoutBuilder(timeLimit time.Duration) timeout.Builder[R]

Types

type FailsafeMetrics

type FailsafeMetrics struct {
	// contains filtered or unexported fields
}

type PolicyEngine

type PolicyEngine[R any] struct {
	Metrics *FailsafeMetrics
	// contains filtered or unexported fields
}

func NewPolicyEngine

func NewPolicyEngine[R any](name string) (PolicyEngine[R], error)

func (PolicyEngine[R]) NewAdaptiveLimiterBuilder

func (p PolicyEngine[R]) NewAdaptiveLimiterBuilder() adaptivelimiter.Builder[R]

func (PolicyEngine[R]) NewAdaptiveThrottlerBuilder

func (p PolicyEngine[R]) NewAdaptiveThrottlerBuilder() adaptivethrottler.Builder[R]

func (PolicyEngine[R]) NewBulkheadBuilder

func (p PolicyEngine[R]) NewBulkheadBuilder(maxConcurrency uint) bulkhead.Builder[R]

func (PolicyEngine[R]) NewCacheBuilder

func (p PolicyEngine[R]) NewCacheBuilder(cache cachepolicy.Cache[R]) cachepolicy.Builder[R]

func (PolicyEngine[R]) NewCircuitBreakerBuilder

func (p PolicyEngine[R]) NewCircuitBreakerBuilder() circuitbreaker.Builder[R]

func (PolicyEngine[R]) NewExecutor

func (p PolicyEngine[R]) NewExecutor(policies ...failsafe.Policy[R]) failsafe.Executor[R]

func (PolicyEngine[R]) NewFallbackWithErrorBuilder

func (p PolicyEngine[R]) NewFallbackWithErrorBuilder(err error) fallback.Builder[R]

func (PolicyEngine[R]) NewFallbackWithFuncBuilder

func (p PolicyEngine[R]) NewFallbackWithFuncBuilder(f func(exec failsafe.Execution[R]) (R, error)) fallback.Builder[R]

func (PolicyEngine[R]) NewFallbackWithResultBuilder

func (p PolicyEngine[R]) NewFallbackWithResultBuilder(result R) fallback.Builder[R]

func (PolicyEngine[R]) NewHedgeWithDelayBuilder

func (p PolicyEngine[R]) NewHedgeWithDelayBuilder(delay time.Duration) hedgepolicy.Builder[R]

func (PolicyEngine[R]) NewHedgeWithDelayFuncBuilder

func (p PolicyEngine[R]) NewHedgeWithDelayFuncBuilder(delayFunc failsafe.DelayFunc[R]) hedgepolicy.Builder[R]

func (PolicyEngine[R]) NewRateLimiterBurstyBuilder

func (p PolicyEngine[R]) NewRateLimiterBurstyBuilder(maxExecutions uint, period time.Duration) ratelimiter.Builder[R]

func (PolicyEngine[R]) NewRateLimiterSmoothBuilder

func (p PolicyEngine[R]) NewRateLimiterSmoothBuilder(maxExecutions uint, period time.Duration) ratelimiter.Builder[R]

func (PolicyEngine[R]) NewRateLimiterSmoothWithMaxRateBuilder

func (p PolicyEngine[R]) NewRateLimiterSmoothWithMaxRateBuilder(maxRate time.Duration) ratelimiter.Builder[R]

func (PolicyEngine[R]) NewRetryBuilder

func (p PolicyEngine[R]) NewRetryBuilder() retrypolicy.Builder[R]

func (PolicyEngine[R]) NewTimeoutBuilder

func (p PolicyEngine[R]) NewTimeoutBuilder(timeLimit time.Duration) timeout.Builder[R]