tapv3

Documentation

Index

• Variables
• type StreamTapsRequest
  • func (*StreamTapsRequest) Descriptor() ([]byte, []int)
  • func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier
  • func (x *StreamTapsRequest) GetTrace() *v3.TraceWrapper
  • func (x *StreamTapsRequest) GetTraceId() uint64
  • func (*StreamTapsRequest) ProtoMessage()
  • func (x *StreamTapsRequest) ProtoReflect() protoreflect.Message
  • func (x *StreamTapsRequest) Reset()
  • func (x *StreamTapsRequest) String() string
• type StreamTapsRequest_Identifier
  • func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int)
  • func (x *StreamTapsRequest_Identifier) GetNode() *v31.Node
  • func (x *StreamTapsRequest_Identifier) GetTapId() string
  • func (*StreamTapsRequest_Identifier) ProtoMessage()
  • func (x *StreamTapsRequest_Identifier) ProtoReflect() protoreflect.Message
  • func (x *StreamTapsRequest_Identifier) Reset()
  • func (x *StreamTapsRequest_Identifier) String() string
• type StreamTapsResponse
  • func (*StreamTapsResponse) Descriptor() ([]byte, []int)
  • func (*StreamTapsResponse) ProtoMessage()
  • func (x *StreamTapsResponse) ProtoReflect() protoreflect.Message
  • func (x *StreamTapsResponse) Reset()
  • func (x *StreamTapsResponse) String() string

Variables

var File_envoy_service_tap_v3_tap_proto protoreflect.FileDescriptor

Types

type StreamTapsRequest

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
}

[#not-implemented-hide:] Stream message for the Tap API. Envoy will open a stream to the server and stream taps without ever expecting a response.

func (*StreamTapsRequest) Descriptor

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

Deprecated: Use StreamTapsRequest.ProtoReflect.Descriptor instead.

func (*StreamTapsRequest) GetIdentifier

func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier

func (*StreamTapsRequest) GetTrace

func (x *StreamTapsRequest) GetTrace() *v3.TraceWrapper

func (*StreamTapsRequest) GetTraceId

func (x *StreamTapsRequest) GetTraceId() uint64

func (*StreamTapsRequest) ProtoMessage

func (*StreamTapsRequest) ProtoMessage()

func (*StreamTapsRequest) ProtoReflect

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

func (*StreamTapsRequest) Reset

func (x *StreamTapsRequest) Reset()

func (*StreamTapsRequest) String

func (x *StreamTapsRequest) String() string

type StreamTapsRequest_Identifier

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
}

func (*StreamTapsRequest_Identifier) Descriptor

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

Deprecated: Use StreamTapsRequest_Identifier.ProtoReflect.Descriptor instead.

func (*StreamTapsRequest_Identifier) GetNode

func (x *StreamTapsRequest_Identifier) GetNode() *v31.Node

func (*StreamTapsRequest_Identifier) GetTapId

func (x *StreamTapsRequest_Identifier) GetTapId() string

func (*StreamTapsRequest_Identifier) ProtoMessage

func (*StreamTapsRequest_Identifier) ProtoMessage()

func (*StreamTapsRequest_Identifier) ProtoReflect

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

func (*StreamTapsRequest_Identifier) Reset

func (x *StreamTapsRequest_Identifier) Reset()

func (*StreamTapsRequest_Identifier) String

func (x *StreamTapsRequest_Identifier) String() string

type StreamTapsResponse

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

[#not-implemented-hide:]

func (*StreamTapsResponse) Descriptor

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

Deprecated: Use StreamTapsResponse.ProtoReflect.Descriptor instead.

func (*StreamTapsResponse) ProtoMessage

func (*StreamTapsResponse) ProtoMessage()

func (*StreamTapsResponse) ProtoReflect

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

func (*StreamTapsResponse) Reset

func (x *StreamTapsResponse) Reset()

func (*StreamTapsResponse) String

func (x *StreamTapsResponse) String() string