metric

Documentation

Index

• Variables
• func AddIsMatchedTag(ctx context.Context, target string) (context.Context, error)
• func AddMismatchedTag(ctx context.Context, reason string) (context.Context, error)
• func InitializeLatencyTracking(ctx context.Context) context.Context
• func RecordMatched(ctx context.Context)
• func RecordMismatched(ctx context.Context, mismatchedPath string)
• type MetricServer
  • func NewMetricServer(server MetricServerImpl) MetricServer
• type MetricServerImpl
  • func (s *MetricServerImpl) Start() (err error)

Variables

var (
	// MLatencyMs records the time it took for matching operation
	MLatencyMs = stats.Float64("matching/latency", "Latency of matching operation", "ms")

	// KeyIsMatched holds matching operation result. It will be either "matched" or "mismatched"
	KeyIsMatched, _ = tag.NewKey("is_matched")

	// KeyMismatchedPath holds information of the mismatched path
	KeyMismatchedPath, _ = tag.NewKey("mismatched_path")
)

Functions

func AddIsMatchedTag

func AddIsMatchedTag(ctx context.Context, target string) (context.Context, error)

AddIsMatchedTag ...

func AddMismatchedTag

func AddMismatchedTag(ctx context.Context, reason string) (context.Context, error)

AddMismatchedTag ...

func InitializeLatencyTracking

func InitializeLatencyTracking(ctx context.Context) context.Context

InitializeLatencyTracking ...

func RecordMatched

func RecordMatched(ctx context.Context)

func RecordMismatched

func RecordMismatched(ctx context.Context, mismatchedPath string)

Types

type MetricServer

type MetricServer interface {
	Start() error
}

func NewMetricServer

func NewMetricServer(server MetricServerImpl) MetricServer

type MetricServerImpl

type MetricServerImpl struct {
	dig.In
	config.Config
}

func (*MetricServerImpl) Start

func (s *MetricServerImpl) Start() (err error)