tracev2

type StreamTracesMessage ¶

type StreamTracesMessage struct {

	// Identifier data effectively is a structured metadata.
	// As a performance optimization this will only be sent in the first message
	// on the stream.
	Identifier *StreamTracesMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// A list of Span entries
	Spans []*v1.Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTracesMessage) Descriptor() ([]byte, []int)

func (x *StreamTracesMessage) GetIdentifier() *StreamTracesMessage_Identifier

func (x *StreamTracesMessage) GetSpans() []*v1.Span

func (*StreamTracesMessage) ProtoMessage()

func (x *StreamTracesMessage) ProtoReflect() protoreflect.Message

func (x *StreamTracesMessage) Reset()

func (x *StreamTracesMessage) String() string

type StreamTracesMessage_Identifier ¶

type StreamTracesMessage_Identifier struct {

	// The node sending the access log messages over the stream.
	Node *core.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTracesMessage_Identifier) Descriptor() ([]byte, []int)

func (x *StreamTracesMessage_Identifier) GetNode() *core.Node

func (*StreamTracesMessage_Identifier) ProtoMessage()

func (x *StreamTracesMessage_Identifier) ProtoReflect() protoreflect.Message

func (x *StreamTracesMessage_Identifier) Reset()

func (x *StreamTracesMessage_Identifier) String() string

type StreamTracesResponse ¶

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

func (*StreamTracesResponse) Descriptor() ([]byte, []int)

func (*StreamTracesResponse) ProtoMessage()

func (x *StreamTracesResponse) ProtoReflect() protoreflect.Message

func (x *StreamTracesResponse) Reset()

func (x *StreamTracesResponse) String() string

type TraceServiceClient ¶

type TraceServiceClient interface {
	// Envoy will connect and send StreamTracesMessage messages forever. It does
	// not expect any response to be sent as nothing would be done in the case
	// of failure.
	StreamTraces(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[StreamTracesMessage, StreamTracesResponse], error)
}

TraceServiceClient is the client API for TraceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

Service for streaming traces to server that consumes the trace data. It uses OpenCensus data model as a standard to represent trace information.

func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient

type TraceServiceServer ¶

type TraceServiceServer interface {
	// Envoy will connect and send StreamTracesMessage messages forever. It does
	// not expect any response to be sent as nothing would be done in the case
	// of failure.
	StreamTraces(grpc.ClientStreamingServer[StreamTracesMessage, StreamTracesResponse]) error
	// contains filtered or unexported methods
}

TraceServiceServer is the server API for TraceService service. All implementations must embed UnimplementedTraceServiceServer for forward compatibility.

Service for streaming traces to server that consumes the trace data. It uses OpenCensus data model as a standard to represent trace information.

type TraceService_StreamTracesClient ¶

type TraceService_StreamTracesClient = grpc.ClientStreamingClient[StreamTracesMessage, StreamTracesResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TraceService_StreamTracesServer ¶

type TraceService_StreamTracesServer = grpc.ClientStreamingServer[StreamTracesMessage, StreamTracesResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedTraceServiceServer ¶

type UnimplementedTraceServiceServer struct{}

UnimplementedTraceServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTraceServiceServer) StreamTraces(grpc.ClientStreamingServer[StreamTracesMessage, StreamTracesResponse]) error

type UnsafeTraceServiceServer ¶

type UnsafeTraceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTraceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TraceServiceServer will result in compilation errors.