sre

Documentation

Index

• Variables
• type Opt
• type Option
  • func WithK(k float64) Option
  • func WithPolicyOption(policy ...window.Option) Option
  • func WithRequest(request uint64) Option
• type SreBreaker
  • func NewSreBreaker(opts ...Option) *SreBreaker
  • func (s *SreBreaker) Allow() error
  • func (s *SreBreaker) MarkFailed()
  • func (s *SreBreaker) MarkSuccess()

Variables

var ErrNotAllowed = errors.New("circuitbreaker: not allowed for circuit open")

Types

type Opt

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

SreBreaker google sre 弹性熔断器

type Option

type Option func(*Opt)

SreBreaker google sre 弹性熔断器

func WithK

func WithK(k float64) Option

func WithPolicyOption

func WithPolicyOption(policy ...window.Option) Option

func WithRequest

func WithRequest(request uint64) Option

type SreBreaker

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

SreBreaker google sre 弹性熔断器

func NewSreBreaker

func NewSreBreaker(opts ...Option) *SreBreaker

func (*SreBreaker) Allow

func (s *SreBreaker) Allow() error

Allow 是否允许改请求通过, 如果返回 error 说明被熔断了

func (*SreBreaker) MarkFailed

func (s *SreBreaker) MarkFailed()

MarkFailed 标记失败

func (*SreBreaker) MarkSuccess

func (s *SreBreaker) MarkSuccess()

MarkSuccess 标记成功