tapv3

Documentation

Index

• Variables
• type StreamTapsRequest
  • func (x *StreamTapsRequest) ClearIdentifier()
  • func (x *StreamTapsRequest) ClearTrace()
  • func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier
  • func (x *StreamTapsRequest) GetTrace() *v3.TraceWrapper
  • func (x *StreamTapsRequest) GetTraceId() uint64
  • func (x *StreamTapsRequest) HasIdentifier() bool
  • func (x *StreamTapsRequest) HasTrace() bool
  • func (*StreamTapsRequest) ProtoMessage()
  • func (x *StreamTapsRequest) ProtoReflect() protoreflect.Message
  • func (x *StreamTapsRequest) Reset()
  • func (x *StreamTapsRequest) SetIdentifier(v *StreamTapsRequest_Identifier)
  • func (x *StreamTapsRequest) SetTrace(v *v3.TraceWrapper)
  • func (x *StreamTapsRequest) SetTraceId(v uint64)
  • func (x *StreamTapsRequest) String() string
• type StreamTapsRequest_Identifier
  • func (x *StreamTapsRequest_Identifier) ClearNode()
  • func (x *StreamTapsRequest_Identifier) GetNode() *v31.Node
  • func (x *StreamTapsRequest_Identifier) GetTapId() string
  • func (x *StreamTapsRequest_Identifier) HasNode() bool
  • func (*StreamTapsRequest_Identifier) ProtoMessage()
  • func (x *StreamTapsRequest_Identifier) ProtoReflect() protoreflect.Message
  • func (x *StreamTapsRequest_Identifier) Reset()
  • func (x *StreamTapsRequest_Identifier) SetNode(v *v31.Node)
  • func (x *StreamTapsRequest_Identifier) SetTapId(v string)
  • func (x *StreamTapsRequest_Identifier) String() string
• type StreamTapsRequest_Identifier_builder
  • func (b0 StreamTapsRequest_Identifier_builder) Build() *StreamTapsRequest_Identifier
• type StreamTapsRequest_builder
  • func (b0 StreamTapsRequest_builder) Build() *StreamTapsRequest
• type StreamTapsResponse
  • func (*StreamTapsResponse) ProtoMessage()
  • func (x *StreamTapsResponse) ProtoReflect() protoreflect.Message
  • func (x *StreamTapsResponse) Reset()
  • func (x *StreamTapsResponse) String() string
• type StreamTapsResponse_builder
  • func (b0 StreamTapsResponse_builder) Build() *StreamTapsResponse

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

func (x *StreamTapsRequest) ClearIdentifier()

func (*StreamTapsRequest) ClearTrace

func (x *StreamTapsRequest) ClearTrace()

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

func (x *StreamTapsRequest) HasIdentifier() bool

func (*StreamTapsRequest) HasTrace

func (x *StreamTapsRequest) HasTrace() bool

func (*StreamTapsRequest) ProtoMessage

func (*StreamTapsRequest) ProtoMessage()

func (*StreamTapsRequest) ProtoReflect

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

func (*StreamTapsRequest) Reset

func (x *StreamTapsRequest) Reset()

func (*StreamTapsRequest) SetIdentifier

func (x *StreamTapsRequest) SetIdentifier(v *StreamTapsRequest_Identifier)

func (*StreamTapsRequest) SetTrace

func (x *StreamTapsRequest) SetTrace(v *v3.TraceWrapper)

func (*StreamTapsRequest) SetTraceId

func (x *StreamTapsRequest) SetTraceId(v uint64)

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

func (x *StreamTapsRequest_Identifier) ClearNode()

func (*StreamTapsRequest_Identifier) GetNode

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

func (*StreamTapsRequest_Identifier) GetTapId

func (x *StreamTapsRequest_Identifier) GetTapId() string

func (*StreamTapsRequest_Identifier) HasNode

func (x *StreamTapsRequest_Identifier) HasNode() bool

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

func (x *StreamTapsRequest_Identifier) SetNode(v *v31.Node)

func (*StreamTapsRequest_Identifier) SetTapId

func (x *StreamTapsRequest_Identifier) SetTapId(v string)

func (*StreamTapsRequest_Identifier) String

func (x *StreamTapsRequest_Identifier) String() string

type StreamTapsRequest_Identifier_builder

type StreamTapsRequest_Identifier_builder struct {

	// The node sending taps over the stream.
	Node *v31.Node
	// The opaque identifier that was set in the :ref:`output config
	// <envoy_v3_api_field_config.tap.v3.StreamingGrpcSink.tap_id>`.
	TapId string
	// contains filtered or unexported fields
}

func (StreamTapsRequest_Identifier_builder) Build

func (b0 StreamTapsRequest_Identifier_builder) Build() *StreamTapsRequest_Identifier

type StreamTapsRequest_builder

type StreamTapsRequest_builder 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
	// 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
	// The trace data.
	Trace *v3.TraceWrapper
	// contains filtered or unexported fields
}

func (StreamTapsRequest_builder) Build

func (b0 StreamTapsRequest_builder) Build() *StreamTapsRequest

type StreamTapsResponse

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

[#not-implemented-hide:]

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

type StreamTapsResponse_builder

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

func (StreamTapsResponse_builder) Build

func (b0 StreamTapsResponse_builder) Build() *StreamTapsResponse