public

Documentation

Index

• func ConfCircuitBreaker(openStream bool)
• type FlowCountService
  • func NewFlowCountService(appID string, interval time.Duration) (*FlowCountService, error)
  • func (o *FlowCountService) Increase()

Functions

func ConfCircuitBreaker

func ConfCircuitBreaker(openStream bool)

ConfCircuitBreaker 设置熔断

Types

type FlowCountService

type FlowCountService struct {
	AppID       string        // 应用 ID
	Interval    time.Duration // 采集频率
	TotalCount  int64         // 当前总共请求数
	QPS         int64         // QPS
	Unix        int64         // 上次 unix 时间戳
	TickerCount int64         // 当前流量
}

FlowCountService 限流，数据、流量统计

func NewFlowCountService

func NewFlowCountService(appID string, interval time.Duration) (*FlowCountService, error)

NewFlowCountService description

func (*FlowCountService) Increase

func (o *FlowCountService) Increase()

Increase 原子增加