tapv2alpha

package
v1.36.3-20231211223035... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const Body_AsBytes_case case_Body_BodyType = 1
View Source 
const Body_AsString_case case_Body_BodyType = 2
View Source 
const Body_BodyType_not_set_case case_Body_BodyType = 0
View Source 
const HttpStreamedTraceSegment_MessagePiece_not_set_case case_HttpStreamedTraceSegment_MessagePiece = 0
View Source 
const HttpStreamedTraceSegment_RequestBodyChunk_case case_HttpStreamedTraceSegment_MessagePiece = 3
View Source 
const HttpStreamedTraceSegment_RequestHeaders_case case_HttpStreamedTraceSegment_MessagePiece = 2
View Source 
const HttpStreamedTraceSegment_RequestTrailers_case case_HttpStreamedTraceSegment_MessagePiece = 4
View Source 
const HttpStreamedTraceSegment_ResponseBodyChunk_case case_HttpStreamedTraceSegment_MessagePiece = 6
View Source 
const HttpStreamedTraceSegment_ResponseHeaders_case case_HttpStreamedTraceSegment_MessagePiece = 5
View Source 
const HttpStreamedTraceSegment_ResponseTrailers_case case_HttpStreamedTraceSegment_MessagePiece = 7
View Source 
const SocketEvent_Closed_case case_SocketEvent_EventSelector = 4
View Source 
const SocketEvent_EventSelector_not_set_case case_SocketEvent_EventSelector = 0
View Source 
const SocketEvent_Read_case case_SocketEvent_EventSelector = 2
View Source 
const SocketEvent_Write_case case_SocketEvent_EventSelector = 3
View Source 
const SocketStreamedTraceSegment_Connection_case case_SocketStreamedTraceSegment_MessagePiece = 2
View Source 
const SocketStreamedTraceSegment_Event_case case_SocketStreamedTraceSegment_MessagePiece = 3
View Source 
const SocketStreamedTraceSegment_MessagePiece_not_set_case case_SocketStreamedTraceSegment_MessagePiece = 0
View Source 
const TraceWrapper_HttpBufferedTrace_case case_TraceWrapper_Trace = 1
View Source 
const TraceWrapper_HttpStreamedTraceSegment_case case_TraceWrapper_Trace = 2
View Source 
const TraceWrapper_SocketBufferedTrace_case case_TraceWrapper_Trace = 3
View Source 
const TraceWrapper_SocketStreamedTraceSegment_case case_TraceWrapper_Trace = 4
View Source 
const TraceWrapper_Trace_not_set_case case_TraceWrapper_Trace = 0

Variables

View Source 
var File_envoy_data_tap_v2alpha_common_proto protoreflect.FileDescriptor
View Source 
var File_envoy_data_tap_v2alpha_http_proto protoreflect.FileDescriptor
View Source 
var File_envoy_data_tap_v2alpha_transport_proto protoreflect.FileDescriptor
View Source 
var File_envoy_data_tap_v2alpha_wrapper_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Body 

