global_api_strategy

Documentation

Overview

全局限流器（令牌桶）

Index

• Variables
• type GlobalRateLimitStrategyClass
  • func (globalRateLimit *GlobalRateLimitStrategyClass) Execute(out _type.IApiSession, param interface{}) *go_error.ErrorInfo
  • func (globalRateLimit *GlobalRateLimitStrategyClass) GetDescription() string
  • func (globalRateLimit *GlobalRateLimitStrategyClass) GetErrorCode() uint64
  • func (globalRateLimit *GlobalRateLimitStrategyClass) GetName() string
  • func (globalRateLimit *GlobalRateLimitStrategyClass) Init(param interface{})
  • func (globalRateLimit *GlobalRateLimitStrategyClass) SetErrorCode(code uint64)
• type GlobalRateLimitStrategyParam
• type OpenCensusClass
  • func (openCensus *OpenCensusClass) Execute(out _type.IApiSession, param interface{}) *go_error.ErrorInfo
  • func (openCensus *OpenCensusClass) GetDescription() string
  • func (openCensus *OpenCensusClass) GetErrorCode() uint64
  • func (openCensus *OpenCensusClass) GetName() string
  • func (openCensus *OpenCensusClass) Init(param interface{})
  • func (openCensus *OpenCensusClass) SetErrorCode(code uint64)
• type OpenCensusStrategyParam

Variables

var GlobalRateLimitStrategy = GlobalRateLimitStrategyClass{
	// contains filtered or unexported fields
}

var OpenCensusStrategy = OpenCensusClass{}

Types

type GlobalRateLimitStrategyClass

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

func (*GlobalRateLimitStrategyClass) Execute

func (globalRateLimit *GlobalRateLimitStrategyClass) Execute(out _type.IApiSession, param interface{}) *go_error.ErrorInfo

func (*GlobalRateLimitStrategyClass) GetDescription

func (globalRateLimit *GlobalRateLimitStrategyClass) GetDescription() string

func (*GlobalRateLimitStrategyClass) GetErrorCode

func (globalRateLimit *GlobalRateLimitStrategyClass) GetErrorCode() uint64

func (*GlobalRateLimitStrategyClass) GetName

func (globalRateLimit *GlobalRateLimitStrategyClass) GetName() string

func (*GlobalRateLimitStrategyClass) Init

func (globalRateLimit *GlobalRateLimitStrategyClass) Init(param interface{})

func (*GlobalRateLimitStrategyClass) SetErrorCode

func (globalRateLimit *GlobalRateLimitStrategyClass) SetErrorCode(code uint64)

type GlobalRateLimitStrategyParam

type GlobalRateLimitStrategyParam struct {
	FillInterval time.Duration // 每这么长时间往令牌桶塞一个令牌
}

type OpenCensusClass

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

func (*OpenCensusClass) Execute

func (openCensus *OpenCensusClass) Execute(out _type.IApiSession, param interface{}) *go_error.ErrorInfo

func (*OpenCensusClass) GetDescription

func (openCensus *OpenCensusClass) GetDescription() string

func (*OpenCensusClass) GetErrorCode

func (openCensus *OpenCensusClass) GetErrorCode() uint64

func (*OpenCensusClass) GetName

func (openCensus *OpenCensusClass) GetName() string

func (*OpenCensusClass) Init

func (openCensus *OpenCensusClass) Init(param interface{})

func (*OpenCensusClass) SetErrorCode

func (openCensus *OpenCensusClass) SetErrorCode(code uint64)

type OpenCensusStrategyParam

type OpenCensusStrategyParam struct {
	StackDriverOption *stackdriver.Options
	EnableTrace       bool
	EnableStats       bool
}