otlpgrpc

package
v0.48.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 30, 2022 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InstrumentationLibraryLogsToScope added in v0.48.0 

func InstrumentationLibraryLogsToScope(rls []*otlplogs.ResourceLogs)

InstrumentationLibraryLogsToScope implements the translation of resource logs data following the v0.15.0 upgrade: 

receivers SHOULD check if instrumentation_library_logs is set
and scope_logs is not set then the value in instrumentation_library_logs
SHOULD be used instead by converting InstrumentationLibraryLogs into ScopeLogs.
If scope_logs is set then instrumentation_library_logs SHOULD be ignored.

https://github.com/open-telemetry/opentelemetry-proto/blob/3c2915c01a9fb37abfc0415ec71247c4978386b0/opentelemetry/proto/logs/v1/logs.proto#L58

func InstrumentationLibraryMetricsToScope added in v0.48.0 

func InstrumentationLibraryMetricsToScope(rms []*otlpmetrics.ResourceMetrics)

InstrumentationLibraryMetricsToScope implements the translation of resource metrics data following the v0.15.0 upgrade: 

receivers SHOULD check if instrumentation_library_metrics is set
and scope_metrics is not set then the value in instrumentation_library_metrics
SHOULD be used instead by converting InstrumentationLibraryMetrics into ScopeMetrics.
If scope_metrics is set then instrumentation_library_metrics SHOULD be ignored.

https://github.com/open-telemetry/opentelemetry-proto/blob/3c2915c01a9fb37abfc0415ec71247c4978386b0/opentelemetry/proto/metrics/v1/metrics.proto#L58

func InstrumentationLibrarySpansToScope added in v0.48.0 

func InstrumentationLibrarySpansToScope(rss []*otlptrace.ResourceSpans)

InstrumentationLibraryToScope implements the translation of resource span data following the v0.15.0 upgrade: 

receivers SHOULD check if instrumentation_library_spans is set
and scope_spans is not set then the value in instrumentation_library_spans
SHOULD be used instead by converting InstrumentationLibrarySpans into ScopeSpans.
If scope_spans is set then instrumentation_library_spans SHOULD be ignored.

https://github.com/open-telemetry/opentelemetry-proto/blob/3c2915c01a9fb37abfc0415ec71247c4978386b0/opentelemetry/proto/trace/v1/trace.proto#L58

func RegisterLogsServer 

func RegisterLogsServer(s *grpc.Server, srv LogsServer)

RegisterLogsServer registers the LogsServer to the grpc.Server.

func RegisterMetricsServer 

func RegisterMetricsServer(s *grpc.Server, srv MetricsServer)

RegisterMetricsServer registers the MetricsServer to the grpc.Server.

func RegisterTracesServer 

func RegisterTracesServer(s *grpc.Server, srv TracesServer)

RegisterTracesServer registers the TracesServer to the grpc.Server.

Types

type LogsClient 

type LogsClient interface {
	// Export pdata.Logs 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 LogsRequest, opts ...grpc.CallOption) (LogsResponse, error)
}

LogsClient is the client API for OTLP-GRPC Logs service.

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

func NewLogsClient 

func NewLogsClient(cc *grpc.ClientConn) LogsClient

NewLogsClient returns a new LogsClient connected using the given connection.

type LogsRequest added in v0.36.0 

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

LogsRequest represents the response for gRPC client/server.

func NewLogsRequest added in v0.36.0 

func NewLogsRequest() LogsRequest

NewLogsRequest returns an empty LogsRequest.

func UnmarshalJSONLogsRequest deprecated added in v0.38.0 

func UnmarshalJSONLogsRequest(data []byte) (LogsRequest, error)

Deprecated: [v0.48.0] use LogsRequest.UnmarshalJSON.

func UnmarshalLogsRequest deprecated added in v0.38.0 

func UnmarshalLogsRequest(data []byte) (LogsRequest, error)

Deprecated: [v0.48.0] use LogsRequest.UnmarshalProto.

func (LogsRequest) Logs added in v0.36.0 

func (lr LogsRequest) Logs() pdata.Logs

func (LogsRequest) Marshal deprecated added in v0.37.0 

func (lr LogsRequest) Marshal() ([]byte, error)

Deprecated: [v0.48.0] use MarshalProto.

func (LogsRequest) MarshalJSON added in v0.37.0 