type Body struct {

	// Types that are valid to be assigned 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_api_field_service.tap.v2alpha.OutputConfig.max_buffered_rx_bytes>` and
	// :ref:`max_buffered_tx_bytes
	// <envoy_api_field_service.tap.v2alpha.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) ClearAsBytes 

func (x *Body) ClearAsBytes()

func (*Body) ClearAsString 

func (x *Body) ClearAsString()

func (*Body) ClearBodyType 

func (x *Body) ClearBodyType()

func (*Body) GetAsBytes 

func (x *Body) GetAsBytes() []byte

func (*Body) GetAsString 

func (x *Body) GetAsString() string

func (*Body) GetBodyType 

func (x *Body) GetBodyType() isBody_BodyType

func (*Body) GetTruncated 

func (x *Body) GetTruncated() bool

func (*Body) HasAsBytes 

func (x *Body) HasAsBytes() bool

func (*Body) HasAsString 

func (x *Body) HasAsString() bool

func (*Body) HasBodyType 

func (x *Body) HasBodyType() bool

func (*Body) ProtoMessage 

func (*Body) ProtoMessage()

func (*Body) ProtoReflect 

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

func (*Body) Reset 

func (x *Body) Reset()

func (*Body) SetAsBytes 

func (x *Body) SetAsBytes(v []byte)

func (*Body) SetAsString 

func (x *Body) SetAsString(v string)

func (*Body) SetTruncated 

func (x *Body) SetTruncated(v bool)

func (*Body) String 

func (x *Body) String() string

func (*Body) WhichBodyType 

func (x *Body) WhichBodyType() case_Body_BodyType

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_api_enum_value_service.tap.v2alpha.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 Body_builder 

type Body_builder struct {

	// Fields of oneof BodyType:
	// 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
	// Body data as string. This field is only used when the :ref:`JSON_BODY_AS_STRING
	// <envoy_api_enum_value_service.tap.v2alpha.OutputSink.Format.JSON_BODY_AS_STRING>` sink
	// format type is selected. See the documentation for that option for why this is useful.
	AsString *string
	// -- end of BodyType
	// Specifies whether body data has been truncated to fit within the specified
	// :ref:`max_buffered_rx_bytes
	// <envoy_api_field_service.tap.v2alpha.OutputConfig.max_buffered_rx_bytes>` and
	// :ref:`max_buffered_tx_bytes
	// <envoy_api_field_service.tap.v2alpha.OutputConfig.max_buffered_tx_bytes>` settings.
	Truncated bool
	// contains filtered or unexported fields
}

func (Body_builder) Build 

func (b0 Body_builder) Build() *Body

type Connection 

type Connection struct {

	// Local address.
	LocalAddress *core.Address `protobuf:"bytes,2,opt,name=local_address,json=localAddress,proto3" json:"local_address,omitempty"`
	// Remote address.
	RemoteAddress *core.Address `protobuf:"bytes,3,opt,name=remote_address,json=remoteAddress,proto3" json:"remote_address,omitempty"`
	// contains filtered or unexported fields
}

Connection properties.

func (*Connection) ClearLocalAddress 

func (x *Connection) ClearLocalAddress()

func (*Connection) ClearRemoteAddress 

func (x *Connection) ClearRemoteAddress()

func (*Connection) GetLocalAddress 

func (x *Connection) GetLocalAddress() *core.Address

func (*Connection) GetRemoteAddress 

func (x *Connection) GetRemoteAddress() *core.Address

func (*Connection) HasLocalAddress 

func (x *Connection) HasLocalAddress() bool

func (*Connection) HasRemoteAddress 

func (x *Connection) HasRemoteAddress() bool

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect 

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

func (*Connection) Reset 

func (x *Connection) Reset()

func (*Connection) SetLocalAddress 

func (x *Connection) SetLocalAddress(v *core.Address)

func (*Connection) SetRemoteAddress 

func (x *Connection) SetRemoteAddress(v *core.Address)

func (*Connection) String 

func (x *Connection) String() string

type Connection_builder 

type Connection_builder struct {

	// Local address.
	LocalAddress *core.Address
	// Remote address.
	RemoteAddress *core.Address
	// contains filtered or unexported fields
}

func (Connection_builder) Build 

func (b0 Connection_builder) Build() *Connection

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

func (x *HttpBufferedTrace) ClearRequest()

func (*HttpBufferedTrace) ClearResponse 

func (x *HttpBufferedTrace) ClearResponse()

func (*HttpBufferedTrace) GetRequest 

func (x *HttpBufferedTrace) GetRequest() *HttpBufferedTrace_Message

func (*HttpBufferedTrace) GetResponse 

func (x *HttpBufferedTrace) GetResponse() *HttpBufferedTrace_Message

func (*HttpBufferedTrace) HasRequest 

func (x *HttpBufferedTrace) HasRequest() bool

func (*HttpBufferedTrace) HasResponse 

func (x *HttpBufferedTrace) HasResponse() bool

func (*HttpBufferedTrace) ProtoMessage 

func (*HttpBufferedTrace) ProtoMessage()

func (*HttpBufferedTrace) ProtoReflect 

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

func (*HttpBufferedTrace) Reset 

func (x *HttpBufferedTrace) Reset()

func (*HttpBufferedTrace) SetRequest 

func (x *HttpBufferedTrace) SetRequest(v *HttpBufferedTrace_Message)

func (*HttpBufferedTrace) SetResponse 

func (x *HttpBufferedTrace) SetResponse(v *HttpBufferedTrace_Message)

func (*HttpBufferedTrace) String 

func (x *HttpBufferedTrace) String() string

type HttpBufferedTrace_Message 

type HttpBufferedTrace_Message struct {

	// Message headers.
	Headers []*core.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 []*core.HeaderValue `protobuf:"bytes,3,rep,name=trailers,proto3" json:"trailers,omitempty"`
	// contains filtered or unexported fields
}

HTTP message wrapper.

func (*HttpBufferedTrace_Message) ClearBody 

func (x *HttpBufferedTrace_Message) ClearBody()

func (*HttpBufferedTrace_Message) GetBody 

func (x *HttpBufferedTrace_Message) GetBody() *Body

func (*HttpBufferedTrace_Message) GetHeaders 

func (x *HttpBufferedTrace_Message) GetHeaders() []*core.HeaderValue

func (*HttpBufferedTrace_Message) GetTrailers 

func (x *HttpBufferedTrace_Message) GetTrailers() []*core.HeaderValue

func (*HttpBufferedTrace_Message) HasBody 

func (x *HttpBufferedTrace_Message) HasBody() bool

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

func (x *HttpBufferedTrace_Message) SetBody(v *Body)

func (*HttpBufferedTrace_Message) SetHeaders 

func (x *HttpBufferedTrace_Message) SetHeaders(v []*core.HeaderValue)

func (*HttpBufferedTrace_Message) SetTrailers 

func (x *HttpBufferedTrace_Message) SetTrailers(v []*core.HeaderValue)

func (*HttpBufferedTrace_Message) String 

func (x *HttpBufferedTrace_Message) String() string

type HttpBufferedTrace_Message_builder 

type HttpBufferedTrace_Message_builder struct {

	// Message headers.
	Headers []*core.HeaderValue
	// Message body.
	Body *Body
	// Message trailers.
	Trailers []*core.HeaderValue
	// contains filtered or unexported fields
}

func (HttpBufferedTrace_Message_builder) Build 

func (b0 HttpBufferedTrace_Message_builder) Build() *HttpBufferedTrace_Message

type HttpBufferedTrace_builder 

type HttpBufferedTrace_builder struct {

	// Request message.
	Request *HttpBufferedTrace_Message
	// Response message.
	Response *HttpBufferedTrace_Message
	// contains filtered or unexported fields
}

func (HttpBufferedTrace_builder) Build 

func (b0 HttpBufferedTrace_builder) Build() *HttpBufferedTrace

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 valid to be assigned 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) ClearMessagePiece 

