cloudmonitoring

Documentation

Overview

Package cloudmonitoring provides primitives for Cloud Monitoring integration.

Index

• func StartExporter(ctx context.Context, exporterConfig ExporterConfig, ...) (func(), error)
• type ExporterConfig
• type MetricMiddleware
  • func NewMetricMiddleware() (MetricMiddleware, 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)

Functions

func StartExporter

func StartExporter(
	ctx context.Context,
	exporterConfig ExporterConfig,
	resource *resource.Resource,
) (func(), error)

StartExporter starts the OpenTelemetry Cloud Monitoring exporter.

Types

type ExporterConfig

type ExporterConfig struct {
	Enabled                bool          `onGCE:"false"`
	Interval               time.Duration `default:"60s"`
	RuntimeInstrumentation bool          `onGCE:"true"`
	HostInstrumentation    bool          `onGCE:"true"`
}

ExporterConfig configures the metrics exporter.

type MetricMiddleware

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

func NewMetricMiddleware

func NewMetricMiddleware() (MetricMiddleware, error)

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.