throttle

package
v0.2.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 31, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithBreakerListener

func WithBreakerListener(listener circuitbreaker.StateChangeListener) opt.Option[options]

func WithLogLevel

func WithLogLevel(level logging.Level) opt.Option[options]

Types

type Func

type Func func()

type FuncWithErr

type FuncWithErr func() error

type StateChangeListener

type StateChangeListener struct{}

func DefaultStateChangeListener

func DefaultStateChangeListener() *StateChangeListener

func (*StateChangeListener) OnTransformToClosed

func (s *StateChangeListener) OnTransformToClosed(prev circuitbreaker.State, rule circuitbreaker.Rule)

func (*StateChangeListener) OnTransformToHalfOpen

func (s *StateChangeListener) OnTransformToHalfOpen(prev circuitbreaker.State, rule circuitbreaker.Rule)

func (*StateChangeListener) OnTransformToOpen

func (s *StateChangeListener) OnTransformToOpen(prev circuitbreaker.State, rule circuitbreaker.Rule, snapshot interface{})

type Throttler

type Throttler interface {
	Build(...opt.Option[options]) error
	Guard(resource string, pass FuncWithErr, reject Func, opts ...sentinelApi.EntryOption) bool
}

type ThrottlerBreaker

type ThrottlerBreaker interface {
	Throttler
	Rule(rules []*circuitbreaker.Rule) error
}

func Breaker

func Breaker() ThrottlerBreaker

type ThrottlerLimiter

type ThrottlerLimiter interface {
	Throttler
	Rule(rules []*flow.Rule) error
}

func Limiter

func Limiter() ThrottlerLimiter

Jump to

Keyboard shortcuts

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