rpc

Documentation

Index

• func InitRpcMetrics(m metric.Meter)
• type ClientRpcAttrsExtractor
  • func (s *ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey() attribute.Key
  • func (s *ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, ...) ([]attribute.KeyValue, context.Context)
  • func (s *ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, ...) ([]attribute.KeyValue, context.Context)
• type RpcAttrsExtractor
  • func (r *RpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, ...) ([]attribute.KeyValue, context.Context)
  • func (r *RpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, ...) ([]attribute.KeyValue, context.Context)
• type RpcAttrsGetter
• type RpcClientMetric
  • func RpcClientMetrics(key string) *RpcClientMetric
  • func (h *RpcClientMetric) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, endTime time.Time)
  • func (h *RpcClientMetric) OnAfterStart(context context.Context, endTime time.Time)
  • func (h *RpcClientMetric) OnBeforeEnd(ctx context.Context, startAttributes []attribute.KeyValue, startTime time.Time) context.Context
  • func (h *RpcClientMetric) OnBeforeStart(parentContext context.Context, startTime time.Time) context.Context
• type RpcServerMetric
  • func RpcServerMetrics(key string) *RpcServerMetric
  • func (h *RpcServerMetric) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, endTime time.Time)
  • func (h *RpcServerMetric) OnAfterStart(context context.Context, endTime time.Time)
  • func (h *RpcServerMetric) OnBeforeEnd(ctx context.Context, startAttributes []attribute.KeyValue, startTime time.Time) context.Context
  • func (h *RpcServerMetric) OnBeforeStart(parentContext context.Context, startTime time.Time) context.Context
• type RpcSpanNameExtractor
  • func (r *RpcSpanNameExtractor[REQUEST]) Extract(request REQUEST) string
• type ServerRpcAttrsExtractor
  • func (s *ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey() attribute.Key
  • func (s *ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, ...) ([]attribute.KeyValue, context.Context)
  • func (s *ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, ...) ([]attribute.KeyValue, context.Context)

Functions

func InitRpcMetrics

func InitRpcMetrics(m metric.Meter)

InitRpcMetrics so we need to make sure the otel_setup is executed before all the init() function related to issue rpcs://github.com/alibaba/opentelemetry-go-auto-instrumentation/issues/48

Types

type ClientRpcAttrsExtractor

type ClientRpcAttrsExtractor[REQUEST any, RESPONSE any, GETTER RpcAttrsGetter[REQUEST]] struct {
	Base RpcAttrsExtractor[REQUEST, RESPONSE, GETTER]
}

func (*ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey

func (s *ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey() attribute.Key

func (*ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd

func (s *ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, response RESPONSE, err error) ([]attribute.KeyValue, context.Context)

func (*ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart

func (s *ClientRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, request REQUEST) ([]attribute.KeyValue, context.Context)

type RpcAttrsExtractor

type RpcAttrsExtractor[REQUEST any, RESPONSE any, GETTER RpcAttrsGetter[REQUEST]] struct {
	Getter GETTER
}

func (*RpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd

func (r *RpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, response RESPONSE, err error) ([]attribute.KeyValue, context.Context)

func (*RpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart

func (r *RpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, request REQUEST) ([]attribute.KeyValue, context.Context)

type RpcAttrsGetter

type RpcAttrsGetter[REQUEST any] interface {
	GetSystem(request REQUEST) string
	GetService(request REQUEST) string
	GetMethod(request REQUEST) string
	GetServerAddress(request REQUEST) string
}

type RpcClientMetric

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

func RpcClientMetrics

func RpcClientMetrics(key string) *RpcClientMetric

func (*RpcClientMetric) OnAfterEnd

func (h *RpcClientMetric) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, endTime time.Time)

func (*RpcClientMetric) OnAfterStart

func (h *RpcClientMetric) OnAfterStart(context context.Context, endTime time.Time)

func (*RpcClientMetric) OnBeforeEnd

func (h *RpcClientMetric) OnBeforeEnd(ctx context.Context, startAttributes []attribute.KeyValue, startTime time.Time) context.Context

func (*RpcClientMetric) OnBeforeStart

func (h *RpcClientMetric) OnBeforeStart(parentContext context.Context, startTime time.Time) context.Context

type RpcServerMetric

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

func RpcServerMetrics

func RpcServerMetrics(key string) *RpcServerMetric

func (*RpcServerMetric) OnAfterEnd

func (h *RpcServerMetric) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, endTime time.Time)

func (*RpcServerMetric) OnAfterStart

func (h *RpcServerMetric) OnAfterStart(context context.Context, endTime time.Time)

func (*RpcServerMetric) OnBeforeEnd

func (h *RpcServerMetric) OnBeforeEnd(ctx context.Context, startAttributes []attribute.KeyValue, startTime time.Time) context.Context

func (*RpcServerMetric) OnBeforeStart

func (h *RpcServerMetric) OnBeforeStart(parentContext context.Context, startTime time.Time) context.Context

type RpcSpanNameExtractor

type RpcSpanNameExtractor[REQUEST any] struct {
	Getter RpcAttrsGetter[REQUEST]
}

func (*RpcSpanNameExtractor[REQUEST]) Extract

func (r *RpcSpanNameExtractor[REQUEST]) Extract(request REQUEST) string

type ServerRpcAttrsExtractor

type ServerRpcAttrsExtractor[REQUEST any, RESPONSE any, GETTER RpcAttrsGetter[REQUEST]] struct {
	Base RpcAttrsExtractor[REQUEST, RESPONSE, GETTER]
}

func (*ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey

func (s *ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) GetSpanKey() attribute.Key

func (*ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd

func (s *ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnEnd(attributes []attribute.KeyValue, context context.Context, request REQUEST, response RESPONSE, err error) ([]attribute.KeyValue, context.Context)

func (*ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart

func (s *ServerRpcAttrsExtractor[REQUEST, RESPONSE, GETTER]) OnStart(attributes []attribute.KeyValue, parentContext context.Context, request REQUEST) ([]attribute.KeyValue, context.Context)