Documentation ¶
Index ¶
- Variables
- type Body
- func (*Body) Descriptor() ([]byte, []int)deprecated
- func (x *Body) GetAsBytes() []byte
- func (x *Body) GetAsString() string
- func (m *Body) GetBodyType() isBody_BodyType
- func (x *Body) GetTruncated() bool
- func (*Body) ProtoMessage()
- func (x *Body) ProtoReflect() protoreflect.Message
- func (x *Body) Reset()
- func (x *Body) String() string
- type Body_AsBytes
- type Body_AsString
- type Connection
- func (*Connection) Descriptor() ([]byte, []int)deprecated
- func (x *Connection) GetLocalAddress() *v3.Address
- func (x *Connection) GetRemoteAddress() *v3.Address
- func (*Connection) ProtoMessage()
- func (x *Connection) ProtoReflect() protoreflect.Message
- func (x *Connection) Reset()
- func (x *Connection) String() string
- type HttpBufferedTrace
- func (*HttpBufferedTrace) Descriptor() ([]byte, []int)deprecated
- func (x *HttpBufferedTrace) GetRequest() *HttpBufferedTrace_Message
- func (x *HttpBufferedTrace) GetResponse() *HttpBufferedTrace_Message
- func (*HttpBufferedTrace) ProtoMessage()
- func (x *HttpBufferedTrace) ProtoReflect() protoreflect.Message
- func (x *HttpBufferedTrace) Reset()
- func (x *HttpBufferedTrace) String() string
- type HttpBufferedTrace_Message
- func (*HttpBufferedTrace_Message) Descriptor() ([]byte, []int)deprecated
- func (x *HttpBufferedTrace_Message) GetBody() *Body
- func (x *HttpBufferedTrace_Message) GetHeaders() []*v3.HeaderValue
- func (x *HttpBufferedTrace_Message) GetTrailers() []*v3.HeaderValue
- func (*HttpBufferedTrace_Message) ProtoMessage()
- func (x *HttpBufferedTrace_Message) ProtoReflect() protoreflect.Message
- func (x *HttpBufferedTrace_Message) Reset()
- func (x *HttpBufferedTrace_Message) String() string
- type HttpStreamedTraceSegment
- func (*HttpStreamedTraceSegment) Descriptor() ([]byte, []int)deprecated
- func (m *HttpStreamedTraceSegment) GetMessagePiece() isHttpStreamedTraceSegment_MessagePiece
- func (x *HttpStreamedTraceSegment) GetRequestBodyChunk() *Body
- func (x *HttpStreamedTraceSegment) GetRequestHeaders() *v3.HeaderMap
- func (x *HttpStreamedTraceSegment) GetRequestTrailers() *v3.HeaderMap
- func (x *HttpStreamedTraceSegment) GetResponseBodyChunk() *Body
- func (x *HttpStreamedTraceSegment) GetResponseHeaders() *v3.HeaderMap
- func (x *HttpStreamedTraceSegment) GetResponseTrailers() *v3.HeaderMap
- func (x *HttpStreamedTraceSegment) GetTraceId() uint64
- func (*HttpStreamedTraceSegment) ProtoMessage()
- func (x *HttpStreamedTraceSegment) ProtoReflect() protoreflect.Message
- func (x *HttpStreamedTraceSegment) Reset()
- func (x *HttpStreamedTraceSegment) String() string
- type HttpStreamedTraceSegment_RequestBodyChunk
- type HttpStreamedTraceSegment_RequestHeaders
- type HttpStreamedTraceSegment_RequestTrailers
- type HttpStreamedTraceSegment_ResponseBodyChunk
- type HttpStreamedTraceSegment_ResponseHeaders
- type HttpStreamedTraceSegment_ResponseTrailers
- type SocketBufferedTrace
- func (*SocketBufferedTrace) Descriptor() ([]byte, []int)deprecated
- func (x *SocketBufferedTrace) GetConnection() *Connection
- func (x *SocketBufferedTrace) GetEvents() []*SocketEvent
- func (x *SocketBufferedTrace) GetReadTruncated() bool
- func (x *SocketBufferedTrace) GetTraceId() uint64
- func (x *SocketBufferedTrace) GetWriteTruncated() bool
- func (*SocketBufferedTrace) ProtoMessage()
- func (x *SocketBufferedTrace) ProtoReflect() protoreflect.Message
- func (x *SocketBufferedTrace) Reset()
- func (x *SocketBufferedTrace) String() string
- type SocketEvent
- func (*SocketEvent) Descriptor() ([]byte, []int)deprecated
- func (x *SocketEvent) GetClosed() *SocketEvent_Closed
- func (m *SocketEvent) GetEventSelector() isSocketEvent_EventSelector
- func (x *SocketEvent) GetRead() *SocketEvent_Read
- func (x *SocketEvent) GetTimestamp() *timestamppb.Timestamp
- func (x *SocketEvent) GetWrite() *SocketEvent_Write
- func (*SocketEvent) ProtoMessage()
- func (x *SocketEvent) ProtoReflect() protoreflect.Message
- func (x *SocketEvent) Reset()
- func (x *SocketEvent) String() string
- type SocketEvent_Closed
- type SocketEvent_Closed_
- type SocketEvent_Read
- type SocketEvent_Read_
- type SocketEvent_Write
- func (*SocketEvent_Write) Descriptor() ([]byte, []int)deprecated
- func (x *SocketEvent_Write) GetData() *Body
- func (x *SocketEvent_Write) GetEndStream() bool
- func (*SocketEvent_Write) ProtoMessage()
- func (x *SocketEvent_Write) ProtoReflect() protoreflect.Message
- func (x *SocketEvent_Write) Reset()
- func (x *SocketEvent_Write) String() string
- type SocketEvent_Write_
- type SocketStreamedTraceSegment
- func (*SocketStreamedTraceSegment) Descriptor() ([]byte, []int)deprecated
- func (x *SocketStreamedTraceSegment) GetConnection() *Connection
- func (x *SocketStreamedTraceSegment) GetEvent() *SocketEvent
- func (m *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece
- func (x *SocketStreamedTraceSegment) GetTraceId() uint64
- func (*SocketStreamedTraceSegment) ProtoMessage()
- func (x *SocketStreamedTraceSegment) ProtoReflect() protoreflect.Message
- func (x *SocketStreamedTraceSegment) Reset()
- func (x *SocketStreamedTraceSegment) String() string
- type SocketStreamedTraceSegment_Connection
- type SocketStreamedTraceSegment_Event
- type TraceWrapper
- func (*TraceWrapper) Descriptor() ([]byte, []int)deprecated
- func (x *TraceWrapper) GetHttpBufferedTrace() *HttpBufferedTrace
- func (x *TraceWrapper) GetHttpStreamedTraceSegment() *HttpStreamedTraceSegment
- func (x *TraceWrapper) GetSocketBufferedTrace() *SocketBufferedTrace
- func (x *TraceWrapper) GetSocketStreamedTraceSegment() *SocketStreamedTraceSegment
- func (m *TraceWrapper) GetTrace() isTraceWrapper_Trace
- func (*TraceWrapper) ProtoMessage()
- func (x *TraceWrapper) ProtoReflect() protoreflect.Message
- func (x *TraceWrapper) Reset()
- func (x *TraceWrapper) String() string
- type TraceWrapper_HttpBufferedTrace
- type TraceWrapper_HttpStreamedTraceSegment
- type TraceWrapper_SocketBufferedTrace
- type TraceWrapper_SocketStreamedTraceSegment
Constants ¶
This section is empty.
Variables ¶
var File_envoy_data_tap_v3_common_proto protoreflect.FileDescriptor
var File_envoy_data_tap_v3_http_proto protoreflect.FileDescriptor
var File_envoy_data_tap_v3_transport_proto protoreflect.FileDescriptor
var File_envoy_data_tap_v3_wrapper_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Body ¶
type Body struct { // Types that are assignable to BodyType: // // *Body_AsBytes // *Body_AsString BodyType isBody_BodyType `protobuf_oneof:"body_type"` // Specifies whether body data has been truncated to fit within the specified // :ref:`max_buffered_rx_bytes // <envoy_v3_api_field_config.tap.v3.OutputConfig.max_buffered_rx_bytes>` and // :ref:`max_buffered_tx_bytes // <envoy_v3_api_field_config.tap.v3.OutputConfig.max_buffered_tx_bytes>` settings. Truncated bool `protobuf:"varint,3,opt,name=truncated,proto3" json:"truncated,omitempty"` // contains filtered or unexported fields }
Wrapper for tapped body data. This includes HTTP request/response body, transport socket received and transmitted data, etc.
func (*Body) ProtoReflect ¶
func (x *Body) ProtoReflect() protoreflect.Message
type Body_AsBytes ¶
type Body_AsBytes struct { // Body data as bytes. By default, tap body data will be present in this field, as the proto // “bytes“ type can contain any valid byte. AsBytes []byte `protobuf:"bytes,1,opt,name=as_bytes,json=asBytes,proto3,oneof"` }
type Body_AsString ¶
type Body_AsString struct { // Body data as string. This field is only used when the :ref:`JSON_BODY_AS_STRING // <envoy_v3_api_enum_value_config.tap.v3.OutputSink.Format.JSON_BODY_AS_STRING>` sink // format type is selected. See the documentation for that option for why this is useful. AsString string `protobuf:"bytes,2,opt,name=as_string,json=asString,proto3,oneof"` }
type Connection ¶
type Connection struct { // Local address. LocalAddress *v3.Address `protobuf:"bytes,2,opt,name=local_address,json=localAddress,proto3" json:"local_address,omitempty"` // Remote address. RemoteAddress *v3.Address `protobuf:"bytes,3,opt,name=remote_address,json=remoteAddress,proto3" json:"remote_address,omitempty"` // contains filtered or unexported fields }
Connection properties.
func (*Connection) Descriptor
deprecated
func (*Connection) Descriptor() ([]byte, []int)
Deprecated: Use Connection.ProtoReflect.Descriptor instead.
func (*Connection) GetLocalAddress ¶
func (x *Connection) GetLocalAddress() *v3.Address
func (*Connection) GetRemoteAddress ¶
func (x *Connection) GetRemoteAddress() *v3.Address
func (*Connection) ProtoMessage ¶
func (*Connection) ProtoMessage()
func (*Connection) ProtoReflect ¶
func (x *Connection) ProtoReflect() protoreflect.Message
func (*Connection) Reset ¶
func (x *Connection) Reset()
func (*Connection) String ¶
func (x *Connection) String() string
type HttpBufferedTrace ¶
type HttpBufferedTrace struct { // Request message. Request *HttpBufferedTrace_Message `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` // Response message. Response *HttpBufferedTrace_Message `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` // contains filtered or unexported fields }
A fully buffered HTTP trace message.
func (*HttpBufferedTrace) Descriptor
deprecated
func (*HttpBufferedTrace) Descriptor() ([]byte, []int)
Deprecated: Use HttpBufferedTrace.ProtoReflect.Descriptor instead.
func (*HttpBufferedTrace) GetRequest ¶
func (x *HttpBufferedTrace) GetRequest() *HttpBufferedTrace_Message
func (*HttpBufferedTrace) GetResponse ¶
func (x *HttpBufferedTrace) GetResponse() *HttpBufferedTrace_Message
func (*HttpBufferedTrace) ProtoMessage ¶
func (*HttpBufferedTrace) ProtoMessage()
func (*HttpBufferedTrace) ProtoReflect ¶
func (x *HttpBufferedTrace) ProtoReflect() protoreflect.Message
func (*HttpBufferedTrace) Reset ¶
func (x *HttpBufferedTrace) Reset()
func (*HttpBufferedTrace) String ¶
func (x *HttpBufferedTrace) String() string
type HttpBufferedTrace_Message ¶
type HttpBufferedTrace_Message struct { // Message headers. Headers []*v3.HeaderValue `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"` // Message body. Body *Body `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` // Message trailers. Trailers []*v3.HeaderValue `protobuf:"bytes,3,rep,name=trailers,proto3" json:"trailers,omitempty"` // contains filtered or unexported fields }
HTTP message wrapper.
func (*HttpBufferedTrace_Message) Descriptor
deprecated
func (*HttpBufferedTrace_Message) Descriptor() ([]byte, []int)
Deprecated: Use HttpBufferedTrace_Message.ProtoReflect.Descriptor instead.
func (*HttpBufferedTrace_Message) GetBody ¶
func (x *HttpBufferedTrace_Message) GetBody() *Body
func (*HttpBufferedTrace_Message) GetHeaders ¶
func (x *HttpBufferedTrace_Message) GetHeaders() []*v3.HeaderValue
func (*HttpBufferedTrace_Message) GetTrailers ¶
func (x *HttpBufferedTrace_Message) GetTrailers() []*v3.HeaderValue
func (*HttpBufferedTrace_Message) ProtoMessage ¶
func (*HttpBufferedTrace_Message) ProtoMessage()
func (*HttpBufferedTrace_Message) ProtoReflect ¶
func (x *HttpBufferedTrace_Message) ProtoReflect() protoreflect.Message
func (*HttpBufferedTrace_Message) Reset ¶
func (x *HttpBufferedTrace_Message) Reset()
func (*HttpBufferedTrace_Message) String ¶
func (x *HttpBufferedTrace_Message) String() string
type HttpStreamedTraceSegment ¶
type HttpStreamedTraceSegment struct { // Trace ID unique to the originating Envoy only. Trace IDs can repeat and should not be used // for long term stable uniqueness. TraceId uint64 `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // Types that are assignable to MessagePiece: // // *HttpStreamedTraceSegment_RequestHeaders // *HttpStreamedTraceSegment_RequestBodyChunk // *HttpStreamedTraceSegment_RequestTrailers // *HttpStreamedTraceSegment_ResponseHeaders // *HttpStreamedTraceSegment_ResponseBodyChunk // *HttpStreamedTraceSegment_ResponseTrailers MessagePiece isHttpStreamedTraceSegment_MessagePiece `protobuf_oneof:"message_piece"` // contains filtered or unexported fields }
A streamed HTTP trace segment. Multiple segments make up a full trace. [#next-free-field: 8]
func (*HttpStreamedTraceSegment) Descriptor
deprecated
func (*HttpStreamedTraceSegment) Descriptor() ([]byte, []int)
Deprecated: Use HttpStreamedTraceSegment.ProtoReflect.Descriptor instead.
func (*HttpStreamedTraceSegment) GetMessagePiece ¶
func (m *HttpStreamedTraceSegment) GetMessagePiece() isHttpStreamedTraceSegment_MessagePiece
func (*HttpStreamedTraceSegment) GetRequestBodyChunk ¶
func (x *HttpStreamedTraceSegment) GetRequestBodyChunk() *Body
func (*HttpStreamedTraceSegment) GetRequestHeaders ¶
func (x *HttpStreamedTraceSegment) GetRequestHeaders() *v3.HeaderMap
func (*HttpStreamedTraceSegment) GetRequestTrailers ¶
func (x *HttpStreamedTraceSegment) GetRequestTrailers() *v3.HeaderMap
func (*HttpStreamedTraceSegment) GetResponseBodyChunk ¶
func (x *HttpStreamedTraceSegment) GetResponseBodyChunk() *Body
func (*HttpStreamedTraceSegment) GetResponseHeaders ¶
func (x *HttpStreamedTraceSegment) GetResponseHeaders() *v3.HeaderMap
func (*HttpStreamedTraceSegment) GetResponseTrailers ¶
func (x *HttpStreamedTraceSegment) GetResponseTrailers() *v3.HeaderMap
func (*HttpStreamedTraceSegment) GetTraceId ¶
func (x *HttpStreamedTraceSegment) GetTraceId() uint64
func (*HttpStreamedTraceSegment) ProtoMessage ¶
func (*HttpStreamedTraceSegment) ProtoMessage()
func (*HttpStreamedTraceSegment) ProtoReflect ¶
func (x *HttpStreamedTraceSegment) ProtoReflect() protoreflect.Message
func (*HttpStreamedTraceSegment) Reset ¶
func (x *HttpStreamedTraceSegment) Reset()
func (*HttpStreamedTraceSegment) String ¶
func (x *HttpStreamedTraceSegment) String() string
type HttpStreamedTraceSegment_RequestBodyChunk ¶
type HttpStreamedTraceSegment_RequestBodyChunk struct { // Request body chunk. RequestBodyChunk *Body `protobuf:"bytes,3,opt,name=request_body_chunk,json=requestBodyChunk,proto3,oneof"` }
type HttpStreamedTraceSegment_RequestHeaders ¶
type HttpStreamedTraceSegment_RequestTrailers ¶
type HttpStreamedTraceSegment_ResponseBodyChunk ¶
type HttpStreamedTraceSegment_ResponseBodyChunk struct { // Response body chunk. ResponseBodyChunk *Body `protobuf:"bytes,6,opt,name=response_body_chunk,json=responseBodyChunk,proto3,oneof"` }
type HttpStreamedTraceSegment_ResponseHeaders ¶
type HttpStreamedTraceSegment_ResponseTrailers ¶
type SocketBufferedTrace ¶
type SocketBufferedTrace struct { // Trace ID unique to the originating Envoy only. Trace IDs can repeat and should not be used // for long term stable uniqueness. Matches connection IDs used in Envoy logs. TraceId uint64 `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // Connection properties. Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"` // Sequence of observed events. Events []*SocketEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"` // Set to true if read events were truncated due to the :ref:`max_buffered_rx_bytes // <envoy_v3_api_field_config.tap.v3.OutputConfig.max_buffered_rx_bytes>` setting. ReadTruncated bool `protobuf:"varint,4,opt,name=read_truncated,json=readTruncated,proto3" json:"read_truncated,omitempty"` // Set to true if write events were truncated due to the :ref:`max_buffered_tx_bytes // <envoy_v3_api_field_config.tap.v3.OutputConfig.max_buffered_tx_bytes>` setting. WriteTruncated bool `protobuf:"varint,5,opt,name=write_truncated,json=writeTruncated,proto3" json:"write_truncated,omitempty"` // contains filtered or unexported fields }
Sequence of read/write events that constitute a buffered trace on a socket. [#next-free-field: 6]
func (*SocketBufferedTrace) Descriptor
deprecated
func (*SocketBufferedTrace) Descriptor() ([]byte, []int)
Deprecated: Use SocketBufferedTrace.ProtoReflect.Descriptor instead.
func (*SocketBufferedTrace) GetConnection ¶
func (x *SocketBufferedTrace) GetConnection() *Connection
func (*SocketBufferedTrace) GetEvents ¶
func (x *SocketBufferedTrace) GetEvents() []*SocketEvent
func (*SocketBufferedTrace) GetReadTruncated ¶
func (x *SocketBufferedTrace) GetReadTruncated() bool
func (*SocketBufferedTrace) GetTraceId ¶
func (x *SocketBufferedTrace) GetTraceId() uint64
func (*SocketBufferedTrace) GetWriteTruncated ¶
func (x *SocketBufferedTrace) GetWriteTruncated() bool
func (*SocketBufferedTrace) ProtoMessage ¶
func (*SocketBufferedTrace) ProtoMessage()
func (*SocketBufferedTrace) ProtoReflect ¶
func (x *SocketBufferedTrace) ProtoReflect() protoreflect.Message
func (*SocketBufferedTrace) Reset ¶
func (x *SocketBufferedTrace) Reset()
func (*SocketBufferedTrace) String ¶
func (x *SocketBufferedTrace) String() string
type SocketEvent ¶
type SocketEvent struct { // Timestamp for event. Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Read or write with content as bytes string. // // Types that are assignable to EventSelector: // // *SocketEvent_Read_ // *SocketEvent_Write_ // *SocketEvent_Closed_ EventSelector isSocketEvent_EventSelector `protobuf_oneof:"event_selector"` // contains filtered or unexported fields }
Event in a socket trace.
func (*SocketEvent) Descriptor
deprecated
func (*SocketEvent) Descriptor() ([]byte, []int)
Deprecated: Use SocketEvent.ProtoReflect.Descriptor instead.
func (*SocketEvent) GetClosed ¶
func (x *SocketEvent) GetClosed() *SocketEvent_Closed
func (*SocketEvent) GetEventSelector ¶
func (m *SocketEvent) GetEventSelector() isSocketEvent_EventSelector
func (*SocketEvent) GetRead ¶
func (x *SocketEvent) GetRead() *SocketEvent_Read
func (*SocketEvent) GetTimestamp ¶
func (x *SocketEvent) GetTimestamp() *timestamppb.Timestamp
func (*SocketEvent) GetWrite ¶
func (x *SocketEvent) GetWrite() *SocketEvent_Write
func (*SocketEvent) ProtoMessage ¶
func (*SocketEvent) ProtoMessage()
func (*SocketEvent) ProtoReflect ¶
func (x *SocketEvent) ProtoReflect() protoreflect.Message
func (*SocketEvent) Reset ¶
func (x *SocketEvent) Reset()
func (*SocketEvent) String ¶
func (x *SocketEvent) String() string
type SocketEvent_Closed ¶
type SocketEvent_Closed struct {
// contains filtered or unexported fields
}
The connection was closed.
func (*SocketEvent_Closed) Descriptor
deprecated
func (*SocketEvent_Closed) Descriptor() ([]byte, []int)
Deprecated: Use SocketEvent_Closed.ProtoReflect.Descriptor instead.
func (*SocketEvent_Closed) ProtoMessage ¶
func (*SocketEvent_Closed) ProtoMessage()
func (*SocketEvent_Closed) ProtoReflect ¶
func (x *SocketEvent_Closed) ProtoReflect() protoreflect.Message
func (*SocketEvent_Closed) Reset ¶
func (x *SocketEvent_Closed) Reset()
func (*SocketEvent_Closed) String ¶
func (x *SocketEvent_Closed) String() string
type SocketEvent_Closed_ ¶
type SocketEvent_Closed_ struct {
Closed *SocketEvent_Closed `protobuf:"bytes,4,opt,name=closed,proto3,oneof"`
}
type SocketEvent_Read ¶
type SocketEvent_Read struct { // Binary data read. Data *Body `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
Data read by Envoy from the transport socket.
func (*SocketEvent_Read) Descriptor
deprecated
func (*SocketEvent_Read) Descriptor() ([]byte, []int)
Deprecated: Use SocketEvent_Read.ProtoReflect.Descriptor instead.
func (*SocketEvent_Read) GetData ¶
func (x *SocketEvent_Read) GetData() *Body
func (*SocketEvent_Read) ProtoMessage ¶
func (*SocketEvent_Read) ProtoMessage()
func (*SocketEvent_Read) ProtoReflect ¶
func (x *SocketEvent_Read) ProtoReflect() protoreflect.Message
func (*SocketEvent_Read) Reset ¶
func (x *SocketEvent_Read) Reset()
func (*SocketEvent_Read) String ¶
func (x *SocketEvent_Read) String() string
type SocketEvent_Read_ ¶
type SocketEvent_Read_ struct {
Read *SocketEvent_Read `protobuf:"bytes,2,opt,name=read,proto3,oneof"`
}
type SocketEvent_Write ¶
type SocketEvent_Write struct { // Binary data written. Data *Body `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // Stream was half closed after this write. EndStream bool `protobuf:"varint,2,opt,name=end_stream,json=endStream,proto3" json:"end_stream,omitempty"` // contains filtered or unexported fields }
Data written by Envoy to the transport socket.
func (*SocketEvent_Write) Descriptor
deprecated
func (*SocketEvent_Write) Descriptor() ([]byte, []int)
Deprecated: Use SocketEvent_Write.ProtoReflect.Descriptor instead.
func (*SocketEvent_Write) GetData ¶
func (x *SocketEvent_Write) GetData() *Body
func (*SocketEvent_Write) GetEndStream ¶
func (x *SocketEvent_Write) GetEndStream() bool
func (*SocketEvent_Write) ProtoMessage ¶
func (*SocketEvent_Write) ProtoMessage()
func (*SocketEvent_Write) ProtoReflect ¶
func (x *SocketEvent_Write) ProtoReflect() protoreflect.Message
func (*SocketEvent_Write) Reset ¶
func (x *SocketEvent_Write) Reset()
func (*SocketEvent_Write) String ¶
func (x *SocketEvent_Write) String() string
type SocketEvent_Write_ ¶
type SocketEvent_Write_ struct {
Write *SocketEvent_Write `protobuf:"bytes,3,opt,name=write,proto3,oneof"`
}
type SocketStreamedTraceSegment ¶
type SocketStreamedTraceSegment struct { // Trace ID unique to the originating Envoy only. Trace IDs can repeat and should not be used // for long term stable uniqueness. Matches connection IDs used in Envoy logs. TraceId uint64 `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // Types that are assignable to MessagePiece: // // *SocketStreamedTraceSegment_Connection // *SocketStreamedTraceSegment_Event MessagePiece isSocketStreamedTraceSegment_MessagePiece `protobuf_oneof:"message_piece"` // contains filtered or unexported fields }
A streamed socket trace segment. Multiple segments make up a full trace.
func (*SocketStreamedTraceSegment) Descriptor
deprecated
func (*SocketStreamedTraceSegment) Descriptor() ([]byte, []int)
Deprecated: Use SocketStreamedTraceSegment.ProtoReflect.Descriptor instead.
func (*SocketStreamedTraceSegment) GetConnection ¶
func (x *SocketStreamedTraceSegment) GetConnection() *Connection
func (*SocketStreamedTraceSegment) GetEvent ¶
func (x *SocketStreamedTraceSegment) GetEvent() *SocketEvent
func (*SocketStreamedTraceSegment) GetMessagePiece ¶
func (m *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece
func (*SocketStreamedTraceSegment) GetTraceId ¶
func (x *SocketStreamedTraceSegment) GetTraceId() uint64
func (*SocketStreamedTraceSegment) ProtoMessage ¶
func (*SocketStreamedTraceSegment) ProtoMessage()
func (*SocketStreamedTraceSegment) ProtoReflect ¶
func (x *SocketStreamedTraceSegment) ProtoReflect() protoreflect.Message
func (*SocketStreamedTraceSegment) Reset ¶
func (x *SocketStreamedTraceSegment) Reset()
func (*SocketStreamedTraceSegment) String ¶
func (x *SocketStreamedTraceSegment) String() string
type SocketStreamedTraceSegment_Connection ¶
type SocketStreamedTraceSegment_Connection struct { // Connection properties. Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3,oneof"` }
type SocketStreamedTraceSegment_Event ¶
type SocketStreamedTraceSegment_Event struct { // Socket event. Event *SocketEvent `protobuf:"bytes,3,opt,name=event,proto3,oneof"` }
type TraceWrapper ¶
type TraceWrapper struct { // Types that are assignable to Trace: // // *TraceWrapper_HttpBufferedTrace // *TraceWrapper_HttpStreamedTraceSegment // *TraceWrapper_SocketBufferedTrace // *TraceWrapper_SocketStreamedTraceSegment Trace isTraceWrapper_Trace `protobuf_oneof:"trace"` // contains filtered or unexported fields }
Wrapper for all fully buffered and streamed tap traces that Envoy emits. This is required for sending traces over gRPC APIs or more easily persisting binary messages to files.
func (*TraceWrapper) Descriptor
deprecated
func (*TraceWrapper) Descriptor() ([]byte, []int)
Deprecated: Use TraceWrapper.ProtoReflect.Descriptor instead.
func (*TraceWrapper) GetHttpBufferedTrace ¶
func (x *TraceWrapper) GetHttpBufferedTrace() *HttpBufferedTrace
func (*TraceWrapper) GetHttpStreamedTraceSegment ¶
func (x *TraceWrapper) GetHttpStreamedTraceSegment() *HttpStreamedTraceSegment
func (*TraceWrapper) GetSocketBufferedTrace ¶
func (x *TraceWrapper) GetSocketBufferedTrace() *SocketBufferedTrace
func (*TraceWrapper) GetSocketStreamedTraceSegment ¶
func (x *TraceWrapper) GetSocketStreamedTraceSegment() *SocketStreamedTraceSegment
func (*TraceWrapper) GetTrace ¶
func (m *TraceWrapper) GetTrace() isTraceWrapper_Trace
func (*TraceWrapper) ProtoMessage ¶
func (*TraceWrapper) ProtoMessage()
func (*TraceWrapper) ProtoReflect ¶
func (x *TraceWrapper) ProtoReflect() protoreflect.Message
func (*TraceWrapper) Reset ¶
func (x *TraceWrapper) Reset()
func (*TraceWrapper) String ¶
func (x *TraceWrapper) String() string
type TraceWrapper_HttpBufferedTrace ¶
type TraceWrapper_HttpBufferedTrace struct { // An HTTP buffered tap trace. HttpBufferedTrace *HttpBufferedTrace `protobuf:"bytes,1,opt,name=http_buffered_trace,json=httpBufferedTrace,proto3,oneof"` }
type TraceWrapper_HttpStreamedTraceSegment ¶
type TraceWrapper_HttpStreamedTraceSegment struct { // An HTTP streamed tap trace segment. HttpStreamedTraceSegment *HttpStreamedTraceSegment `protobuf:"bytes,2,opt,name=http_streamed_trace_segment,json=httpStreamedTraceSegment,proto3,oneof"` }
type TraceWrapper_SocketBufferedTrace ¶
type TraceWrapper_SocketBufferedTrace struct { // A socket buffered tap trace. SocketBufferedTrace *SocketBufferedTrace `protobuf:"bytes,3,opt,name=socket_buffered_trace,json=socketBufferedTrace,proto3,oneof"` }
type TraceWrapper_SocketStreamedTraceSegment ¶
type TraceWrapper_SocketStreamedTraceSegment struct { // A socket streamed tap trace segment. SocketStreamedTraceSegment *SocketStreamedTraceSegment `protobuf:"bytes,4,opt,name=socket_streamed_trace_segment,json=socketStreamedTraceSegment,proto3,oneof"` }