metrics

Documentation

Index

• Variables
• func MonitorAcquiredTokenCounter(serverName, clientID, flowControl, flowControlType, strategy, method string, ...)
• func MonitorAllocateRequest(serverName, clientID, flowControl, flowControlType, strategy, method string, ...)
• func MonitorLeaderElection(shard int, leader string, leaderState int)
• func MonitorLimiterRequest(req *http.Request, serverName, clientID string, ...)
• func Register()
• type MetricInfo
• type MetricObserver
• type UnionObserver

Variables

var (
	RateLimiterRequestCounterObservers        = newUnionObserver()
	RateLimiterRequestLatenciesObservers      = newUnionObserver()
	RateLimiterResponseSizesObservers         = newUnionObserver()
	RateLimiterAllocatedLimitsObservers       = newUnionObserver()
	RateLimiterAllocatedTokenCounterObservers = newUnionObserver()
	RateLimiterLeaderElectionObservers        = newUnionObserver()
)

Functions

func MonitorAcquiredTokenCounter

func MonitorAcquiredTokenCounter(serverName, clientID, flowControl, flowControlType, strategy, method string, limit int32)

func MonitorAllocateRequest

func MonitorAllocateRequest(serverName, clientID, flowControl, flowControlType, strategy, method string, limit int32)

func MonitorLeaderElection

func MonitorLeaderElection(shard int, leader string, leaderState int)

func MonitorLimiterRequest

func MonitorLimiterRequest(req *http.Request, serverName, clientID string, requestInfo *request.RequestInfo, httpCode, respSize int, elapsed time.Duration)

func Register

func Register()

Register all metrics.

Types

type MetricInfo

type MetricInfo struct {
	Request      *http.Request
	ServerName   string
	ClientID     string
	Verb         string
	Resource     string
	HttpCode     string
	ResponseSize float64
	Latency      float64

	// for limit allocation
	FlowControl     string
	FlowControlType string
	Strategy        string
	Method          string
	Limit           float64

	// for leader election
	Shard       string
	Leader      string
	LeaderState int
}

type MetricObserver

type MetricObserver interface {
	Observe(metric MetricInfo)
}

type UnionObserver

type UnionObserver interface {
	MetricObserver
	AddObserver(MetricObserver)
}