func (x *HttpStreamedTraceSegment) ClearMessagePiece()

func (*HttpStreamedTraceSegment) ClearRequestBodyChunk 

func (x *HttpStreamedTraceSegment) ClearRequestBodyChunk()

func (*HttpStreamedTraceSegment) ClearRequestHeaders 

func (x *HttpStreamedTraceSegment) ClearRequestHeaders()

func (*HttpStreamedTraceSegment) ClearRequestTrailers 

func (x *HttpStreamedTraceSegment) ClearRequestTrailers()

func (*HttpStreamedTraceSegment) ClearResponseBodyChunk 

func (x *HttpStreamedTraceSegment) ClearResponseBodyChunk()

func (*HttpStreamedTraceSegment) ClearResponseHeaders 

func (x *HttpStreamedTraceSegment) ClearResponseHeaders()

func (*HttpStreamedTraceSegment) ClearResponseTrailers 

func (x *HttpStreamedTraceSegment) ClearResponseTrailers()

func (*HttpStreamedTraceSegment) GetMessagePiece 

func (x *HttpStreamedTraceSegment) GetMessagePiece() isHttpStreamedTraceSegment_MessagePiece

func (*HttpStreamedTraceSegment) GetRequestBodyChunk 

func (x *HttpStreamedTraceSegment) GetRequestBodyChunk() *Body

func (*HttpStreamedTraceSegment) GetRequestHeaders 

func (x *HttpStreamedTraceSegment) GetRequestHeaders() *core.HeaderMap

func (*HttpStreamedTraceSegment) GetRequestTrailers 

func (x *HttpStreamedTraceSegment) GetRequestTrailers() *core.HeaderMap

func (*HttpStreamedTraceSegment) GetResponseBodyChunk 

func (x *HttpStreamedTraceSegment) GetResponseBodyChunk() *Body

