Documentation
¶
Index ¶
- func RegisterGRPCServer(s *grpc.Server, srv GRPCServer)
- type ExportPartialSuccess
- func (ms ExportPartialSuccess) CopyTo(dest ExportPartialSuccess)
- func (ms ExportPartialSuccess) ErrorMessage() string
- func (ms ExportPartialSuccess) MoveTo(dest ExportPartialSuccess)
- func (ms ExportPartialSuccess) RejectedSpans() int64
- func (ms ExportPartialSuccess) SetErrorMessage(v string)
- func (ms ExportPartialSuccess) SetRejectedSpans(v int64)
- type ExportRequest
- type ExportResponse
- type GRPCClient
- type GRPCServer
- type UnimplementedGRPCServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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) RejectedSpans ¶
func (ms ExportPartialSuccess) RejectedSpans() int64
RejectedSpans returns the rejectedspans associated with this ExportPartialSuccess.
func (ExportPartialSuccess) SetErrorMessage ¶
func (ms ExportPartialSuccess) SetErrorMessage(v string)
SetErrorMessage replaces the errormessage associated with this ExportPartialSuccess.
func (ExportPartialSuccess) SetRejectedSpans ¶
func (ms ExportPartialSuccess) SetRejectedSpans(v int64)
SetRejectedSpans replaces the rejectedspans 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 ptrace.Traces data.
func NewExportRequest ¶
func NewExportRequest() ExportRequest
NewExportRequest returns an empty ExportRequest.
func NewExportRequestFromTraces ¶
func NewExportRequestFromTraces(td ptrace.Traces) ExportRequest
NewExportRequestFromTraces returns a ExportRequest from ptrace.Traces. Because ExportRequest is a wrapper for ptrace.Traces, any changes to the provided Traces 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) Traces ¶
func (ms ExportRequest) Traces() ptrace.Traces
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 ptrace.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 ExportRequest, opts ...grpc.CallOption) (ExportResponse, error)
// contains filtered or unexported methods
}
GRPCClient 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 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 TracesService 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)
Source Files