tracing

Documentation

Index

• type ClientPrometheusPlugin
  • func NewClientPrometheusPlugin() *ClientPrometheusPlugin
  • func (p *ClientPrometheusPlugin) DoPostCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error
  • func (p *ClientPrometheusPlugin) DoPreCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error
• type OpenTracingPlugin
  • func NewOpenTracingPlugin(tracer opentracing.Tracer) *OpenTracingPlugin
  • func (p *OpenTracingPlugin) DoPostCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error
  • func (p *OpenTracingPlugin) DoPostReadRequestHeader(ctx context.Context, r *core.Request) error
  • func (p *OpenTracingPlugin) DoPostWriteResponse(ctx context.Context, resp *core.Response, body interface{}) error
  • func (p *OpenTracingPlugin) DoPreCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error
• type ServerPrometheusPlugin
  • func NewServerPrometheusPlugin() *ServerPrometheusPlugin
  • func (p *ServerPrometheusPlugin) DoPostReadRequestHeader(ctx context.Context, r *core.Request) error
  • func (p *ServerPrometheusPlugin) DoPostWriteResponse(ctx context.Context, resp *core.Response, body interface{}) error

Types

type ClientPrometheusPlugin

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

ClientPrometheusPlugin for Prometheus.

func NewClientPrometheusPlugin

func NewClientPrometheusPlugin() *ClientPrometheusPlugin

func (*ClientPrometheusPlugin) DoPostCall

func (p *ClientPrometheusPlugin) DoPostCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

func (*ClientPrometheusPlugin) DoPreCall

func (p *ClientPrometheusPlugin) DoPreCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

type OpenTracingPlugin

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

OpenTracingPlugin for opentracing and zipkin.

func NewOpenTracingPlugin

func NewOpenTracingPlugin(tracer opentracing.Tracer) *OpenTracingPlugin

func (*OpenTracingPlugin) DoPostCall

func (p *OpenTracingPlugin) DoPostCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

func (*OpenTracingPlugin) DoPostReadRequestHeader

func (p *OpenTracingPlugin) DoPostReadRequestHeader(ctx context.Context, r *core.Request) error

func (*OpenTracingPlugin) DoPostWriteResponse

func (p *OpenTracingPlugin) DoPostWriteResponse(ctx context.Context, resp *core.Response, body interface{}) error

func (*OpenTracingPlugin) DoPreCall

func (p *OpenTracingPlugin) DoPreCall(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

type ServerPrometheusPlugin

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

ServerPrometheusPlugin for Prometheus.

func NewServerPrometheusPlugin

func NewServerPrometheusPlugin() *ServerPrometheusPlugin

func (*ServerPrometheusPlugin) DoPostReadRequestHeader

func (p *ServerPrometheusPlugin) DoPostReadRequestHeader(ctx context.Context, r *core.Request) error

func (*ServerPrometheusPlugin) DoPostWriteResponse

func (p *ServerPrometheusPlugin) DoPostWriteResponse(ctx context.Context, resp *core.Response, body interface{}) error