func (*HttpStreamedTraceSegment) GetResponseHeaders 

func (x *HttpStreamedTraceSegment) GetResponseHeaders() *core.HeaderMap

func (*HttpStreamedTraceSegment) GetResponseTrailers 

func (x *HttpStreamedTraceSegment) GetResponseTrailers() *core.HeaderMap

func (*HttpStreamedTraceSegment) GetTraceId 

func (x *HttpStreamedTraceSegment) GetTraceId() uint64

func (*HttpStreamedTraceSegment) HasMessagePiece 

func (x *HttpStreamedTraceSegment) HasMessagePiece() bool

func (*HttpStreamedTraceSegment) HasRequestBodyChunk 

func (x *HttpStreamedTraceSegment) HasRequestBodyChunk() bool

func (*HttpStreamedTraceSegment) HasRequestHeaders 

func (x *HttpStreamedTraceSegment) HasRequestHeaders() bool

func (*HttpStreamedTraceSegment) HasRequestTrailers 

func (x *HttpStreamedTraceSegment) HasRequestTrailers() bool

func (*HttpStreamedTraceSegment) HasResponseBodyChunk 

func (x *HttpStreamedTraceSegment) HasResponseBodyChunk() bool

func (*HttpStreamedTraceSegment) HasResponseHeaders 

func (x *HttpStreamedTraceSegment) HasResponseHeaders() bool

func (*HttpStreamedTraceSegment) HasResponseTrailers 

func (x *HttpStreamedTraceSegment) HasResponseTrailers() bool

func (*HttpStreamedTraceSegment) ProtoMessage 

func (*HttpStreamedTraceSegment) ProtoMessage()

func (*HttpStreamedTraceSegment) ProtoReflect 

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

func (*HttpStreamedTraceSegment) Reset 

func (x *HttpStreamedTraceSegment) Reset()

func (*HttpStreamedTraceSegment) SetRequestBodyChunk 

func (x *HttpStreamedTraceSegment) SetRequestBodyChunk(v *Body)

func (*HttpStreamedTraceSegment) SetRequestHeaders 

func (x *HttpStreamedTraceSegment) SetRequestHeaders(v *core.HeaderMap)

func (*HttpStreamedTraceSegment) SetRequestTrailers 

func (x *HttpStreamedTraceSegment) SetRequestTrailers(v *core.HeaderMap)

func (*HttpStreamedTraceSegment) SetResponseBodyChunk 

func (x *HttpStreamedTraceSegment) SetResponseBodyChunk(v *Body)

func (*HttpStreamedTraceSegment) SetResponseHeaders 

func (x *HttpStreamedTraceSegment) SetResponseHeaders(v *core.HeaderMap)

func (*HttpStreamedTraceSegment) SetResponseTrailers 

func (x *HttpStreamedTraceSegment) SetResponseTrailers(v *core.HeaderMap)

func (*HttpStreamedTraceSegment) SetTraceId 

func (x *HttpStreamedTraceSegment) SetTraceId(v uint64)

func (*HttpStreamedTraceSegment) String 

func (x *HttpStreamedTraceSegment) String() string

func (*HttpStreamedTraceSegment) WhichMessagePiece 

func (x *HttpStreamedTraceSegment) WhichMessagePiece() case_HttpStreamedTraceSegment_MessagePiece

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_RequestHeaders struct {
	// Request headers.
	RequestHeaders *core.HeaderMap `protobuf:"bytes,2,opt,name=request_headers,json=requestHeaders,proto3,oneof"`
}

type HttpStreamedTraceSegment_RequestTrailers 

type HttpStreamedTraceSegment_RequestTrailers struct {
	// Request trailers.
	RequestTrailers *core.HeaderMap `protobuf:"bytes,4,opt,name=request_trailers,json=requestTrailers,proto3,oneof"`
}

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_ResponseHeaders struct {
	// Response headers.
	ResponseHeaders *core.HeaderMap `protobuf:"bytes,5,opt,name=response_headers,json=responseHeaders,proto3,oneof"`
}

type HttpStreamedTraceSegment_ResponseTrailers 

type HttpStreamedTraceSegment_ResponseTrailers struct {
	// Response trailers.
	ResponseTrailers *core.HeaderMap `protobuf:"bytes,7,opt,name=response_trailers,json=responseTrailers,proto3,oneof"`
}

