resource

Documentation

Index

• Variables
• func AddAttrKeysContext(ctx context.Context) context.Context
• func AddKeysContext(ctx context.Context, ops ...AddKeyContexFunc) context.Context
• func AddMetricKeysContext(ctx context.Context) context.Context
• func AppendAttrsContext(ctx context.Context, values ...string) context.Context
• func AppendMetricCountContext(ctx context.Context, values ...string) context.Context
• func Attrs(dim Dimension) []attribute.KeyValue
• func ExtractAttrsWithContext(ctx context.Context) []attribute.KeyValue
• func GlobalMeter() metric.Meter
• func ReportBusinessMetric(ctx context.Context, attrs []attribute.KeyValue)
• func ReportMetric(ctx context.Context, dim Dimension, costTime time.Duration)
• func UpdateAttrsContext(ctx context.Context, values map[string]interface{}) error
• func UpdateMetricContext(ctx context.Context, values map[string]interface{}) error
• type AddKeyContexFunc
• type Dimension
• type HandlerWithContext
• type MetricMonitor
  • func NewMetricMonitor() *MetricMonitor
  • func (m *MetricMonitor) GetOrNewBusinessCounter(key string) (syncint64.Counter, error)
  • func (m *MetricMonitor) GetOrNewBusinessHistogram(key string) (syncfloat64.Histogram, error)

Variables

var (
	CallerMethodKey = attribute.Key("caller_method") // caller method
	CalleeMethodKey = attribute.Key("callee_method") // callee method
	PodIpKey        = attribute.Key("pod_ip")        // pod ip
	ServerNameKey   = attribute.Key("server_name")   // server name
	ErrorCodeKey    = attribute.Key("error_code")    // error code
)

dims

var (
	DefaultMetricMonitor = NewMetricMonitor()
)

var OpentelemetryDimsKey = "opentelemetry_dims_key"

var OpentelemetryMetricsKey = "opentelemetry_metrics_key"

Functions

func AddAttrKeysContext

func AddAttrKeysContext(ctx context.Context) context.Context

func AddKeysContext

func AddKeysContext(ctx context.Context, ops ...AddKeyContexFunc) context.Context

func AddMetricKeysContext

func AddMetricKeysContext(ctx context.Context) context.Context

func AppendAttrsContext

func AppendAttrsContext(ctx context.Context, values ...string) context.Context

func AppendMetricCountContext

func AppendMetricCountContext(ctx context.Context, values ...string) context.Context

func Attrs

func Attrs(dim Dimension) []attribute.KeyValue

func ExtractAttrsWithContext

func ExtractAttrsWithContext(ctx context.Context) []attribute.KeyValue

func GlobalMeter

func GlobalMeter() metric.Meter

func ReportBusinessMetric

func ReportBusinessMetric(ctx context.Context, attrs []attribute.KeyValue)

func ReportMetric

func ReportMetric(ctx context.Context, dim Dimension, costTime time.Duration)

func UpdateAttrsContext

func UpdateAttrsContext(ctx context.Context, values map[string]interface{}) error

func UpdateMetricContext

func UpdateMetricContext(ctx context.Context, values map[string]interface{}) error

Types

type AddKeyContexFunc

type AddKeyContexFunc func(ctx context.Context) context.Context

type Dimension

type Dimension struct {
	CalleeMethod string
	Error        error
}

type HandlerWithContext

type HandlerWithContext[REQ any, RESP any] func(context.Context, REQ) (RESP, error)

type MetricMonitor

type MetricMonitor struct {
	TotalReqCounter   syncint64.Counter
	FailCntCounter    syncint64.Counter
	CostTimeHistogram syncfloat64.Histogram

	BusinessCounters map[string]syncint64.Counter

	BusinessHistogram map[string]syncfloat64.Histogram
	// contains filtered or unexported fields
}

func NewMetricMonitor

func NewMetricMonitor() *MetricMonitor

func (*MetricMonitor) GetOrNewBusinessCounter

func (m *MetricMonitor) GetOrNewBusinessCounter(key string) (syncint64.Counter, error)

func (*MetricMonitor) GetOrNewBusinessHistogram

func (m *MetricMonitor) GetOrNewBusinessHistogram(key string) (syncfloat64.Histogram, error)