rpc

Documentation

Index

• 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 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)

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
}

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)