type HttpStreamedTraceSegment_builder 

type HttpStreamedTraceSegment_builder 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
	// Fields of oneof MessagePiece:
	// Request headers.
	RequestHeaders *core.HeaderMap
	// Request body chunk.
	RequestBodyChunk *Body
	// Request trailers.
	RequestTrailers *core.HeaderMap
	// Response headers.
	ResponseHeaders *core.HeaderMap
	// Response body chunk.
	ResponseBodyChunk *Body
	// Response trailers.
	ResponseTrailers *core.HeaderMap
	// contains filtered or unexported fields
}

func (HttpStreamedTraceSegment_builder) Build 

func (b0 HttpStreamedTraceSegment_builder) Build() *HttpStreamedTraceSegment

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_api_field_service.tap.v2alpha.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_api_field_service.tap.v2alpha.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) ClearConnection 

func (x *SocketBufferedTrace) ClearConnection()

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

func (x *SocketBufferedTrace) HasConnection() 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) SetConnection 

func (x *SocketBufferedTrace) SetConnection(v *Connection)

func (*SocketBufferedTrace) SetEvents 

func (x *SocketBufferedTrace) SetEvents(v []*SocketEvent)

func (*SocketBufferedTrace) SetReadTruncated 

func (x *SocketBufferedTrace) SetReadTruncated(v bool)

func (*SocketBufferedTrace) SetTraceId 

func (x *SocketBufferedTrace) SetTraceId(v uint64)

func (*SocketBufferedTrace) SetWriteTruncated 

func (x *SocketBufferedTrace) SetWriteTruncated(v bool)

func (*SocketBufferedTrace) String 

func (x *SocketBufferedTrace) String() string

type SocketBufferedTrace_builder 

type SocketBufferedTrace_builder 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
	// Connection properties.
	Connection *Connection
	// Sequence of observed events.
	Events []*SocketEvent
	// Set to true if read events were truncated due to the :ref:`max_buffered_rx_bytes
	// <envoy_api_field_service.tap.v2alpha.OutputConfig.max_buffered_rx_bytes>` setting.
	ReadTruncated bool
	// Set to true if write events were truncated due to the :ref:`max_buffered_tx_bytes
	// <envoy_api_field_service.tap.v2alpha.OutputConfig.max_buffered_tx_bytes>` setting.
	WriteTruncated bool
	// contains filtered or unexported fields
}

func (SocketBufferedTrace_builder) Build 

func (b0 SocketBufferedTrace_builder) Build() *SocketBufferedTrace

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 valid to be assigned 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) ClearClosed 

func (x *SocketEvent) ClearClosed()

func (*SocketEvent) ClearEventSelector 

func (x *SocketEvent) ClearEventSelector()

func (*SocketEvent) ClearRead 

func (x *SocketEvent) ClearRead()

func (*SocketEvent) ClearTimestamp 

func (x *SocketEvent) ClearTimestamp()

func (*SocketEvent) ClearWrite 

func (x *SocketEvent) ClearWrite()

func (*SocketEvent) GetClosed 

func (x *SocketEvent) GetClosed() *SocketEvent_Closed

func (*SocketEvent) GetEventSelector 

func (x *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) HasClosed 

func (x *SocketEvent) HasClosed() bool

func (*SocketEvent) HasEventSelector 

func (x *SocketEvent) HasEventSelector() bool

func (*SocketEvent) HasRead 

func (x *SocketEvent) HasRead() bool

func (*SocketEvent) HasTimestamp 

func (x *SocketEvent) HasTimestamp() bool

func (*SocketEvent) HasWrite 

func (x *SocketEvent) HasWrite() bool

func (*SocketEvent) ProtoMessage 

func (*SocketEvent) ProtoMessage()

func (*SocketEvent) ProtoReflect 

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

func (*SocketEvent) Reset 

func (x *SocketEvent) Reset()

func (*SocketEvent) SetClosed 

func (x *SocketEvent) SetClosed(v *SocketEvent_Closed)

func (*SocketEvent) SetRead 

func (x *SocketEvent) SetRead(v *SocketEvent_Read)

func (*SocketEvent) SetTimestamp 

func (x *SocketEvent) SetTimestamp(v *timestamppb.Timestamp)

