cloudmonitoring

Documentation

Overview

Package cloudmonitoring provides primitives for Cloud Monitoring integration.

Index

• type MetricMiddleware
  • func NewMetricMiddleware() (MetricMiddleware, error)
  • func (m *MetricMiddleware) GRPCStreamServerInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
  • func (m *MetricMiddleware) GRPCUnaryClientInterceptor(ctx context.Context, fullMethod string, request interface{}, ...) error
  • func (m *MetricMiddleware) GRPCUnaryServerInterceptor(ctx context.Context, request interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)

Types

type MetricMiddleware

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

func NewMetricMiddleware

func NewMetricMiddleware() (MetricMiddleware, error)

func (*MetricMiddleware) GRPCStreamServerInterceptor

func (m *MetricMiddleware) GRPCStreamServerInterceptor(
	srv interface{},
	ss grpc.ServerStream,
	info *grpc.StreamServerInfo,
	handler grpc.StreamHandler,
) (err error)

GRPCStreamServerInterceptor implements grpc.UnaryServerInterceptor and emits metrics for request count and request duration when a gRPC server receives streaming requests.

func (*MetricMiddleware) GRPCUnaryClientInterceptor

func (m *MetricMiddleware) GRPCUnaryClientInterceptor(
	ctx context.Context,
	fullMethod string,
	request interface{},
	response interface{},
	cc *grpc.ClientConn,
	invoker grpc.UnaryInvoker,
	opts ...grpc.CallOption,
) error

GRPCUnaryClientInterceptor provides request logging as a grpc.UnaryClientInterceptor.

func (*MetricMiddleware) GRPCUnaryServerInterceptor

func (m *MetricMiddleware) GRPCUnaryServerInterceptor(
	ctx context.Context,
	request interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (resp interface{}, err error)

GRPCUnaryServerInterceptor implements grpc.UnaryServerInterceptor and emits metrics for request count and request duration when a gRPC server receives requests.