otelgrpc

Documentation

Index

• func ExtractAddress(addr string) (host, port string)
• func GetProtoSize(p any) int
• func ParseFullMethod(fullMethod string) []attribute.KeyValue
• type Monitor
  • func NewOtelGRPCMonitor(hostName string) Monitor
  • func (m *Monitor) GetAttributes() []attribute.KeyValue
  • func (m *Monitor) RecordStream(ctx context.Context, start time.Time, method string, err error)
  • func (m *Monitor) RecordUnary(ctx context.Context, p UnaryParams)
  • func (m *Monitor) StreamClientInterceptor() grpc.StreamClientInterceptor
  • func (m *Monitor) UnaryClientInterceptor() grpc.UnaryClientInterceptor
• type UnaryParams

Functions

func ExtractAddress

func ExtractAddress(addr string) (host, port string)

func GetProtoSize

func GetProtoSize(p any) int

func ParseFullMethod

func ParseFullMethod(fullMethod string) []attribute.KeyValue

Types

type Monitor

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

func NewOtelGRPCMonitor

func NewOtelGRPCMonitor(hostName string) Monitor

func (*Monitor) GetAttributes

func (m *Monitor) GetAttributes() []attribute.KeyValue

func (*Monitor) RecordStream

func (m *Monitor) RecordStream(ctx context.Context, start time.Time, method string, err error)

func (*Monitor) RecordUnary

func (m *Monitor) RecordUnary(ctx context.Context, p UnaryParams)

func (*Monitor) StreamClientInterceptor

func (m *Monitor) StreamClientInterceptor() grpc.StreamClientInterceptor

func (*Monitor) UnaryClientInterceptor

func (m *Monitor) UnaryClientInterceptor() grpc.UnaryClientInterceptor

type UnaryParams

type UnaryParams struct {
	Start  time.Time
	Method string
	Req    any
	Res    any
	Err    error
}