func (*SocketEvent) SetWrite 

func (x *SocketEvent) SetWrite(v *SocketEvent_Write)

func (*SocketEvent) String 

func (x *SocketEvent) String() string

func (*SocketEvent) WhichEventSelector 

func (x *SocketEvent) WhichEventSelector() case_SocketEvent_EventSelector

type SocketEvent_Closed 

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

The connection was closed.

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_Closed_builder 

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

func (SocketEvent_Closed_builder) Build 

func (b0 SocketEvent_Closed_builder) Build() *SocketEvent_Closed

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

func (x *SocketEvent_Read) ClearData()

func (*SocketEvent_Read) GetData 

func (x *SocketEvent_Read) GetData() *Body

func (*SocketEvent_Read) HasData 

func (x *SocketEvent_Read) HasData() bool

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

func (x *SocketEvent_Read) SetData(v *Body)

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_Read_builder 

type SocketEvent_Read_builder struct {

	// Binary data read.
	Data *Body
	// contains filtered or unexported fields
}

func (SocketEvent_Read_builder) Build 

func (b0 SocketEvent_Read_builder) Build() *SocketEvent_Read

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

func (x *SocketEvent_Write) ClearData()

func (*SocketEvent_Write) GetData 

func (x *SocketEvent_Write) GetData() *Body

func (*SocketEvent_Write) GetEndStream 

func (x *SocketEvent_Write) GetEndStream() bool

func (*SocketEvent_Write) HasData 

func (x *SocketEvent_Write) HasData() 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) SetData 

func (x *SocketEvent_Write) SetData(v *Body)

func (*SocketEvent_Write) SetEndStream 

func (x *SocketEvent_Write) SetEndStream(v bool)

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 SocketEvent_Write_builder 

type SocketEvent_Write_builder struct {

	// Binary data written.
	Data *Body
	// Stream was half closed after this write.
	EndStream bool
	// contains filtered or unexported fields
}

func (SocketEvent_Write_builder) Build 

func (b0 SocketEvent_Write_builder) Build() *SocketEvent_Write

type SocketEvent_builder 

type SocketEvent_builder struct {

	// Timestamp for event.
	Timestamp *timestamppb.Timestamp

	// Fields of oneof EventSelector:
	Read   *SocketEvent_Read
	Write  *SocketEvent_Write
	Closed *SocketEvent_Closed
	// contains filtered or unexported fields
}

func (SocketEvent_builder) Build 

func (b0 SocketEvent_builder) Build() *SocketEvent

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 valid to be assigned 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) ClearConnection 

func (x *SocketStreamedTraceSegment) ClearConnection()

func (*SocketStreamedTraceSegment) ClearEvent 

func (x *SocketStreamedTraceSegment) ClearEvent()

func (*SocketStreamedTraceSegment) ClearMessagePiece 

func (x *SocketStreamedTraceSegment) ClearMessagePiece()

func (*SocketStreamedTraceSegment) GetConnection 

func (x *SocketStreamedTraceSegment) GetConnection() *Connection

func (*SocketStreamedTraceSegment) GetEvent 

func (x *SocketStreamedTraceSegment) GetEvent() *SocketEvent

func (*SocketStreamedTraceSegment) GetMessagePiece 

func (x *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece

func (*SocketStreamedTraceSegment) GetTraceId 

func (x *SocketStreamedTraceSegment) GetTraceId() uint64

func (*SocketStreamedTraceSegment) HasConnection 

func (x *SocketStreamedTraceSegment) HasConnection() bool

func (*SocketStreamedTraceSegment) HasEvent 

func (x *SocketStreamedTraceSegment) HasEvent() bool

func (*SocketStreamedTraceSegment) HasMessagePiece 

func (x *SocketStreamedTraceSegment) HasMessagePiece() bool

func (*SocketStreamedTraceSegment) ProtoMessage 

func (*SocketStreamedTraceSegment) ProtoMessage()

func (*SocketStreamedTraceSegment) ProtoReflect 

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

func (*SocketStreamedTraceSegment) Reset 

func (x *SocketStreamedTraceSegment) Reset()

func (*SocketStreamedTraceSegment) SetConnection 

func (x *SocketStreamedTraceSegment) SetConnection(v *Connection)

func (*SocketStreamedTraceSegment) SetEvent 

func (x *SocketStreamedTraceSegment) SetEvent(v *SocketEvent)

func (*SocketStreamedTraceSegment) SetTraceId 

func (x *SocketStreamedTraceSegment) SetTraceId(v uint64)

func (*SocketStreamedTraceSegment) String 

func (x *SocketStreamedTraceSegment) String() string

func (*SocketStreamedTraceSegment) WhichMessagePiece 

func (x *SocketStreamedTraceSegment) WhichMessagePiece() case_SocketStreamedTraceSegment_MessagePiece

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 SocketStreamedTraceSegment_builder 

type SocketStreamedTraceSegment_builder 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
	// Fields of oneof MessagePiece:
	// Connection properties.
	Connection *Connection
	// Socket event.
	Event *SocketEvent
	// contains filtered or unexported fields
}

