pmetricotlp

Documentation

Index

• func RegisterGRPCServer(s *grpc.Server, srv GRPCServer)
• type ExportPartialSuccess
  • func NewExportPartialSuccess() ExportPartialSuccess
  • func (ms ExportPartialSuccess) CopyTo(dest ExportPartialSuccess)
  • func (ms ExportPartialSuccess) ErrorMessage() string
  • func (ms ExportPartialSuccess) MoveTo(dest ExportPartialSuccess)
  • func (ms ExportPartialSuccess) RejectedDataPoints() int64
  • func (ms ExportPartialSuccess) SetErrorMessage(v string)
  • func (ms ExportPartialSuccess) SetRejectedDataPoints(v int64)
• type ExportRequest
  • func NewExportRequest() ExportRequest
  • func NewExportRequestFromMetrics(md pmetric.Metrics) ExportRequest
  • func (ms ExportRequest) MarshalJSON() ([]byte, error)
  • func (ms ExportRequest) MarshalProto() ([]byte, error)
  • func (ms ExportRequest) Metrics() pmetric.Metrics
  • func (ms ExportRequest) UnmarshalJSON(data []byte) error
  • func (ms ExportRequest) UnmarshalProto(data []byte) error
• type ExportResponse
  • func NewExportResponse() ExportResponse
  • func (ms ExportResponse) MarshalJSON() ([]byte, error)
  • func (ms ExportResponse) MarshalProto() ([]byte, error)
  • func (ms ExportResponse) PartialSuccess() ExportPartialSuccess
  • func (ms ExportResponse) UnmarshalJSON(data []byte) error
  • func (ms ExportResponse) UnmarshalProto(data []byte) error
• type GRPCClient
  • func NewGRPCClient(cc *grpc.ClientConn) GRPCClient
• type GRPCServer
• type UnimplementedGRPCServer
  • func (*UnimplementedGRPCServer) Export(context.Context, ExportRequest) (ExportResponse, error)

Functions

func RegisterGRPCServer

func RegisterGRPCServer(s *grpc.Server, srv GRPCServer)

RegisterGRPCServer registers the GRPCServer to the grpc.Server.

Types

type ExportPartialSuccess

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

ExportPartialSuccess represents the details of a partially successful export request.

This is a reference type, if passed by value and callee modifies it the caller will see the modification.

Must use NewExportPartialSuccess function to create new instances. Important: zero-initialized instance is not valid for use.

func NewExportPartialSuccess

func NewExportPartialSuccess() ExportPartialSuccess

NewExportPartialSuccess creates a new empty ExportPartialSuccess.

This must be used only in testing code. Users should use "AppendEmpty" when part of a Slice, OR directly access the member if this is embedded in another struct.

func (ExportPartialSuccess) CopyTo

func (ms ExportPartialSuccess) CopyTo(dest ExportPartialSuccess)

CopyTo copies all properties from the current struct overriding the destination.

func (ExportPartialSuccess) ErrorMessage

func (ms ExportPartialSuccess) ErrorMessage() string

ErrorMessage returns the errormessage associated with this ExportPartialSuccess.

func (ExportPartialSuccess) MoveTo

func (ms ExportPartialSuccess) MoveTo(dest ExportPartialSuccess)

MoveTo moves all properties from the current struct overriding the destination and resetting the current instance to its zero value

func (ExportPartialSuccess) RejectedDataPoints

func (ms ExportPartialSuccess) RejectedDataPoints() int64

RejectedDataPoints returns the rejecteddatapoints associated with this ExportPartialSuccess.

func (ExportPartialSuccess) SetErrorMessage

func (ms ExportPartialSuccess) SetErrorMessage(v string)

SetErrorMessage replaces the errormessage associated with this ExportPartialSuccess.

func (ExportPartialSuccess) SetRejectedDataPoints

func (ms ExportPartialSuccess) SetRejectedDataPoints(v int64)

SetRejectedDataPoints replaces the rejecteddatapoints associated with this ExportPartialSuccess.

type ExportRequest

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

ExportRequest represents the request for gRPC/HTTP client/server. It's a wrapper for pmetric.Metrics data.

func NewExportRequest

func NewExportRequest() ExportRequest

NewExportRequest returns an empty ExportRequest.

func NewExportRequestFromMetrics

func NewExportRequestFromMetrics(md pmetric.Metrics) ExportRequest

NewExportRequestFromMetrics returns a ExportRequest from pmetric.Metrics. Because ExportRequest is a wrapper for pmetric.Metrics, any changes to the provided Metrics struct will be reflected in the ExportRequest and vice versa.

func (ExportRequest) MarshalJSON

func (ms ExportRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals ExportRequest into JSON bytes.

func (ExportRequest) MarshalProto

func (ms ExportRequest) MarshalProto() ([]byte, error)

MarshalProto marshals ExportRequest into proto bytes.

func (ExportRequest) Metrics

func (ms ExportRequest) Metrics() pmetric.Metrics

func (ExportRequest) UnmarshalJSON

func (ms ExportRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls ExportRequest from JSON bytes.

func (ExportRequest) UnmarshalProto

func (ms ExportRequest) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls ExportRequest from proto bytes.

type ExportResponse

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

ExportResponse represents the response for gRPC/HTTP client/server.

func NewExportResponse

func NewExportResponse() ExportResponse

NewExportResponse returns an empty ExportResponse.

func (ExportResponse) MarshalJSON

func (ms ExportResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals ExportResponse into JSON bytes.

func (ExportResponse) MarshalProto

func (ms ExportResponse) MarshalProto() ([]byte, error)

MarshalProto marshals ExportResponse into proto bytes.

func (ExportResponse) PartialSuccess

func (ms ExportResponse) PartialSuccess() ExportPartialSuccess

PartialSuccess returns the ExportLogsPartialSuccess associated with this ExportResponse.

func (ExportResponse) UnmarshalJSON

func (ms ExportResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls ExportResponse from JSON bytes.

func (ExportResponse) UnmarshalProto

func (ms ExportResponse) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls ExportResponse from proto bytes.

type GRPCClient

type GRPCClient interface {
	// Export pmetric.Metrics to the server.
	//
	// For performance reasons, it is recommended to keep this RPC
	// alive for the entire life of the application.
	Export(ctx context.Context, request ExportRequest, opts ...grpc.CallOption) (ExportResponse, error)
	// contains filtered or unexported methods
}

GRPCClient is the client API for OTLP-GRPC Metrics service.

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

func NewGRPCClient

func NewGRPCClient(cc *grpc.ClientConn) GRPCClient

NewGRPCClient returns a new GRPCClient connected using the given connection.

type GRPCServer

type GRPCServer interface {
	// Export is called every time a new request is received.
	//
	// For performance reasons, it is recommended to keep this RPC
	// alive for the entire life of the application.
	Export(context.Context, ExportRequest) (ExportResponse, error)
	// contains filtered or unexported methods
}

GRPCServer is the server API for OTLP gRPC MetricsService service. Implementations MUST embed UnimplementedGRPCServer.

type UnimplementedGRPCServer

type UnimplementedGRPCServer struct{}

UnimplementedGRPCServer MUST be embedded to have forward compatible implementations.

func (*UnimplementedGRPCServer) Export

func (*UnimplementedGRPCServer) Export(context.Context, ExportRequest) (ExportResponse, error)