limiter

Documentation

Index

• type FlowLimiter
  • func NewFlowLimiter() *FlowLimiter
  • func (counter *FlowLimiter) GetLimiter(serverName string, qps float64) (*rate.Limiter, error)
• type FlowLimiterItem

Types

type FlowLimiter

type FlowLimiter struct {
	FlowLmiterMap   map[string]*FlowLimiterItem
	FlowLmiterSlice []*FlowLimiterItem
	Locker          sync.RWMutex
}

var FlowLimiterHandler *FlowLimiter

func NewFlowLimiter

func NewFlowLimiter() *FlowLimiter

func (*FlowLimiter) GetLimiter

func (counter *FlowLimiter) GetLimiter(serverName string, qps float64) (*rate.Limiter, error)

type FlowLimiterItem

type FlowLimiterItem struct {
	ServiceName string
	Limter      *rate.Limiter
}