func (SocketStreamedTraceSegment_builder) Build 

func (b0 SocketStreamedTraceSegment_builder) Build() *SocketStreamedTraceSegment

type TraceWrapper 

type TraceWrapper struct {

	// Types that are valid to be assigned 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) ClearHttpBufferedTrace 

func (x *TraceWrapper) ClearHttpBufferedTrace()

func (*TraceWrapper) ClearHttpStreamedTraceSegment 

func (x *TraceWrapper) ClearHttpStreamedTraceSegment()

func (*TraceWrapper) ClearSocketBufferedTrace 

func (x *TraceWrapper) ClearSocketBufferedTrace()

func (*TraceWrapper) ClearSocketStreamedTraceSegment 

func (x *TraceWrapper) ClearSocketStreamedTraceSegment()

func (*TraceWrapper) ClearTrace 

func (x *TraceWrapper) ClearTrace()

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 (x *TraceWrapper) GetTrace() isTraceWrapper_Trace

func (*TraceWrapper) HasHttpBufferedTrace 

func (x *TraceWrapper) HasHttpBufferedTrace() bool

func (*TraceWrapper) HasHttpStreamedTraceSegment 

func (x *TraceWrapper) HasHttpStreamedTraceSegment() bool

func (*TraceWrapper) HasSocketBufferedTrace 

func (x *TraceWrapper) HasSocketBufferedTrace() bool

func (*TraceWrapper) HasSocketStreamedTraceSegment 

func (x *TraceWrapper) HasSocketStreamedTraceSegment() bool

func (*TraceWrapper) HasTrace 

func (x *TraceWrapper) HasTrace() bool

func (*TraceWrapper) ProtoMessage 

func (*TraceWrapper) ProtoMessage()

func (*TraceWrapper) ProtoReflect 

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

func (*TraceWrapper) Reset 

func (x *TraceWrapper) Reset()

func (*TraceWrapper) SetHttpBufferedTrace 

func (x *TraceWrapper) SetHttpBufferedTrace(v *HttpBufferedTrace)

func (*TraceWrapper) SetHttpStreamedTraceSegment 

func (x *TraceWrapper) SetHttpStreamedTraceSegment(v *HttpStreamedTraceSegment)

func (*TraceWrapper) SetSocketBufferedTrace 

func (x *TraceWrapper) SetSocketBufferedTrace(v *SocketBufferedTrace)

func (*TraceWrapper) SetSocketStreamedTraceSegment 

func (x *TraceWrapper) SetSocketStreamedTraceSegment(v *SocketStreamedTraceSegment)

func (*TraceWrapper) String 

func (x *TraceWrapper) String() string

func (*TraceWrapper) WhichTrace 

func (x *TraceWrapper) WhichTrace() case_TraceWrapper_Trace

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"`
}

type TraceWrapper_builder 

type TraceWrapper_builder struct {

	// Fields of oneof Trace:
	// An HTTP buffered tap trace.
	HttpBufferedTrace *HttpBufferedTrace
	// An HTTP streamed tap trace segment.
	HttpStreamedTraceSegment *HttpStreamedTraceSegment
	// A socket buffered tap trace.
	SocketBufferedTrace *SocketBufferedTrace
	// A socket streamed tap trace segment.
	SocketStreamedTraceSegment *SocketStreamedTraceSegment
	// contains filtered or unexported fields
}

func (TraceWrapper_builder) Build 

func (b0 TraceWrapper_builder) Build() *TraceWrapper

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.