flow

Documentation

Index

• func NewCricuitBreaker(command string) control.IGoKitAdapter
• func NewTokenBucketLimit(token int, duration time.Duration, tp TokenType) control.IGoKitAdapter
• type CricuitBreaker
  • func (l CricuitBreaker) AdapterInit(args map[string]interface{}) error
  • func (l CricuitBreaker) HandlerFunc(handler gin.HandlerFunc) gin.HandlerFunc
  • func (l CricuitBreaker) Middleware() endpoint.Middleware
• type TokenBucketLimit
  • func (l TokenBucketLimit) AdapterInit(args map[string]interface{}) error
  • func (l TokenBucketLimit) HandlerFunc(handler gin.HandlerFunc) gin.HandlerFunc
  • func (l TokenBucketLimit) Middleware() endpoint.Middleware
• type TokenType

Functions

func NewCricuitBreaker

func NewCricuitBreaker(command string) control.IGoKitAdapter

func NewTokenBucketLimit

func NewTokenBucketLimit(token int, duration time.Duration, tp TokenType) control.IGoKitAdapter

Types

type CricuitBreaker

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

func (CricuitBreaker) AdapterInit

func (l CricuitBreaker) AdapterInit(args map[string]interface{}) error

func (CricuitBreaker) HandlerFunc

func (l CricuitBreaker) HandlerFunc(handler gin.HandlerFunc) gin.HandlerFunc

包装gin的HandlerFunc

func (CricuitBreaker) Middleware

func (l CricuitBreaker) Middleware() endpoint.Middleware

包装go-kit的middleware

type TokenBucketLimit

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

流量限制

func (TokenBucketLimit) AdapterInit

func (l TokenBucketLimit) AdapterInit(args map[string]interface{}) error

func (TokenBucketLimit) HandlerFunc

func (l TokenBucketLimit) HandlerFunc(handler gin.HandlerFunc) gin.HandlerFunc

包装gin的HandlerFunc

func (TokenBucketLimit) Middleware

func (l TokenBucketLimit) Middleware() endpoint.Middleware

包装go-kit的middleware

type TokenType

type TokenType int

const (
	TokenDelay TokenType = iota
	TokenError
)