metrics_collector

Documentation

Index

• Constants
• Variables
• func LabelMap(protocol, method, ip string) map[string]string
• func NewMetricsCollector() filter.Filter
• type MetricsCollector
  • func (f *MetricsCollector) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result
  • func (f *MetricsCollector) OnResponse(_ context.Context, result protocol.Result, invoker protocol.Invoker, ...) protocol.Result

Constants

const (
	StartTimeAttachment           = "StartTime"
	RequestCounter                = "request_count"
	RequestDurationSummary        = "request_duration_ns"
	RequestSuccessCounter         = "request_success"
	RequestUnknownErrorCounter    = "request_unknown_error"
	RequestTimeoutCounter         = "request_timeout"
	RequestOfflineDroppedCounter  = "request_offline_dropped"
	RequestReachLimitationCounter = "request_reach_limitation"
	AdaptiveServiceRemainingGauge = "adaptive_service_remaining"
	AdaptiveServiceInflightGauge  = "adaptive_service_inflight"
	LabelProtocol                 = "protocol"
	LabelMethod                   = "method"
	LabelTargetIP                 = "target_ip"
)

Variables

var ErrConsumerRequestTimeoutStr = "maybe the client read timeout or fail to decode tcp stream in Writer.Write"

Functions

func LabelMap

func LabelMap(protocol, method, ip string) map[string]string

func NewMetricsCollector

func NewMetricsCollector() filter.Filter

Types

type MetricsCollector

type MetricsCollector struct{}

func (*MetricsCollector) Invoke

func (f *MetricsCollector) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result

func (*MetricsCollector) OnResponse

func (f *MetricsCollector) OnResponse(_ context.Context, result protocol.Result, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result