zconcurrency

Documentation

Index

• func Entry(cluster, table string) bool
• func StatBreaker(cluster, table string, err error)
• type Breaker
• type BreakerManager

Functions

func Entry

func Entry(cluster, table string) bool

Entry check if allow request

func StatBreaker

func StatBreaker(cluster, table string, err error)

StatBreaker state errors for breaker

Types

type Breaker

type Breaker struct {
	Rejected      int32
	RejectedStart int64
	Count         int32
}

type BreakerManager

type BreakerManager struct {
	Breakers map[string]*Breaker
	// contains filtered or unexported fields
}

TOOD 简单计数法实现熔断操作，后续改为滑动窗口或三方组件的方式