metrics

Documentation

Index

• type Client
  • func NewClient(meter metric.Meter) *Client
  • func (c *Client) StreamInterceptor() grpc.StreamClientInterceptor
  • func (c *Client) UnaryInterceptor() grpc.UnaryClientInterceptor
• type ClientStream
  • func NewClientStream(params ClientStreamParams) *ClientStream
  • func (s *ClientStream) RecvMsg(m any) error
  • func (s *ClientStream) SendMsg(m any) error
• type ClientStreamParams
• type Server
  • func NewServer(meter metric.Meter) *Server
  • func (s *Server) StreamInterceptor() grpc.StreamServerInterceptor
  • func (s *Server) UnaryInterceptor() grpc.UnaryServerInterceptor
• type ServerStream
  • func NewServerStream(params ServerStreamParams) *ServerStream
  • func (s *ServerStream) RecvMsg(m any) error
  • func (s *ServerStream) SendMsg(m any) error
• type ServerStreamParams

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

func NewClientStream(params ClientStreamParams) *ClientStream

NewClientStream for metrics.

func (*ClientStream) RecvMsg

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

func (*ClientStream) SendMsg

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

type ClientStreamParams

type ClientStreamParams struct {
	Options          metric.MeasurementOption
	Received         metric.Int64Counter
	Sent             metric.Int64Counter
	Handled          metric.Int64Counter
	HandledHistogram metric.Float64Histogram

	grpc.ClientStream
}

ClientStreamParams for metrics.

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

func NewServerStream(params ServerStreamParams) *ServerStream

NewServerStream for metrics.

func (*ServerStream) RecvMsg

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

func (*ServerStream) SendMsg

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

type ServerStreamParams

type ServerStreamParams struct {
	Options          metric.MeasurementOption
	Received         metric.Int64Counter
	Sent             metric.Int64Counter
	Handled          metric.Int64Counter
	HandledHistogram metric.Float64Histogram

	grpc.ServerStream
}

ServerStreamParams for metrics.