utils

Documentation

Index

• Constants
• func Abort(ctx *gin.Context, code int, msg string)
• func Extract(bind string) (string, error)
• func InBlacklist(uid string) bool
• func Listen(network string, addr string) (net.Listener, error)
• func ResponseJSON(ctx *gin.Context, code int, msg string, data interface{})
• func UpdateProc(service string)
• func WatchBlacklist()
• type CBOption
  • func WithDuration(duration int64) CBOption
  • func WithFailsLimit(failsRateLimit int64) CBOption
  • func WithLatencyLimit(latencyLimit int64) CBOption
  • func WithTotalLimit(totalLimit int64) CBOption
• type CircuitBreaker
  • func NewCircuitBreaker(opts ...CBOption) *CircuitBreaker
  • func (cb *CircuitBreaker) Allow(f func() bool) bool
• type Counter
  • func (c *Counter) Add() int64
  • func (c *Counter) Load() int64
  • func (c *Counter) Reset()
• type RateLimiter
  • func NewRateLimiter(size int, rate int64, mode int) (RateLimiter, error)
• type Response

Constants

const (
	FanIn  = 1 << 0
	FanOut = 1 << 1
)

Functions

func Abort

func Abort(ctx *gin.Context, code int, msg string)

func Extract

func Extract(bind string) (string, error)

func InBlacklist

func InBlacklist(uid string) bool

func Listen

func Listen(network string, addr string) (net.Listener, error)

func ResponseJSON

func ResponseJSON(ctx *gin.Context, code int, msg string, data interface{})

func UpdateProc

func UpdateProc(service string)

func WatchBlacklist

func WatchBlacklist()

Types

type CBOption

type CBOption func(cb *CircuitBreaker)

func WithDuration

func WithDuration(duration int64) CBOption

func WithFailsLimit

func WithFailsLimit(failsRateLimit int64) CBOption

func WithLatencyLimit

func WithLatencyLimit(latencyLimit int64) CBOption

func WithTotalLimit

func WithTotalLimit(totalLimit int64) CBOption

type CircuitBreaker

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

func NewCircuitBreaker

func NewCircuitBreaker(opts ...CBOption) *CircuitBreaker

func (*CircuitBreaker) Allow

func (cb *CircuitBreaker) Allow(f func() bool) bool

type Counter

type Counter int64

func (*Counter) Add

func (c *Counter) Add() int64

func (*Counter) Load

func (c *Counter) Load() int64

func (*Counter) Reset

func (c *Counter) Reset()

type RateLimiter

type RateLimiter interface {
	Push(t pool.Task) bool
	Pop() (pool.Task, bool)
	Close() error
}

func NewRateLimiter

func NewRateLimiter(size int, rate int64, mode int) (RateLimiter, error)

type Response

type Response struct {
	Code int         `json:"code"` // 业务错误码
	Data interface{} `json:"data"` // 数据
	Msg  string      `json:"msg"`  // 提示信息
}