ptraceotlp

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) IsNil() bool
  • 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
  • func NewExportRequest() ExportRequest
  • func NewExportRequestFromTraces(td ptrace.Traces) ExportRequest
  • func (ms ExportRequest) MarshalJSON() ([]byte, error)
  • func (ms ExportRequest) MarshalProto(buf *bytes.Buffer) error
  • func (ms ExportRequest) ReturnToPool()
  • func (ms ExportRequest) Traces() ptrace.Traces
  • func (ms ExportRequest) UnmarshalJSON(data []byte) error
  • func (ms ExportRequest) UnmarshalProto(data []byte) error
  • func (ms ExportRequest) UnmarshalProtoUnsafe(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) IsNil

func (ms ExportPartialSuccess) IsNil() bool

IsNil returns whether the struct is nil value.

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(buf *bytes.Buffer) error

MarshalProto marshals ExportRequest into proto bytes.

func (ExportRequest) ReturnToPool

func (ms ExportRequest) ReturnToPool()

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.

func (ExportRequest) UnmarshalProtoUnsafe

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

UnmarshalProtoUnsafe 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)