metrics

Documentation

Index

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

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(st 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 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(st 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.