load

Documentation

Index

• Variables
• func Disable()
• type Promise
• type Shedder
  • func NewAdaptiveShedder(opts ...ShedderOption) Shedder
• type ShedderGroup
  • func NewShedderGroup(opts ...ShedderOption) *ShedderGroup
  • func (g *ShedderGroup) GetShedder(key string) Shedder
• type ShedderOption
  • func WithBuckets(buckets int) ShedderOption
  • func WithCpuThreshold(threshold int64) ShedderOption
  • func WithWindow(window time.Duration) ShedderOption
• type SheddingStat
  • func NewSheddingStat(name string) *SheddingStat
  • func (s *SheddingStat) IncrementDrop()
  • func (s *SheddingStat) IncrementPass()
  • func (s *SheddingStat) IncrementTotal()

Variables

var (
	ErrServiceOverloaded = errors.New("service overloaded")
)

Functions

func Disable

func Disable()

Types

type Promise

type Promise interface {
	Pass()
	Fail()
}

type Shedder

type Shedder interface {
	Allow() (Promise, error)
}

func NewAdaptiveShedder

func NewAdaptiveShedder(opts ...ShedderOption) Shedder

type ShedderGroup

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

func NewShedderGroup

func NewShedderGroup(opts ...ShedderOption) *ShedderGroup

func (*ShedderGroup) GetShedder

func (g *ShedderGroup) GetShedder(key string) Shedder

type ShedderOption

type ShedderOption func(opts *shedderOptions)

func WithBuckets

func WithBuckets(buckets int) ShedderOption

func WithCpuThreshold

func WithCpuThreshold(threshold int64) ShedderOption

func WithWindow

func WithWindow(window time.Duration) ShedderOption

type SheddingStat

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

func NewSheddingStat

func NewSheddingStat(name string) *SheddingStat

func (*SheddingStat) IncrementDrop

func (s *SheddingStat) IncrementDrop()

func (*SheddingStat) IncrementPass

func (s *SheddingStat) IncrementPass()

func (*SheddingStat) IncrementTotal

func (s *SheddingStat) IncrementTotal()