otelgrpc

Documentation

Index

• func ExtractAddress(addr string) (host, port string)
• func GetProtoSize(p any) int
• func ParseFullMethod(fullMethod string) []attribute.KeyValue
• type Meter
  • func NewMeter(hostName string, opts ...Option) Meter
  • func (m *Meter) GetAttributes() []attribute.KeyValue
  • func (m *Meter) RecordStream(ctx context.Context, start time.Time, method string, err error)
  • func (m *Meter) RecordUnary(ctx context.Context, p UnaryParams)
  • func (m *Meter) StreamClientInterceptor() grpc.StreamClientInterceptor
  • func (m *Meter) UnaryClientInterceptor() grpc.UnaryClientInterceptor
• type MeterOpts
• type Option
  • func WithMeterName(meterName string) Option
• 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 Meter

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

func NewMeter

func NewMeter(hostName string, opts ...Option) Meter

func (*Meter) GetAttributes

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

func (*Meter) RecordStream

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

func (*Meter) RecordUnary

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

func (*Meter) StreamClientInterceptor

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

func (*Meter) UnaryClientInterceptor

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

type MeterOpts

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

type Option

type Option func(*MeterOpts)

func WithMeterName

func WithMeterName(meterName string) Option

type UnaryParams

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