metrics

Documentation

Index

• type Client
  • func NewClient(meter metric.Meter) *Client
  • func (c *Client) Stream(stream grpc.ClientStream, opts metric.MeasurementOption) grpc.ClientStream
  • func (c *Client) StreamInterceptor() grpc.StreamClientInterceptor
  • func (c *Client) UnaryInterceptor() grpc.UnaryClientInterceptor
• type ClientStream
  • func (s *ClientStream) RecvMsg(m any) error
  • func (s *ClientStream) SendMsg(m any) error
• type Server
  • func NewServer(meter metric.Meter) *Server
  • func (s *Server) Stream(stream grpc.ServerStream, opts metric.MeasurementOption) grpc.ServerStream
  • func (s *Server) StreamInterceptor() grpc.StreamServerInterceptor
  • func (s *Server) UnaryInterceptor() grpc.UnaryServerInterceptor
• type ServerStream
  • func (s *ServerStream) RecvMsg(m any) error
  • func (s *ServerStream) SendMsg(m any) error

Types

type Client

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

Client for metrics.

func NewClient

func NewClient(meter metric.Meter) *Client

NewClient for metrics.

func (*Client) Stream

func (c *Client) Stream(stream grpc.ClientStream, opts metric.MeasurementOption) grpc.ClientStream

Stream fpr client.

func (*Client) StreamInterceptor

func (c *Client) StreamInterceptor() grpc.StreamClientInterceptor

StreamInterceptor is a gRPC client-side interceptor that provides prometheus monitoring for Streaming RPCs.

func (*Client) UnaryInterceptor

func (c *Client) UnaryInterceptor() grpc.UnaryClientInterceptor

UnaryInterceptor is a gRPC client-side interceptor that provides prometheus monitoring for Unary RPCs.

type ClientStream

type ClientStream struct {
	grpc.ClientStream
	// contains filtered or unexported fields
}

ClientStream wraps grpc.ClientStream allowing each Sent/Recv of message to increment counters.

func (*ClientStream) RecvMsg

func (s *ClientStream) RecvMsg(m any) error

func (*ClientStream) SendMsg

func (s *ClientStream) SendMsg(m any) error

type Server

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

Server for metrics.

func NewServer

func NewServer(meter metric.Meter) *Server

NewServer for metrics.

func (*Server) Stream

func (s *Server) Stream(stream grpc.ServerStream, opts metric.MeasurementOption) grpc.ServerStream

Stream for the server.

func (*Server) StreamInterceptor

func (s *Server) StreamInterceptor() grpc.StreamServerInterceptor

StreamInterceptor for metrics.

func (*Server) UnaryInterceptor

func (s *Server) UnaryInterceptor() grpc.UnaryServerInterceptor

UnaryInterceptor for metrics.

type ServerStream

type ServerStream struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

ServerStream wraps grpc.ServerStream allowing each Sent/Recv of message to increment counters.

func (*ServerStream) RecvMsg

func (s *ServerStream) RecvMsg(m any) error

func (*ServerStream) SendMsg

func (s *ServerStream) SendMsg(m any) error