func (lr LogsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals LogsRequest into JSON bytes.

func (LogsRequest) MarshalProto added in v0.48.0 

func (lr LogsRequest) MarshalProto() ([]byte, error)

MarshalProto marshals LogsRequest into proto bytes.

func (LogsRequest) SetLogs added in v0.36.0 

func (lr LogsRequest) SetLogs(ld pdata.Logs)

func (LogsRequest) UnmarshalJSON added in v0.48.0 

func (lr LogsRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls LogsRequest from JSON bytes.

func (LogsRequest) UnmarshalProto added in v0.48.0 

func (lr LogsRequest) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls LogsRequest from proto bytes.

type LogsResponse 

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

LogsResponse represents the response for gRPC client/server.

func NewLogsResponse 

func NewLogsResponse() LogsResponse

NewLogsResponse returns an empty LogsResponse.

func UnmarshalJSONLogsResponse deprecated added in v0.38.0 

func UnmarshalJSONLogsResponse(data []byte) (LogsResponse, error)

Deprecated: [v0.48.0] use LogsResponse.UnmarshalJSON.

func UnmarshalLogsResponse deprecated added in v0.38.0 

func UnmarshalLogsResponse(data []byte) (LogsResponse, error)

Deprecated: [v0.48.0] use LogsResponse.UnmarshalProto.

func (LogsResponse) Marshal deprecated added in v0.37.0 

func (lr LogsResponse) Marshal() ([]byte, error)

Deprecated: [v0.48.0] use MarshalProto.

func (LogsResponse) MarshalJSON added in v0.37.0 

func (lr LogsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals LogsResponse into JSON bytes.

func (LogsResponse) MarshalProto added in v0.48.0 

func (lr LogsResponse) MarshalProto() ([]byte, error)

MarshalProto marshals LogsResponse into proto bytes.

func (LogsResponse) UnmarshalJSON added in v0.48.0 

func (lr LogsResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls LogsResponse from JSON bytes.

func (LogsResponse) UnmarshalProto added in v0.48.0 

func (lr LogsResponse) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls LogsResponse from proto bytes.

type LogsServer 

type LogsServer 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, LogsRequest) (LogsResponse, error)
}

LogsServer is the server API for OTLP gRPC LogsService service.

type MetricsClient 

type MetricsClient interface {
	// Export pdata.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 MetricsRequest, opts ...grpc.CallOption) (MetricsResponse, error)
}

MetricsClient 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 NewMetricsClient 

func NewMetricsClient(cc *grpc.ClientConn) MetricsClient

NewMetricsClient returns a new MetricsClient connected using the given connection.

type MetricsRequest added in v0.36.0 

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

MetricsRequest represents the response for gRPC client/server.

func NewMetricsRequest added in v0.36.0 

func NewMetricsRequest() MetricsRequest

NewMetricsRequest returns an empty MetricsRequest.

func UnmarshalJSONMetricsRequest deprecated added in v0.38.0 

func UnmarshalJSONMetricsRequest(data []byte) (MetricsRequest, error)

Deprecated: [v0.48.0] use MetricsRequest.UnmarshalJSON.

func UnmarshalMetricsRequest deprecated added in v0.38.0 

func UnmarshalMetricsRequest(data []byte) (MetricsRequest, error)

Deprecated: [v0.48.0] use MetricsRequest.UnmarshalProto.

func (MetricsRequest) Marshal deprecated added in v0.37.0 

func (mr MetricsRequest) Marshal() ([]byte, error)

Deprecated: [v0.48.0] use MarshalProto.

func (MetricsRequest) MarshalJSON added in v0.37.0 

func (mr MetricsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals MetricsRequest into JSON bytes.

func (MetricsRequest) MarshalProto added in v0.48.0 

func (mr MetricsRequest) MarshalProto() ([]byte, error)

MarshalProto marshals MetricsRequest into proto bytes.

func (MetricsRequest) Metrics added in v0.36.0 

func (mr MetricsRequest) Metrics() pdata.Metrics

func (MetricsRequest) SetMetrics added in v0.36.0 

func (mr MetricsRequest) SetMetrics(ld pdata.Metrics)

func (MetricsRequest) UnmarshalJSON added in v0.48.0 

func (mr MetricsRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls MetricsRequest from JSON bytes.

func (MetricsRequest) UnmarshalProto added in v0.48.0 

func (mr MetricsRequest) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls MetricsRequest from proto bytes.

type MetricsResponse 

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

MetricsResponse represents the response for gRPC client/server.

func NewMetricsResponse 

func NewMetricsResponse() MetricsResponse

NewMetricsResponse returns an empty MetricsResponse.

func UnmarshalJSONMetricsResponse deprecated added in v0.38.0 

func UnmarshalJSONMetricsResponse(data []byte) (MetricsResponse, error)

Deprecated: [v0.48.0] use MetricsResponse.UnmarshalJSON.

func UnmarshalMetricsResponse deprecated added in v0.38.0 

func UnmarshalMetricsResponse(data []byte) (MetricsResponse, error)

Deprecated: [v0.48.0] use MetricsResponse.UnmarshalProto.

func (MetricsResponse) Marshal deprecated added in v0.37.0 

func (mr MetricsResponse) Marshal() ([]byte, error)

Deprecated: [v0.48.0] use MarshalProto.

func (MetricsResponse) MarshalJSON added in v0.37.0 

func (mr MetricsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals MetricsResponse into JSON bytes.

func (MetricsResponse) MarshalProto added in v0.48.0 

func (mr MetricsResponse) MarshalProto() ([]byte, error)

MarshalProto marshals MetricsResponse into proto bytes.

func (MetricsResponse) UnmarshalJSON added in v0.48.0 

func (mr MetricsResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls MetricsResponse from JSON bytes.

func (MetricsResponse) UnmarshalProto added in v0.48.0 

func (mr MetricsResponse) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls MetricsResponse from proto bytes.

type MetricsServer 

type MetricsServer 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, MetricsRequest) (MetricsResponse, error)
}

MetricsServer is the server API for OTLP gRPC MetricsService service.

type TracesClient 

type TracesClient interface {
	// Export pdata.Traces 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 TracesRequest, opts ...grpc.CallOption) (TracesResponse, error)
}

TracesClient is the client API for OTLP-GRPC Traces service.

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

func NewTracesClient 

func NewTracesClient(cc *grpc.ClientConn) TracesClient

NewTracesClient returns a new TracesClient connected using the given connection.

type TracesRequest added in v0.36.0 

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

TracesRequest represents the response for gRPC client/server.

func NewTracesRequest added in v0.36.0 

func NewTracesRequest() TracesRequest

NewTracesRequest returns an empty TracesRequest.

func UnmarshalJSONTracesRequest deprecated added in v0.38.0 

func UnmarshalJSONTracesRequest(data []byte) (TracesRequest, error)

Deprecated: [v0.48.0] use TracesRequest.UnmarshalJSON.

func UnmarshalTracesRequest deprecated added in v0.38.0 

func UnmarshalTracesRequest(data []byte) (TracesRequest, error)

Deprecated: [v0.48.0] use TracesRequest.UnmarshalProto.

func (TracesRequest) Marshal deprecated added in v0.37.0 

func (tr TracesRequest) Marshal() ([]byte, error)

Deprecated: [v0.48.0] use MarshalProto.

func (TracesRequest) MarshalJSON added in v0.37.0 

func (tr TracesRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals TracesRequest into JSON bytes.

func (TracesRequest) MarshalProto added in v0.48.0 

func (tr TracesRequest) MarshalProto() ([]byte, error)

MarshalProto marshals TracesRequest into proto bytes.

func (TracesRequest) SetTraces added in v0.36.0 

func (tr TracesRequest) SetTraces(td pdata.Traces)

func (TracesRequest) Traces added in v0.36.0 

func (tr TracesRequest) Traces() pdata.Traces

func (TracesRequest) UnmarshalJSON added in v0.48.0 

func (tr TracesRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls TracesRequest from JSON bytes.

func (TracesRequest) UnmarshalProto added in v0.48.0 

func (tr TracesRequest) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls TracesRequest from proto bytes.

type TracesResponse 

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

TracesResponse represents the response for gRPC client/server.

func NewTracesResponse 

func NewTracesResponse() TracesResponse

NewTracesResponse returns an empty TracesResponse.

func UnmarshalJSONTracesResponse deprecated added in v0.38.0 

func UnmarshalJSONTracesResponse(data []byte) (TracesResponse, error)

Deprecated: [v0.48.0] use TracesResponse.UnmarshalJSON.

func UnmarshalTracesResponse deprecated added in v0.38.0 

func UnmarshalTracesResponse(data []byte) (TracesResponse, error)

Deprecated: [v0.48.0] use TracesResponse.UnmarshalProto.

func (TracesResponse) Marshal deprecated added in v0.37.0 

func (tr TracesResponse) Marshal() ([]byte, error)

Deprecated: [v0.48.0] use MarshalProto.

func (TracesResponse) MarshalJSON added in v0.37.0 

func (tr TracesResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals TracesResponse into JSON bytes.

func (TracesResponse) MarshalProto added in v0.48.0 

func (tr TracesResponse) MarshalProto() ([]byte, error)

MarshalProto marshals TracesResponse into proto bytes.

func (TracesResponse) UnmarshalJSON added in v0.48.0 

func (tr TracesResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls TracesResponse from JSON bytes.

func (TracesResponse) UnmarshalProto added in v0.48.0 

func (tr TracesResponse) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls TracesResponse from proto bytes.

type TracesServer 

type TracesServer 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, TracesRequest) (TracesResponse, error)
}

TracesServer is the server API for OTLP gRPC TracesService service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.