resource

Documentation

Index

• Constants
• Variables
• func InitConsulCacheResource()
• func InitFetcherResource()
• func InitSingleRedis(conf config.RedisConf, role string) redis.Cmdable

Constants

const (
	PromLabelPath   = "path"
	PromLabelStatus = "status"

	PromLabelSVC = "service"
	PromLabelDC  = "dc"
)

const (
	DefaultGlobalRate    = 5000
	DefaultMaxConcurrent = 50000
)

Variables

var (
	// {dc}:{service} -> *ServiceState
	SeviceStateCache   *coolcache.CoolCache
	StateReadOnlyRedis redis.Cmdable
	StateMQConsumer    rocketmq.PushConsumer

	// 用于控制block query
	ServiceStateWait *model.StateWait

	// 并发执行的请求数
	ConcurrentReq int64
)

var (
	RedisConsulClient redis.Cmdable

	StateTopic      string
	StateMQProducer rocketmq.Producer
)

var (
	HTTPReqTotal           *prometheus.CounterVec
	ConcurrentRequestCount prometheus.GaugeFunc

	PushMsgTotal *prometheus.CounterVec
)

var (
	// 	*rate.Limiter
	GlobalRatelimiter atomic.Value
	GlobalRate        *expvar.Int

	MaxConcurrent *expvar.Int
)

Functions

func InitConsulCacheResource

func InitConsulCacheResource()

func InitFetcherResource

func InitFetcherResource()

func InitSingleRedis

func InitSingleRedis(conf config.RedisConf, role string) redis.Cmdable