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 (
    	ErrInvalidLengthLogsService        = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowLogsService          = fmt.Errorf("proto: integer overflow")
    	ErrUnexpectedEndOfGroupLogsService = fmt.Errorf("proto: unexpected end of group")
    )

    Functions

    func RegisterLogsServiceHandler

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

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

      func RegisterLogsServiceHandlerClient

      func RegisterLogsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LogsServiceClient) error

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

        func RegisterLogsServiceHandlerFromEndpoint

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

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

          func RegisterLogsServiceHandlerServer

          func RegisterLogsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LogsServiceServer) error

            RegisterLogsServiceHandlerServer registers the http handlers for service LogsService to "mux". UnaryRPC :call LogsServiceServer 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 RegisterLogsServiceHandlerFromEndpoint instead.

            func RegisterLogsServiceServer

            func RegisterLogsServiceServer(s *grpc.Server, srv LogsServiceServer)

            Types

            type ExportLogsServiceRequest

            type ExportLogsServiceRequest struct {
            	// An array of ResourceLogs.
            	// 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.
            	ResourceLogs []*v1.ResourceLogs `protobuf:"bytes,1,rep,name=resource_logs,json=resourceLogs,proto3" json:"resource_logs,omitempty"`
            }

            func (*ExportLogsServiceRequest) Descriptor

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

            func (*ExportLogsServiceRequest) GetResourceLogs

            func (m *ExportLogsServiceRequest) GetResourceLogs() []*v1.ResourceLogs

            func (*ExportLogsServiceRequest) Marshal

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

            func (*ExportLogsServiceRequest) MarshalTo

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

            func (*ExportLogsServiceRequest) MarshalToSizedBuffer

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

            func (*ExportLogsServiceRequest) ProtoMessage

            func (*ExportLogsServiceRequest) ProtoMessage()

            func (*ExportLogsServiceRequest) Reset

            func (m *ExportLogsServiceRequest) Reset()

            func (*ExportLogsServiceRequest) Size

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

            func (*ExportLogsServiceRequest) String

            func (m *ExportLogsServiceRequest) String() string

            func (*ExportLogsServiceRequest) Unmarshal

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

            func (*ExportLogsServiceRequest) XXX_DiscardUnknown

            func (m *ExportLogsServiceRequest) XXX_DiscardUnknown()

            func (*ExportLogsServiceRequest) XXX_Marshal

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

            func (*ExportLogsServiceRequest) XXX_Merge

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

            func (*ExportLogsServiceRequest) XXX_Size

            func (m *ExportLogsServiceRequest) XXX_Size() int

            func (*ExportLogsServiceRequest) XXX_Unmarshal

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

            type ExportLogsServiceResponse

            type ExportLogsServiceResponse struct {
            }

            func (*ExportLogsServiceResponse) Descriptor

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

            func (*ExportLogsServiceResponse) Marshal

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

            func (*ExportLogsServiceResponse) MarshalTo

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

            func (*ExportLogsServiceResponse) MarshalToSizedBuffer

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

            func (*ExportLogsServiceResponse) ProtoMessage

            func (*ExportLogsServiceResponse) ProtoMessage()

            func (*ExportLogsServiceResponse) Reset

            func (m *ExportLogsServiceResponse) Reset()

            func (*ExportLogsServiceResponse) Size

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

            func (*ExportLogsServiceResponse) String

            func (m *ExportLogsServiceResponse) String() string

            func (*ExportLogsServiceResponse) Unmarshal

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

            func (*ExportLogsServiceResponse) XXX_DiscardUnknown

            func (m *ExportLogsServiceResponse) XXX_DiscardUnknown()

            func (*ExportLogsServiceResponse) XXX_Marshal

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

            func (*ExportLogsServiceResponse) XXX_Merge

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

            func (*ExportLogsServiceResponse) XXX_Size

            func (m *ExportLogsServiceResponse) XXX_Size() int

            func (*ExportLogsServiceResponse) XXX_Unmarshal

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

            type LogsServiceClient

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

              LogsServiceClient is the client API for LogsService service.

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

              func NewLogsServiceClient

              func NewLogsServiceClient(cc *grpc.ClientConn) LogsServiceClient

              type LogsServiceServer

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

                LogsServiceServer is the server API for LogsService service.

                type UnimplementedLogsServiceServer

                type UnimplementedLogsServiceServer struct {
                }

                  UnimplementedLogsServiceServer can be embedded to have forward compatible implementations.

                  func (*UnimplementedLogsServiceServer) Export