metrics_service.pb.gw.go

Documentation: go.opentelemetry.io/proto/otlp/collector/metrics/v1

     1  // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
     2  // source: opentelemetry/proto/collector/metrics/v1/metrics_service.proto
     3  
     4  /*
     5  Package v1 is a reverse proxy.
     6  
     7  It translates gRPC into RESTful JSON APIs.
     8  */
     9  package v1
    10  
    11  import (
    12  	"context"
    13  	"io"
    14  	"net/http"
    15  
    16  	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
    17  	"github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
    18  	"google.golang.org/grpc"
    19  	"google.golang.org/grpc/codes"
    20  	"google.golang.org/grpc/grpclog"
    21  	"google.golang.org/grpc/metadata"
    22  	"google.golang.org/grpc/status"
    23  	"google.golang.org/protobuf/proto"
    24  )
    25  
    26  // Suppress "imported and not used" errors
    27  var _ codes.Code
    28  var _ io.Reader
    29  var _ status.Status
    30  var _ = runtime.String
    31  var _ = utilities.NewDoubleArray
    32  var _ = metadata.Join
    33  
    34  func request_MetricsService_Export_0(ctx context.Context, marshaler runtime.Marshaler, client MetricsServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
    35  	var protoReq ExportMetricsServiceRequest
    36  	var metadata runtime.ServerMetadata
    37  
    38  	newReader, berr := utilities.IOReaderFactory(req.Body)
    39  	if berr != nil {
    40  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
    41  	}
    42  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
    43  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
    44  	}
    45  
    46  	msg, err := client.Export(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
    47  	return msg, metadata, err
    48  
    49  }
    50  
    51  func local_request_MetricsService_Export_0(ctx context.Context, marshaler runtime.Marshaler, server MetricsServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
    52  	var protoReq ExportMetricsServiceRequest
    53  	var metadata runtime.ServerMetadata
    54  
    55  	newReader, berr := utilities.IOReaderFactory(req.Body)
    56  	if berr != nil {
    57  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
    58  	}
    59  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
    60  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
    61  	}
    62  
    63  	msg, err := server.Export(ctx, &protoReq)
    64  	return msg, metadata, err
    65  
    66  }
    67  
    68  // RegisterMetricsServiceHandlerServer registers the http handlers for service MetricsService to "mux".
    69  // UnaryRPC     :call MetricsServiceServer directly.
    70  // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
    71  // Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMetricsServiceHandlerFromEndpoint instead.
    72  func RegisterMetricsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MetricsServiceServer) error {
    73  
    74  	mux.Handle("POST", pattern_MetricsService_Export_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
    75  		ctx, cancel := context.WithCancel(req.Context())
    76  		defer cancel()
    77  		var stream runtime.ServerTransportStream
    78  		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
    79  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
    80  		var err error
    81  		var annotatedContext context.Context
    82  		annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/opentelemetry.proto.collector.metrics.v1.MetricsService/Export", runtime.WithHTTPPathPattern("/v1/metrics"))
    83  		if err != nil {
    84  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
    85  			return
    86  		}
    87  		resp, md, err := local_request_MetricsService_Export_0(annotatedContext, inboundMarshaler, server, req, pathParams)
    88  		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
    89  		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
    90  		if err != nil {
    91  			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
    92  			return
    93  		}
    94  
    95  		forward_MetricsService_Export_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
    96  
    97  	})
    98  
    99  	return nil
   100  }
   101  
   102  // RegisterMetricsServiceHandlerFromEndpoint is same as RegisterMetricsServiceHandler but
   103  // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
   104  func RegisterMetricsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
   105  	conn, err := grpc.Dial(endpoint, opts...)
   106  	if err != nil {
   107  		return err
   108  	}
   109  	defer func() {
   110  		if err != nil {
   111  			if cerr := conn.Close(); cerr != nil {
   112  				grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
   113  			}
   114  			return
   115  		}
   116  		go func() {
   117  			<-ctx.Done()
   118  			if cerr := conn.Close(); cerr != nil {
   119  				grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
   120  			}
   121  		}()
   122  	}()
   123  
   124  	return RegisterMetricsServiceHandler(ctx, mux, conn)
   125  }
   126  
   127  // RegisterMetricsServiceHandler registers the http handlers for service MetricsService to "mux".
   128  // The handlers forward requests to the grpc endpoint over "conn".
   129  func RegisterMetricsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
   130  	return RegisterMetricsServiceHandlerClient(ctx, mux, NewMetricsServiceClient(conn))
   131  }
   132  
   133  // RegisterMetricsServiceHandlerClient registers the http handlers for service MetricsService
   134  // to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MetricsServiceClient".
   135  // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MetricsServiceClient"
   136  // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
   137  // "MetricsServiceClient" to call the correct interceptors.
   138  func RegisterMetricsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MetricsServiceClient) error {
   139  
   140  	mux.Handle("POST", pattern_MetricsService_Export_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   141  		ctx, cancel := context.WithCancel(req.Context())
   142  		defer cancel()
   143  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   144  		var err error
   145  		var annotatedContext context.Context
   146  		annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/opentelemetry.proto.collector.metrics.v1.MetricsService/Export", runtime.WithHTTPPathPattern("/v1/metrics"))
   147  		if err != nil {
   148  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   149  			return
   150  		}
   151  		resp, md, err := request_MetricsService_Export_0(annotatedContext, inboundMarshaler, client, req, pathParams)
   152  		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
   153  		if err != nil {
   154  			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
   155  			return
   156  		}
   157  
   158  		forward_MetricsService_Export_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   159  
   160  	})
   161  
   162  	return nil
   163  }
   164  
   165  var (
   166  	pattern_MetricsService_Export_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "metrics"}, ""))
   167  )
   168  
   169  var (
   170  	forward_MetricsService_Export_0 = runtime.ForwardResponseMessage
   171  )
   172
View as plain text