instrumentation

type MetricsServer ¶

type MetricsServer struct {
	// contains filtered or unexported fields
}

func NewMetricsServer(port int, registry *prometheus.Registry, logger log.Logger) *MetricsServer

func (s *MetricsServer) Start() error

func (s *MetricsServer) Stop()

type TracerTransport ¶

type TracerTransport struct {
	Next http.RoundTripper
}

TracerTransport uses opentracing.GlobalTracer() to inject request trace span (if any) to the request headers, then it passes then handling to Next, or to http.DefaultTransport if Next is nil.

func (t TracerTransport) RoundTrip(req *http.Request) (*http.Response, error)