tapv3

type StreamTapsRequest 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 *StreamTapsRequest_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// The trace id. this can be used to merge together a streaming trace. Note that the trace_id
	// is not guaranteed to be spatially or temporally unique.
	TraceId uint64 `protobuf:"varint,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// The trace data.
	Trace *v3.TraceWrapper `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"`
	// contains filtered or unexported fields
}

type StreamTapsRequest_Identifier struct {

	// The node sending taps over the stream.
	Node *v31.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// The opaque identifier that was set in the :ref:`output config
	// <envoy_v3_api_field_config.tap.v3.StreamingGrpcSink.tap_id>`.
	TapId string `protobuf:"bytes,2,opt,name=tap_id,json=tapId,proto3" json:"tap_id,omitempty"`
	// contains filtered or unexported fields
}

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

type TapSinkServiceClient interface {
	// Envoy will connect and send StreamTapsRequest messages forever. It does not expect any
	// response to be sent as nothing would be done in the case of failure. The server should
	// disconnect if it expects Envoy to reconnect.
	StreamTaps(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[StreamTapsRequest, StreamTapsResponse], error)
}

type TapSinkServiceServer interface {
	// Envoy will connect and send StreamTapsRequest messages forever. It does not expect any
	// response to be sent as nothing would be done in the case of failure. The server should
	// disconnect if it expects Envoy to reconnect.
	StreamTaps(grpc.ClientStreamingServer[StreamTapsRequest, StreamTapsResponse]) error
	// contains filtered or unexported methods
}

type TapSinkService_StreamTapsClient = grpc.ClientStreamingClient[StreamTapsRequest, StreamTapsResponse]

type TapSinkService_StreamTapsServer = grpc.ClientStreamingServer[StreamTapsRequest, StreamTapsResponse]

type UnimplementedTapSinkServiceServer struct{}

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