Versions in this module Expand all Collapse all v0 v0.0.11 Feb 5, 2024 v0.0.8 Dec 7, 2023 Changes in this version + const DefaultGlobalRate + const DefaultMaxConcurrent + const PromLabelDC + const PromLabelPath + const PromLabelSVC + const PromLabelStatus + var ConcurrentReq int64 + var ConcurrentRequestCount prometheus.GaugeFunc + var GlobalRate *expvar.Int + var GlobalRatelimiter atomic.Value + var HTTPReqTotal *prometheus.CounterVec + var MaxConcurrent *expvar.Int + var PushMsgTotal *prometheus.CounterVec + var RedisConsulClient redis.Cmdable + var ServiceStateWait *model.StateWait + var SeviceStateCache *cache.Cache + var StateMQConsumer rocketmq.PushConsumer + var StateMQProducer rocketmq.Producer + var StateReadOnlyRedis redis.Cmdable + var StateTopic string + func InitConsulCacheResource() + func InitFetcherResource() + func InitSingleRedis(conf config.RedisConf, role string) redis.Cmdable