otlpgrpc

Documentation

Index

• func RegisterLogsServer(s *grpc.Server, srv LogsServer)
• func RegisterMetricsServer(s *grpc.Server, srv MetricsServer)
• func RegisterTracesServer(s *grpc.Server, srv TracesServer)
• type LogsClient
  • func NewLogsClient(cc *grpc.ClientConn) LogsClient
• type LogsResponse
  • func NewLogsResponse() LogsResponse
• type LogsServer
• type MetricsClient
  • func NewMetricsClient(cc *grpc.ClientConn) MetricsClient
• type MetricsResponse
  • func NewMetricsResponse() MetricsResponse
• type MetricsServer
• type TracesClient
  • func NewTracesClient(cc *grpc.ClientConn) TracesClient
• type TracesResponse
  • func NewTracesResponse() TracesResponse
• type TracesServer

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, in pdata.Logs, 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 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.

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, pdata.Logs) (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, in pdata.Metrics, 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 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.

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, pdata.Metrics) (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, in pdata.Traces, 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 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.

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, pdata.Traces) (TracesResponse, error)
}

TracesServer is the server API for OTLP gRPC TracesService service.