Documentation

Overview

    Package v1 is a reverse proxy.

    It translates gRPC into RESTful JSON APIs.

    Index

    Constants

    This section is empty.

    Variables

    View Source
    var (
    	ErrInvalidLengthMetricsService        = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowMetricsService          = fmt.Errorf("proto: integer overflow")
    	ErrUnexpectedEndOfGroupMetricsService = fmt.Errorf("proto: unexpected end of group")
    )

    Functions

    func RegisterMetricsServiceHandler

    func RegisterMetricsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

      RegisterMetricsServiceHandler registers the http handlers for service MetricsService to "mux". The handlers forward requests to the grpc endpoint over "conn".

      func RegisterMetricsServiceHandlerClient

      func RegisterMetricsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MetricsServiceClient) error

        RegisterMetricsServiceHandlerClient registers the http handlers for service MetricsService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MetricsServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MetricsServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MetricsServiceClient" to call the correct interceptors.

        func RegisterMetricsServiceHandlerFromEndpoint

        func RegisterMetricsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

          RegisterMetricsServiceHandlerFromEndpoint is same as RegisterMetricsServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

          func RegisterMetricsServiceHandlerServer

          func RegisterMetricsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MetricsServiceServer) error

            RegisterMetricsServiceHandlerServer registers the http handlers for service MetricsService to "mux". UnaryRPC :call MetricsServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMetricsServiceHandlerFromEndpoint instead.

            func RegisterMetricsServiceServer

            func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)

            Types

            type ExportMetricsServiceRequest

            type ExportMetricsServiceRequest struct {
            	// An array of ResourceMetrics.
            	// For data coming from a single resource this array will typically contain one
            	// element. Intermediary nodes (such as OpenTelemetry Collector) that receive
            	// data from multiple origins typically batch the data before forwarding further and
            	// in that case this array will contain multiple elements.
            	ResourceMetrics []*v1.ResourceMetrics `protobuf:"bytes,1,rep,name=resource_metrics,json=resourceMetrics,proto3" json:"resource_metrics,omitempty"`
            }

            func (*ExportMetricsServiceRequest) Descriptor

            func (*ExportMetricsServiceRequest) Descriptor() ([]byte, []int)

            func (*ExportMetricsServiceRequest) GetResourceMetrics

            func (m *ExportMetricsServiceRequest) GetResourceMetrics() []*v1.ResourceMetrics

            func (*ExportMetricsServiceRequest) Marshal

            func (m *ExportMetricsServiceRequest) Marshal() (dAtA []byte, err error)

            func (*ExportMetricsServiceRequest) MarshalTo

            func (m *ExportMetricsServiceRequest) MarshalTo(dAtA []byte) (int, error)

            func (*ExportMetricsServiceRequest) MarshalToSizedBuffer

            func (m *ExportMetricsServiceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

            func (*ExportMetricsServiceRequest) ProtoMessage

            func (*ExportMetricsServiceRequest) ProtoMessage()

            func (*ExportMetricsServiceRequest) Reset

            func (m *ExportMetricsServiceRequest) Reset()

            func (*ExportMetricsServiceRequest) Size

            func (m *ExportMetricsServiceRequest) Size() (n int)

            func (*ExportMetricsServiceRequest) String

            func (m *ExportMetricsServiceRequest) String() string

            func (*ExportMetricsServiceRequest) Unmarshal

            func (m *ExportMetricsServiceRequest) Unmarshal(dAtA []byte) error

            func (*ExportMetricsServiceRequest) XXX_DiscardUnknown

            func (m *ExportMetricsServiceRequest) XXX_DiscardUnknown()

            func (*ExportMetricsServiceRequest) XXX_Marshal

            func (m *ExportMetricsServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

            func (*ExportMetricsServiceRequest) XXX_Merge

            func (m *ExportMetricsServiceRequest) XXX_Merge(src proto.Message)

            func (*ExportMetricsServiceRequest) XXX_Size

            func (m *ExportMetricsServiceRequest) XXX_Size() int

            func (*ExportMetricsServiceRequest) XXX_Unmarshal

            func (m *ExportMetricsServiceRequest) XXX_Unmarshal(b []byte) error

            type ExportMetricsServiceResponse

            type ExportMetricsServiceResponse struct {
            }

            func (*ExportMetricsServiceResponse) Descriptor

            func (*ExportMetricsServiceResponse) Descriptor() ([]byte, []int)

            func (*ExportMetricsServiceResponse) Marshal

            func (m *ExportMetricsServiceResponse) Marshal() (dAtA []byte, err error)

            func (*ExportMetricsServiceResponse) MarshalTo

            func (m *ExportMetricsServiceResponse) MarshalTo(dAtA []byte) (int, error)

            func (*ExportMetricsServiceResponse) MarshalToSizedBuffer

            func (m *ExportMetricsServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

            func (*ExportMetricsServiceResponse) ProtoMessage

            func (*ExportMetricsServiceResponse) ProtoMessage()

            func (*ExportMetricsServiceResponse) Reset

            func (m *ExportMetricsServiceResponse) Reset()

            func (*ExportMetricsServiceResponse) Size

            func (m *ExportMetricsServiceResponse) Size() (n int)

            func (*ExportMetricsServiceResponse) String

            func (*ExportMetricsServiceResponse) Unmarshal

            func (m *ExportMetricsServiceResponse) Unmarshal(dAtA []byte) error

            func (*ExportMetricsServiceResponse) XXX_DiscardUnknown

            func (m *ExportMetricsServiceResponse) XXX_DiscardUnknown()

            func (*ExportMetricsServiceResponse) XXX_Marshal

            func (m *ExportMetricsServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

            func (*ExportMetricsServiceResponse) XXX_Merge

            func (m *ExportMetricsServiceResponse) XXX_Merge(src proto.Message)

            func (*ExportMetricsServiceResponse) XXX_Size

            func (m *ExportMetricsServiceResponse) XXX_Size() int

            func (*ExportMetricsServiceResponse) XXX_Unmarshal

            func (m *ExportMetricsServiceResponse) XXX_Unmarshal(b []byte) error

            type MetricsServiceClient

            type MetricsServiceClient interface {
            	// For performance reasons, it is recommended to keep this RPC
            	// alive for the entire life of the application.
            	Export(ctx context.Context, in *ExportMetricsServiceRequest, opts ...grpc.CallOption) (*ExportMetricsServiceResponse, error)
            }

              MetricsServiceClient is the client API for MetricsService service.

              For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

              func NewMetricsServiceClient

              func NewMetricsServiceClient(cc *grpc.ClientConn) MetricsServiceClient

              type MetricsServiceServer

              type MetricsServiceServer interface {
              	// For performance reasons, it is recommended to keep this RPC
              	// alive for the entire life of the application.
              	Export(context.Context, *ExportMetricsServiceRequest) (*ExportMetricsServiceResponse, error)
              }

                MetricsServiceServer is the server API for MetricsService service.

                type UnimplementedMetricsServiceServer

                type UnimplementedMetricsServiceServer struct {
                }

                  UnimplementedMetricsServiceServer can be embedded to have forward compatible implementations.

                  func (*UnimplementedMetricsServiceServer) Export