otlpgrpc

package
v0.37.0 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2021 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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 (LogsRequest) Logs added in v0.36.0 

func (lr LogsRequest) Logs() pdata.Logs

func (LogsRequest) Marshal added in v0.37.0 

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

Marshal marshals LogsRequest into proto bytes.

func (LogsRequest) MarshalJSON added in v0.37.0 

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

MarshalJSON marshals LogsRequest into JSON bytes.

func (LogsRequest) SetLogs added in v0.36.0 

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

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 (LogsResponse) Marshal added in v0.37.0 

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

Marshal marshals LogsResponse into proto bytes.

func (LogsResponse) MarshalJSON added in v0.37.0 

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

MarshalJSON marshals LogsResponse into JSON 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 (MetricsRequest) Marshal added in v0.37.0 

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

Marshal marshals MetricsRequest into proto bytes.

func (MetricsRequest) MarshalJSON added in v0.37.0 

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

MarshalJSON marshals LogsRequest into JSON 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)

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 (MetricsResponse) Marshal added in v0.37.0 

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

Marshal marshals MetricsResponse into proto bytes.

func (MetricsResponse) MarshalJSON added in v0.37.0 

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

MarshalJSON marshals MetricsResponse into JSON 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 (TracesRequest) Marshal added in v0.37.0 

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

Marshal marshals TracesRequest into proto bytes.

func (TracesRequest) MarshalJSON added in v0.37.0 

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

MarshalJSON marshals TracesRequest into JSON 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

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 (TracesResponse) Marshal added in v0.37.0 

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

Marshal marshals TracesResponse into proto bytes.

func (TracesResponse) MarshalJSON added in v0.37.0 

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

MarshalJSON marshals TracesResponse into JSON 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.