gobreaker

Index ¶

• Variables
• type CircuitBreaker
• • func NewCircuitBreaker[T any](st Settings) *CircuitBreaker[T]
• • func (cb *CircuitBreaker[T]) Counts() Counts
  • func (cb *CircuitBreaker[T]) Execute(req func() (T, error)) (T, error)
  • func (cb *CircuitBreaker[T]) Name() string
  • func (cb *CircuitBreaker[T]) State() State
• type Counts
• type DistributedCircuitBreaker
• • func NewDistributedCircuitBreaker[T any](store SharedDataStore, settings Settings) (dcb *DistributedCircuitBreaker[T], err error)
• • func (dcb *DistributedCircuitBreaker[T]) Execute(req func() (T, error)) (t T, err error)
  • func (dcb *DistributedCircuitBreaker[T]) State() (state State, err error)
• type Settings
• type SharedDataStore
• type SharedState
• type State
• • func (s State) String() string
• type TwoStepCircuitBreaker
• • func NewTwoStepCircuitBreaker[T any](st Settings) *TwoStepCircuitBreaker[T]
• • func (tscb *TwoStepCircuitBreaker[T]) Allow() (done func(err error), err error)