echo

Documentation

Index

• type StaticsWorker
  • func (s *StaticsWorker) AddAPICall(value plugin.APICallStatValue)
  • func (s *StaticsWorker) AddEventToLog(value plugin.EventToLog)
  • func (s *StaticsWorker) CreateRateLimitStatCollectorV1() *plugin.RateLimitStatCollectorV1
  • func (s *StaticsWorker) CreateRateLimitStatCollectorV2() *plugin.RateLimitStatCollectorV2
  • func (s *StaticsWorker) Destroy() error
  • func (s *StaticsWorker) DropRateLimitStatCollector(collector plugin.RateLimitStatCollector)
  • func (s *StaticsWorker) Initialize(conf *plugin.ConfigEntry) error
  • func (s *StaticsWorker) Name() string

Types

type StaticsWorker

type StaticsWorker struct {
}

StaticsWorker 智研上报处理器

func (*StaticsWorker) AddAPICall

func (s *StaticsWorker) AddAPICall(value plugin.APICallStatValue)

服务方法调用结果反馈，含有规则的计算周期

func (*StaticsWorker) AddEventToLog

func (s *StaticsWorker) AddEventToLog(value plugin.EventToLog)

添加日志时间

func (*StaticsWorker) CreateRateLimitStatCollectorV1

func (s *StaticsWorker) CreateRateLimitStatCollectorV1() *plugin.RateLimitStatCollectorV1

创建采集器V1，每个stream上来后获取一次

func (*StaticsWorker) CreateRateLimitStatCollectorV2

func (s *StaticsWorker) CreateRateLimitStatCollectorV2() *plugin.RateLimitStatCollectorV2

创建采集器V2，每个stream上来后获取一次

func (*StaticsWorker) Destroy

func (s *StaticsWorker) Destroy() error

*

• @brief 销毁统计插件

func (*StaticsWorker) DropRateLimitStatCollector

func (s *StaticsWorker) DropRateLimitStatCollector(collector plugin.RateLimitStatCollector)

归还采集器

func (*StaticsWorker) Initialize

func (s *StaticsWorker) Initialize(conf *plugin.ConfigEntry) error

*

• @brief 初始化统计插件

func (*StaticsWorker) Name

func (s *StaticsWorker) Name() string

Name 获取统计插件名称