window

README

抄的kratos , 在滑块中添加缓存, 并修复了kratos中apply的一个小BUG, 见 https://github.com/go-kratos/aegis/issues/17

kratos: https://github.com/go-kratos/kratos/blob/main/middleware/circuitbreaker/circuitbreaker.go sre: https://github.com/go-kratos/aegis/tree/main/circuitbreaker/sre window: https://github.com/go-kratos/aegis/tree/main/pkg/window

Documentation

Index

• func NewWindow(size int) *window
• type Breaker
• type Bucket
  • func (b *Bucket) Add(val uint64)
  • func (b *Bucket) Reset()
• type Option
  • func WithBucket(bucketSize int) Option
  • func WithBucketDuration(bucketDuration time.Duration) Option
• type Rolling
• type RollingPolicy
  • func NewRollingPolicy(opts ...Option) *RollingPolicy
  • func (r *RollingPolicy) Add(val uint64)
  • func (r *RollingPolicy) Reduce(fn func(*Bucket))
  • func (r *RollingPolicy) Summary() (accept uint64, count uint64)
• type Window

Functions

func NewWindow

func NewWindow(size int) *window

Types

type Breaker

type Breaker interface {
	Allow() (bool, error)
}

type Bucket

type Bucket struct {
	Sum   uint64 // 这里可以是请求耗时, 也可以是请求成功次数
	Count uint64 // 请求总数
}

func (*Bucket) Add

func (b *Bucket) Add(val uint64)

Add Count是总数，这个是必须加1的

func (*Bucket) Reset

func (b *Bucket) Reset()

Reset 重置桶

type Option

type Option func(*options)

func WithBucket

func WithBucket(bucketSize int) Option

func WithBucketDuration

func WithBucketDuration(bucketDuration time.Duration) Option

type Rolling

type Rolling interface {
	Add(val uint64)

	Reduce(func(*Bucket))
	Summary() (accept uint64, count uint64)
	// contains filtered or unexported methods
}

type RollingPolicy

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

RollingPolicy 滑块

func NewRollingPolicy

func NewRollingPolicy(opts ...Option) *RollingPolicy

func (*RollingPolicy) Add

func (r *RollingPolicy) Add(val uint64)

Add 桶数据增 这里会触发滑动

func (*RollingPolicy) Reduce

func (r *RollingPolicy) Reduce(fn func(*Bucket))

Reduce 统计所有的采集完整的桶, 当前这个桶和跳过的桶不计算

func (*RollingPolicy) Summary

func (r *RollingPolicy) Summary() (accept uint64, count uint64)

Summary 返回有效bucket数量之和

type Window

type Window interface {
	Add(offset int, val uint64)
	ResetBuckets(offset int, count int)
	Reduce(start int, end int, fn func(*Bucket))
}