envoy_data_tap_v2alpha

package
v1.5.0-citest.1 Latest Latest
Warning

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

 Go to latest Published: Jun 1, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCommon        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCommon          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCommon = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthHttp        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHttp          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHttp = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTransport        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTransport          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTransport = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWrapper        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWrapper          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWrapper = fmt.Errorf("proto: unexpected end of group")
)

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Wrapper for tapped body data. This includes HTTP request/response body, transport socket received and transmitted data, etc.

func (*Body) Descriptor 

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

func (*Body) GetAsBytes 

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

func (*Body) GetAsString 

func (m *Body) GetAsString() string

func (*Body) GetBodyType 

func (m *Body) GetBodyType() isBody_BodyType

func (*Body) GetTruncated 

func (m *Body) GetTruncated() bool

func (*Body) Marshal 

func (m *Body) Marshal() (dAtA []byte, err error)

func (*Body) MarshalTo 

func (m *Body) MarshalTo(dAtA []byte) (int, error)

func (*Body) MarshalToSizedBuffer 

func (m *Body) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Body) ProtoMessage 

func (*Body) ProtoMessage()

func (*Body) Reset 

func (m *Body) Reset()

func (*Body) Size 

func (m *Body) Size() (n int)

func (*Body) String 

func (m *Body) String() string

func (*Body) Unmarshal 

func (m *Body) Unmarshal(dAtA []byte) error

func (*Body) Validate 

func (m *Body) Validate() error

Validate checks the field values on Body with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Body) XXX_DiscardUnknown 

func (m *Body) XXX_DiscardUnknown()

func (*Body) XXX_Marshal 

func (m *Body) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Body) XXX_Merge 

func (m *Body) XXX_Merge(src proto.Message)

func (*Body) XXX_OneofWrappers 

func (*Body) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Body) XXX_Size 

func (m *Body) XXX_Size() int

func (*Body) XXX_Unmarshal 

func (m *Body) XXX_Unmarshal(b []byte) error

type BodyValidationError 

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

BodyValidationError is the validation error returned by Body.Validate if the designated constraints aren't met.

func (BodyValidationError) Cause 

func (e BodyValidationError) Cause() error

Cause function returns cause value.

func (BodyValidationError) Error 

func (e BodyValidationError) Error() string

Error satisfies the builtin error interface

func (BodyValidationError) ErrorName 

func (e BodyValidationError) ErrorName() string

ErrorName returns error name.

func (BodyValidationError) Field 

func (e BodyValidationError) Field() string

Field function returns field value.

func (BodyValidationError) Key 

func (e BodyValidationError) Key() bool

Key function returns key value.

func (BodyValidationError) Reason 

func (e BodyValidationError) Reason() string

Reason function returns reason value.

type Body_AsBytes 

type Body_AsBytes struct {
	AsBytes []byte `protobuf:"bytes,1,opt,name=as_bytes,json=asBytes,proto3,oneof" json:"as_bytes,omitempty"`
}

func (*Body_AsBytes) MarshalTo 

func (m *Body_AsBytes) MarshalTo(dAtA []byte) (int, error)

func (*Body_AsBytes) MarshalToSizedBuffer 

func (m *Body_AsBytes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Body_AsBytes) Size 

func (m *Body_AsBytes) Size() (n int)

type Body_AsString 

type Body_AsString struct {
	AsString string `protobuf:"bytes,2,opt,name=as_string,json=asString,proto3,oneof" json:"as_string,omitempty"`
}

func (*Body_AsString) MarshalTo 

func (m *Body_AsString) MarshalTo(dAtA []byte) (int, error)

func (*Body_AsString) MarshalToSizedBuffer 

func (m *Body_AsString) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Body_AsString) Size 

func (m *Body_AsString) Size() (n int)

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Connection properties.

func (*Connection) Descriptor 

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

func (*Connection) GetLocalAddress 

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

func (*Connection) GetRemoteAddress 

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

func (*Connection) Marshal 

func (m *Connection) Marshal() (dAtA []byte, err error)

func (*Connection) MarshalTo 

func (m *Connection) MarshalTo(dAtA []byte) (int, error)

func (*Connection) MarshalToSizedBuffer 

func (m *Connection) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) Reset 

func (m *Connection) Reset()

func (*Connection) Size 

func (m *Connection) Size() (n int)

func (*Connection) String 

func (m *Connection) String() string

func (*Connection) Unmarshal 

func (m *Connection) Unmarshal(dAtA []byte) error

func (*Connection) Validate 

func (m *Connection) Validate() error

Validate checks the field values on Connection with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Connection) XXX_DiscardUnknown 

func (m *Connection) XXX_DiscardUnknown()

func (*Connection) XXX_Marshal 

func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connection) XXX_Merge 

func (m *Connection) XXX_Merge(src proto.Message)

func (*Connection) XXX_Size 

func (m *Connection) XXX_Size() int

func (*Connection) XXX_Unmarshal 

func (m *Connection) XXX_Unmarshal(b []byte) error

type ConnectionValidationError 

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

ConnectionValidationError is the validation error returned by Connection.Validate if the designated constraints aren't met.

func (ConnectionValidationError) Cause 

func (e ConnectionValidationError) Cause() error

Cause function returns cause value.

func (ConnectionValidationError) Error 

func (e ConnectionValidationError) Error() string

Error satisfies the builtin error interface

func (ConnectionValidationError) ErrorName 

func (e ConnectionValidationError) ErrorName() string

ErrorName returns error name.

func (ConnectionValidationError) Field 

func (e ConnectionValidationError) Field() string

Field function returns field value.

func (ConnectionValidationError) Key 

func (e ConnectionValidationError) Key() bool

Key function returns key value.

func (ConnectionValidationError) Reason 

func (e ConnectionValidationError) Reason() string

Reason function returns reason value.

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

A fully buffered HTTP trace message.

func (*HttpBufferedTrace) Descriptor 

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

func (*HttpBufferedTrace) GetRequest 

func (m *HttpBufferedTrace) GetRequest() *HttpBufferedTrace_Message

func (*HttpBufferedTrace) GetResponse 

func (m *HttpBufferedTrace) GetResponse() *HttpBufferedTrace_Message

func (*HttpBufferedTrace) Marshal 

func (m *HttpBufferedTrace) Marshal() (dAtA []byte, err error)

func (*HttpBufferedTrace) MarshalTo 

func (m *HttpBufferedTrace) MarshalTo(dAtA []byte) (int, error)

func (*HttpBufferedTrace) MarshalToSizedBuffer 

func (m *HttpBufferedTrace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpBufferedTrace) ProtoMessage 

func (*HttpBufferedTrace) ProtoMessage()

func (*HttpBufferedTrace) Reset 

func (m *HttpBufferedTrace) Reset()

func (*HttpBufferedTrace) Size 

func (m *HttpBufferedTrace) Size() (n int)

func (*HttpBufferedTrace) String 

func (m *HttpBufferedTrace) String() string

func (*HttpBufferedTrace) Unmarshal 

func (m *HttpBufferedTrace) Unmarshal(dAtA []byte) error

func (*HttpBufferedTrace) Validate 

func (m *HttpBufferedTrace) Validate() error

Validate checks the field values on HttpBufferedTrace with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*HttpBufferedTrace) XXX_DiscardUnknown 

func (m *HttpBufferedTrace) XXX_DiscardUnknown()

func (*HttpBufferedTrace) XXX_Marshal 

func (m *HttpBufferedTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpBufferedTrace) XXX_Merge 

func (m *HttpBufferedTrace) XXX_Merge(src proto.Message)

func (*HttpBufferedTrace) XXX_Size 

func (m *HttpBufferedTrace) XXX_Size() int

func (*HttpBufferedTrace) XXX_Unmarshal 

func (m *HttpBufferedTrace) XXX_Unmarshal(b []byte) error

type HttpBufferedTraceValidationError 

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

HttpBufferedTraceValidationError is the validation error returned by HttpBufferedTrace.Validate if the designated constraints aren't met.

func (HttpBufferedTraceValidationError) Cause 

func (e HttpBufferedTraceValidationError) Cause() error

Cause function returns cause value.

func (HttpBufferedTraceValidationError) Error 

func (e HttpBufferedTraceValidationError) Error() string

Error satisfies the builtin error interface

func (HttpBufferedTraceValidationError) ErrorName 

func (e HttpBufferedTraceValidationError) ErrorName() string

ErrorName returns error name.

func (HttpBufferedTraceValidationError) Field 

func (e HttpBufferedTraceValidationError) Field() string

Field function returns field value.

func (HttpBufferedTraceValidationError) Key 

func (e HttpBufferedTraceValidationError) Key() bool

Key function returns key value.

func (HttpBufferedTraceValidationError) Reason 

func (e HttpBufferedTraceValidationError) Reason() string

Reason function returns reason value.

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

HTTP message wrapper.

func (*HttpBufferedTrace_Message) Descriptor 

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

func (*HttpBufferedTrace_Message) GetBody 

func (m *HttpBufferedTrace_Message) GetBody() *Body

func (*HttpBufferedTrace_Message) GetHeaders 

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

func (*HttpBufferedTrace_Message) GetTrailers 

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

func (*HttpBufferedTrace_Message) Marshal 

func (m *HttpBufferedTrace_Message) Marshal() (dAtA []byte, err error)

func (*HttpBufferedTrace_Message) MarshalTo 

func (m *HttpBufferedTrace_Message) MarshalTo(dAtA []byte) (int, error)

func (*HttpBufferedTrace_Message) MarshalToSizedBuffer 

func (m *HttpBufferedTrace_Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpBufferedTrace_Message) ProtoMessage 

func (*HttpBufferedTrace_Message) ProtoMessage()

func (*HttpBufferedTrace_Message) Reset 

func (m *HttpBufferedTrace_Message) Reset()

func (*HttpBufferedTrace_Message) Size 

func (m *HttpBufferedTrace_Message) Size() (n int)

func (*HttpBufferedTrace_Message) String 

func (m *HttpBufferedTrace_Message) String() string

func (*HttpBufferedTrace_Message) Unmarshal 

func (m *HttpBufferedTrace_Message) Unmarshal(dAtA []byte) error

func (*HttpBufferedTrace_Message) Validate 

func (m *HttpBufferedTrace_Message) Validate() error

Validate checks the field values on HttpBufferedTrace_Message with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*HttpBufferedTrace_Message) XXX_DiscardUnknown 

func (m *HttpBufferedTrace_Message) XXX_DiscardUnknown()

func (*HttpBufferedTrace_Message) XXX_Marshal 

func (m *HttpBufferedTrace_Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpBufferedTrace_Message) XXX_Merge 

func (m *HttpBufferedTrace_Message) XXX_Merge(src proto.Message)

func (*HttpBufferedTrace_Message) XXX_Size 

func (m *HttpBufferedTrace_Message) XXX_Size() int

func (*HttpBufferedTrace_Message) XXX_Unmarshal 

func (m *HttpBufferedTrace_Message) XXX_Unmarshal(b []byte) error

type HttpBufferedTrace_MessageValidationError 

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

HttpBufferedTrace_MessageValidationError is the validation error returned by HttpBufferedTrace_Message.Validate if the designated constraints aren't met.

func (HttpBufferedTrace_MessageValidationError) Cause 

func (e HttpBufferedTrace_MessageValidationError) Cause() error

Cause function returns cause value.

func (HttpBufferedTrace_MessageValidationError) Error 

func (e HttpBufferedTrace_MessageValidationError) Error() string

Error satisfies the builtin error interface

func (HttpBufferedTrace_MessageValidationError) ErrorName 

func (e HttpBufferedTrace_MessageValidationError) ErrorName() string

ErrorName returns error name.

func (HttpBufferedTrace_MessageValidationError) Field 

func (e HttpBufferedTrace_MessageValidationError) Field() string

Field function returns field value.

func (HttpBufferedTrace_MessageValidationError) Key 

func (e HttpBufferedTrace_MessageValidationError) Key() bool

Key function returns key value.

func (HttpBufferedTrace_MessageValidationError) Reason 

func (e HttpBufferedTrace_MessageValidationError) Reason() string

Reason function returns reason value.

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"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

A streamed HTTP trace segment. Multiple segments make up a full trace. [#next-free-field: 8]

func (*HttpStreamedTraceSegment) Descriptor 

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

func (*HttpStreamedTraceSegment) GetMessagePiece 

func (m *HttpStreamedTraceSegment) GetMessagePiece() isHttpStreamedTraceSegment_MessagePiece

func (*HttpStreamedTraceSegment) GetRequestBodyChunk 

func (m *HttpStreamedTraceSegment) GetRequestBodyChunk() *Body

func (*HttpStreamedTraceSegment) GetRequestHeaders 

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

func (*HttpStreamedTraceSegment) GetRequestTrailers 

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

func (*HttpStreamedTraceSegment) GetResponseBodyChunk 

func (m *HttpStreamedTraceSegment) GetResponseBodyChunk() *Body

func (*HttpStreamedTraceSegment) GetResponseHeaders 

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

func (*HttpStreamedTraceSegment) GetResponseTrailers 

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

func (*HttpStreamedTraceSegment) GetTraceId 

func (m *HttpStreamedTraceSegment) GetTraceId() uint64

func (*HttpStreamedTraceSegment) Marshal 

func (m *HttpStreamedTraceSegment) Marshal() (dAtA []byte, err error)

func (*HttpStreamedTraceSegment) MarshalTo 

func (m *HttpStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment) MarshalToSizedBuffer 

func (m *HttpStreamedTraceSegment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment) ProtoMessage 

func (*HttpStreamedTraceSegment) ProtoMessage()

func (*HttpStreamedTraceSegment) Reset 

func (m *HttpStreamedTraceSegment) Reset()

func (*HttpStreamedTraceSegment) Size 

func (m *HttpStreamedTraceSegment) Size() (n int)

func (*HttpStreamedTraceSegment) String 

func (m *HttpStreamedTraceSegment) String() string

func (*HttpStreamedTraceSegment) Unmarshal 

func (m *HttpStreamedTraceSegment) Unmarshal(dAtA []byte) error

func (*HttpStreamedTraceSegment) Validate 

func (m *HttpStreamedTraceSegment) Validate() error

Validate checks the field values on HttpStreamedTraceSegment with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*HttpStreamedTraceSegment) XXX_DiscardUnknown 

func (m *HttpStreamedTraceSegment) XXX_DiscardUnknown()

func (*HttpStreamedTraceSegment) XXX_Marshal 

func (m *HttpStreamedTraceSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpStreamedTraceSegment) XXX_Merge 

func (m *HttpStreamedTraceSegment) XXX_Merge(src proto.Message)

func (*HttpStreamedTraceSegment) XXX_OneofWrappers 

func (*HttpStreamedTraceSegment) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*HttpStreamedTraceSegment) XXX_Size 

func (m *HttpStreamedTraceSegment) XXX_Size() int

func (*HttpStreamedTraceSegment) XXX_Unmarshal 

func (m *HttpStreamedTraceSegment) XXX_Unmarshal(b []byte) error

type HttpStreamedTraceSegmentValidationError 

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

HttpStreamedTraceSegmentValidationError is the validation error returned by HttpStreamedTraceSegment.Validate if the designated constraints aren't met.

func (HttpStreamedTraceSegmentValidationError) Cause 

func (e HttpStreamedTraceSegmentValidationError) Cause() error

Cause function returns cause value.

func (HttpStreamedTraceSegmentValidationError) Error 

func (e HttpStreamedTraceSegmentValidationError) Error() string

Error satisfies the builtin error interface

func (HttpStreamedTraceSegmentValidationError) ErrorName 

func (e HttpStreamedTraceSegmentValidationError) ErrorName() string

ErrorName returns error name.

func (HttpStreamedTraceSegmentValidationError) Field 

func (e HttpStreamedTraceSegmentValidationError) Field() string

Field function returns field value.

func (HttpStreamedTraceSegmentValidationError) Key 

func (e HttpStreamedTraceSegmentValidationError) Key() bool

Key function returns key value.

func (HttpStreamedTraceSegmentValidationError) Reason 

func (e HttpStreamedTraceSegmentValidationError) Reason() string

Reason function returns reason value.

type HttpStreamedTraceSegment_RequestBodyChunk 

type HttpStreamedTraceSegment_RequestBodyChunk struct {
	RequestBodyChunk *Body `protobuf:"bytes,3,opt,name=request_body_chunk,json=requestBodyChunk,proto3,oneof" json:"request_body_chunk,omitempty"`
}

func (*HttpStreamedTraceSegment_RequestBodyChunk) MarshalTo 

func (m *HttpStreamedTraceSegment_RequestBodyChunk) MarshalTo(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_RequestBodyChunk) MarshalToSizedBuffer 

func (m *HttpStreamedTraceSegment_RequestBodyChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_RequestBodyChunk) Size 

func (m *HttpStreamedTraceSegment_RequestBodyChunk) Size() (n int)

type HttpStreamedTraceSegment_RequestHeaders 

type HttpStreamedTraceSegment_RequestHeaders struct {
	RequestHeaders *core.HeaderMap `protobuf:"bytes,2,opt,name=request_headers,json=requestHeaders,proto3,oneof" json:"request_headers,omitempty"`
}

func (*HttpStreamedTraceSegment_RequestHeaders) MarshalTo 

func (m *HttpStreamedTraceSegment_RequestHeaders) MarshalTo(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_RequestHeaders) MarshalToSizedBuffer 

func (m *HttpStreamedTraceSegment_RequestHeaders) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_RequestHeaders) Size 

func (m *HttpStreamedTraceSegment_RequestHeaders) Size() (n int)

type HttpStreamedTraceSegment_RequestTrailers 

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

func (*HttpStreamedTraceSegment_RequestTrailers) MarshalTo 

func (m *HttpStreamedTraceSegment_RequestTrailers) MarshalTo(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_RequestTrailers) MarshalToSizedBuffer 

func (m *HttpStreamedTraceSegment_RequestTrailers) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_RequestTrailers) Size 

func (m *HttpStreamedTraceSegment_RequestTrailers) Size() (n int)

type HttpStreamedTraceSegment_ResponseBodyChunk 

type HttpStreamedTraceSegment_ResponseBodyChunk struct {
	ResponseBodyChunk *Body `protobuf:"bytes,6,opt,name=response_body_chunk,json=responseBodyChunk,proto3,oneof" json:"response_body_chunk,omitempty"`
}

func (*HttpStreamedTraceSegment_ResponseBodyChunk) MarshalTo 

func (m *HttpStreamedTraceSegment_ResponseBodyChunk) MarshalTo(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_ResponseBodyChunk) MarshalToSizedBuffer 

func (m *HttpStreamedTraceSegment_ResponseBodyChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_ResponseBodyChunk) Size 

func (m *HttpStreamedTraceSegment_ResponseBodyChunk) Size() (n int)

type HttpStreamedTraceSegment_ResponseHeaders 

type HttpStreamedTraceSegment_ResponseHeaders struct {
	ResponseHeaders *core.HeaderMap `protobuf:"bytes,5,opt,name=response_headers,json=responseHeaders,proto3,oneof" json:"response_headers,omitempty"`
}

func (*HttpStreamedTraceSegment_ResponseHeaders) MarshalTo 

func (m *HttpStreamedTraceSegment_ResponseHeaders) MarshalTo(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_ResponseHeaders) MarshalToSizedBuffer 

func (m *HttpStreamedTraceSegment_ResponseHeaders) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_ResponseHeaders) Size 

func (m *HttpStreamedTraceSegment_ResponseHeaders) Size() (n int)

type HttpStreamedTraceSegment_ResponseTrailers 

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

func (*HttpStreamedTraceSegment_ResponseTrailers) MarshalTo 

func (m *HttpStreamedTraceSegment_ResponseTrailers) MarshalTo(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_ResponseTrailers) MarshalToSizedBuffer 

func (m *HttpStreamedTraceSegment_ResponseTrailers) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpStreamedTraceSegment_ResponseTrailers) Size 

func (m *HttpStreamedTraceSegment_ResponseTrailers) Size() (n int)

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sequence of read/write events that constitute a buffered trace on a socket. [#next-free-field: 6]

func (*SocketBufferedTrace) Descriptor 

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

func (*SocketBufferedTrace) GetConnection 

func (m *SocketBufferedTrace) GetConnection() *Connection

func (*SocketBufferedTrace) GetEvents 

func (m *SocketBufferedTrace) GetEvents() []*SocketEvent

func (*SocketBufferedTrace) GetReadTruncated 

func (m *SocketBufferedTrace) GetReadTruncated() bool

func (*SocketBufferedTrace) GetTraceId 

func (m *SocketBufferedTrace) GetTraceId() uint64

func (*SocketBufferedTrace) GetWriteTruncated 

func (m *SocketBufferedTrace) GetWriteTruncated() bool

func (*SocketBufferedTrace) Marshal 

func (m *SocketBufferedTrace) Marshal() (dAtA []byte, err error)

func (*SocketBufferedTrace) MarshalTo 

func (m *SocketBufferedTrace) MarshalTo(dAtA []byte) (int, error)

func (*SocketBufferedTrace) MarshalToSizedBuffer 

func (m *SocketBufferedTrace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketBufferedTrace) ProtoMessage 

func (*SocketBufferedTrace) ProtoMessage()

func (*SocketBufferedTrace) Reset 

func (m *SocketBufferedTrace) Reset()

func (*SocketBufferedTrace) Size 

func (m *SocketBufferedTrace) Size() (n int)

func (*SocketBufferedTrace) String 

func (m *SocketBufferedTrace) String() string

func (*SocketBufferedTrace) Unmarshal 

func (m *SocketBufferedTrace) Unmarshal(dAtA []byte) error

func (*SocketBufferedTrace) Validate 

func (m *SocketBufferedTrace) Validate() error

Validate checks the field values on SocketBufferedTrace with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SocketBufferedTrace) XXX_DiscardUnknown 

func (m *SocketBufferedTrace) XXX_DiscardUnknown()

func (*SocketBufferedTrace) XXX_Marshal 

func (m *SocketBufferedTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketBufferedTrace) XXX_Merge 

func (m *SocketBufferedTrace) XXX_Merge(src proto.Message)

func (*SocketBufferedTrace) XXX_Size 

func (m *SocketBufferedTrace) XXX_Size() int

func (*SocketBufferedTrace) XXX_Unmarshal 

func (m *SocketBufferedTrace) XXX_Unmarshal(b []byte) error

type SocketBufferedTraceValidationError 

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

SocketBufferedTraceValidationError is the validation error returned by SocketBufferedTrace.Validate if the designated constraints aren't met.

func (SocketBufferedTraceValidationError) Cause 

func (e SocketBufferedTraceValidationError) Cause() error

Cause function returns cause value.

func (SocketBufferedTraceValidationError) Error 

func (e SocketBufferedTraceValidationError) Error() string

Error satisfies the builtin error interface

func (SocketBufferedTraceValidationError) ErrorName 

func (e SocketBufferedTraceValidationError) ErrorName() string

ErrorName returns error name.

func (SocketBufferedTraceValidationError) Field 

func (e SocketBufferedTraceValidationError) Field() string

Field function returns field value.

func (SocketBufferedTraceValidationError) Key 

func (e SocketBufferedTraceValidationError) Key() bool

Key function returns key value.

func (SocketBufferedTraceValidationError) Reason 

func (e SocketBufferedTraceValidationError) Reason() string

Reason function returns reason value.

type SocketEvent 

type SocketEvent struct {
	// Timestamp for event.
	Timestamp *types.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"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Event in a socket trace.

func (*SocketEvent) Descriptor 

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

func (*SocketEvent) GetClosed 

func (m *SocketEvent) GetClosed() *SocketEvent_Closed

func (*SocketEvent) GetEventSelector 

func (m *SocketEvent) GetEventSelector() isSocketEvent_EventSelector

func (*SocketEvent) GetRead 

func (m *SocketEvent) GetRead() *SocketEvent_Read

func (*SocketEvent) GetTimestamp 

func (m *SocketEvent) GetTimestamp() *types.Timestamp

func (*SocketEvent) GetWrite 

func (m *SocketEvent) GetWrite() *SocketEvent_Write

func (*SocketEvent) Marshal 

func (m *SocketEvent) Marshal() (dAtA []byte, err error)

func (*SocketEvent) MarshalTo 

func (m *SocketEvent) MarshalTo(dAtA []byte) (int, error)

func (*SocketEvent) MarshalToSizedBuffer 

func (m *SocketEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketEvent) ProtoMessage 

func (*SocketEvent) ProtoMessage()

func (*SocketEvent) Reset 

func (m *SocketEvent) Reset()

func (*SocketEvent) Size 

func (m *SocketEvent) Size() (n int)

func (*SocketEvent) String 

func (m *SocketEvent) String() string

func (*SocketEvent) Unmarshal 

func (m *SocketEvent) Unmarshal(dAtA []byte) error

func (*SocketEvent) Validate 

func (m *SocketEvent) Validate() error

Validate checks the field values on SocketEvent with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SocketEvent) XXX_DiscardUnknown 

func (m *SocketEvent) XXX_DiscardUnknown()

func (*SocketEvent) XXX_Marshal 

func (m *SocketEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketEvent) XXX_Merge 

func (m *SocketEvent) XXX_Merge(src proto.Message)

func (*SocketEvent) XXX_OneofWrappers 

func (*SocketEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SocketEvent) XXX_Size 

func (m *SocketEvent) XXX_Size() int

func (*SocketEvent) XXX_Unmarshal 

func (m *SocketEvent) XXX_Unmarshal(b []byte) error

type SocketEventValidationError 

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

SocketEventValidationError is the validation error returned by SocketEvent.Validate if the designated constraints aren't met.

func (SocketEventValidationError) Cause 

func (e SocketEventValidationError) Cause() error

Cause function returns cause value.

func (SocketEventValidationError) Error 

func (e SocketEventValidationError) Error() string

Error satisfies the builtin error interface

func (SocketEventValidationError) ErrorName 

func (e SocketEventValidationError) ErrorName() string

ErrorName returns error name.

func (SocketEventValidationError) Field 

func (e SocketEventValidationError) Field() string

Field function returns field value.

func (SocketEventValidationError) Key 

func (e SocketEventValidationError) Key() bool

Key function returns key value.

func (SocketEventValidationError) Reason 

func (e SocketEventValidationError) Reason() string

Reason function returns reason value.

type SocketEvent_Closed 

type SocketEvent_Closed struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The connection was closed.

func (*SocketEvent_Closed) Descriptor 

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

func (*SocketEvent_Closed) Marshal 

func (m *SocketEvent_Closed) Marshal() (dAtA []byte, err error)

func (*SocketEvent_Closed) MarshalTo 

func (m *SocketEvent_Closed) MarshalTo(dAtA []byte) (int, error)

func (*SocketEvent_Closed) MarshalToSizedBuffer 

func (m *SocketEvent_Closed) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketEvent_Closed) ProtoMessage 

func (*SocketEvent_Closed) ProtoMessage()

func (*SocketEvent_Closed) Reset 

func (m *SocketEvent_Closed) Reset()

func (*SocketEvent_Closed) Size 

func (m *SocketEvent_Closed) Size() (n int)

func (*SocketEvent_Closed) String 

func (m *SocketEvent_Closed) String() string

func (*SocketEvent_Closed) Unmarshal 

func (m *SocketEvent_Closed) Unmarshal(dAtA []byte) error

func (*SocketEvent_Closed) Validate 

func (m *SocketEvent_Closed) Validate() error

Validate checks the field values on SocketEvent_Closed with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SocketEvent_Closed) XXX_DiscardUnknown 

func (m *SocketEvent_Closed) XXX_DiscardUnknown()

func (*SocketEvent_Closed) XXX_Marshal 

func (m *SocketEvent_Closed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketEvent_Closed) XXX_Merge 

func (m *SocketEvent_Closed) XXX_Merge(src proto.Message)

func (*SocketEvent_Closed) XXX_Size 

func (m *SocketEvent_Closed) XXX_Size() int

func (*SocketEvent_Closed) XXX_Unmarshal 

func (m *SocketEvent_Closed) XXX_Unmarshal(b []byte) error

type SocketEvent_ClosedValidationError 

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

SocketEvent_ClosedValidationError is the validation error returned by SocketEvent_Closed.Validate if the designated constraints aren't met.

func (SocketEvent_ClosedValidationError) Cause 

func (e SocketEvent_ClosedValidationError) Cause() error

Cause function returns cause value.

func (SocketEvent_ClosedValidationError) Error 

func (e SocketEvent_ClosedValidationError) Error() string

Error satisfies the builtin error interface

func (SocketEvent_ClosedValidationError) ErrorName 

func (e SocketEvent_ClosedValidationError) ErrorName() string

ErrorName returns error name.

func (SocketEvent_ClosedValidationError) Field 

func (e SocketEvent_ClosedValidationError) Field() string

Field function returns field value.

func (SocketEvent_ClosedValidationError) Key 

func (e SocketEvent_ClosedValidationError) Key() bool

Key function returns key value.

func (SocketEvent_ClosedValidationError) Reason 

func (e SocketEvent_ClosedValidationError) Reason() string

Reason function returns reason value.

type SocketEvent_Closed_ 

type SocketEvent_Closed_ struct {
	Closed *SocketEvent_Closed `protobuf:"bytes,4,opt,name=closed,proto3,oneof" json:"closed,omitempty"`
}

func (*SocketEvent_Closed_) MarshalTo 

func (m *SocketEvent_Closed_) MarshalTo(dAtA []byte) (int, error)

func (*SocketEvent_Closed_) MarshalToSizedBuffer 

func (m *SocketEvent_Closed_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketEvent_Closed_) Size 

func (m *SocketEvent_Closed_) Size() (n int)

type SocketEvent_Read 

type SocketEvent_Read struct {
	// Binary data read.
	Data                 *Body    `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Data read by Envoy from the transport socket.

func (*SocketEvent_Read) Descriptor 

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

func (*SocketEvent_Read) GetData 

func (m *SocketEvent_Read) GetData() *Body

func (*SocketEvent_Read) Marshal 

func (m *SocketEvent_Read) Marshal() (dAtA []byte, err error)

func (*SocketEvent_Read) MarshalTo 

func (m *SocketEvent_Read) MarshalTo(dAtA []byte) (int, error)

func (*SocketEvent_Read) MarshalToSizedBuffer 

func (m *SocketEvent_Read) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketEvent_Read) ProtoMessage 

func (*SocketEvent_Read) ProtoMessage()

func (*SocketEvent_Read) Reset 

func (m *SocketEvent_Read) Reset()

func (*SocketEvent_Read) Size 

func (m *SocketEvent_Read) Size() (n int)

func (*SocketEvent_Read) String 

func (m *SocketEvent_Read) String() string

func (*SocketEvent_Read) Unmarshal 

func (m *SocketEvent_Read) Unmarshal(dAtA []byte) error

func (*SocketEvent_Read) Validate 

func (m *SocketEvent_Read) Validate() error

Validate checks the field values on SocketEvent_Read with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SocketEvent_Read) XXX_DiscardUnknown 

func (m *SocketEvent_Read) XXX_DiscardUnknown()

func (*SocketEvent_Read) XXX_Marshal 

func (m *SocketEvent_Read) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketEvent_Read) XXX_Merge 

func (m *SocketEvent_Read) XXX_Merge(src proto.Message)

func (*SocketEvent_Read) XXX_Size 

func (m *SocketEvent_Read) XXX_Size() int

func (*SocketEvent_Read) XXX_Unmarshal 

func (m *SocketEvent_Read) XXX_Unmarshal(b []byte) error

type SocketEvent_ReadValidationError 

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

SocketEvent_ReadValidationError is the validation error returned by SocketEvent_Read.Validate if the designated constraints aren't met.

func (SocketEvent_ReadValidationError) Cause 

func (e SocketEvent_ReadValidationError) Cause() error

Cause function returns cause value.

func (SocketEvent_ReadValidationError) Error 

func (e SocketEvent_ReadValidationError) Error() string

Error satisfies the builtin error interface

func (SocketEvent_ReadValidationError) ErrorName 

func (e SocketEvent_ReadValidationError) ErrorName() string

ErrorName returns error name.

func (SocketEvent_ReadValidationError) Field 

func (e SocketEvent_ReadValidationError) Field() string

Field function returns field value.

func (SocketEvent_ReadValidationError) Key 

func (e SocketEvent_ReadValidationError) Key() bool

Key function returns key value.

func (SocketEvent_ReadValidationError) Reason 

func (e SocketEvent_ReadValidationError) Reason() string

Reason function returns reason value.

type SocketEvent_Read_ 

type SocketEvent_Read_ struct {
	Read *SocketEvent_Read `protobuf:"bytes,2,opt,name=read,proto3,oneof" json:"read,omitempty"`
}

func (*SocketEvent_Read_) MarshalTo 

func (m *SocketEvent_Read_) MarshalTo(dAtA []byte) (int, error)

func (*SocketEvent_Read_) MarshalToSizedBuffer 

func (m *SocketEvent_Read_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketEvent_Read_) Size 

func (m *SocketEvent_Read_) Size() (n int)

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Data written by Envoy to the transport socket.

func (*SocketEvent_Write) Descriptor 

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

func (*SocketEvent_Write) GetData 

func (m *SocketEvent_Write) GetData() *Body

func (*SocketEvent_Write) GetEndStream 

func (m *SocketEvent_Write) GetEndStream() bool

func (*SocketEvent_Write) Marshal 

func (m *SocketEvent_Write) Marshal() (dAtA []byte, err error)

func (*SocketEvent_Write) MarshalTo 

func (m *SocketEvent_Write) MarshalTo(dAtA []byte) (int, error)

func (*SocketEvent_Write) MarshalToSizedBuffer 

func (m *SocketEvent_Write) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketEvent_Write) ProtoMessage 

func (*SocketEvent_Write) ProtoMessage()

func (*SocketEvent_Write) Reset 

func (m *SocketEvent_Write) Reset()

func (*SocketEvent_Write) Size 

func (m *SocketEvent_Write) Size() (n int)

func (*SocketEvent_Write) String 

func (m *SocketEvent_Write) String() string

func (*SocketEvent_Write) Unmarshal 

func (m *SocketEvent_Write) Unmarshal(dAtA []byte) error

func (*SocketEvent_Write) Validate 

func (m *SocketEvent_Write) Validate() error

Validate checks the field values on SocketEvent_Write with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SocketEvent_Write) XXX_DiscardUnknown 

func (m *SocketEvent_Write) XXX_DiscardUnknown()

func (*SocketEvent_Write) XXX_Marshal 

func (m *SocketEvent_Write) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketEvent_Write) XXX_Merge 

func (m *SocketEvent_Write) XXX_Merge(src proto.Message)

func (*SocketEvent_Write) XXX_Size 

func (m *SocketEvent_Write) XXX_Size() int

func (*SocketEvent_Write) XXX_Unmarshal 

func (m *SocketEvent_Write) XXX_Unmarshal(b []byte) error

type SocketEvent_WriteValidationError 

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

SocketEvent_WriteValidationError is the validation error returned by SocketEvent_Write.Validate if the designated constraints aren't met.

func (SocketEvent_WriteValidationError) Cause 

func (e SocketEvent_WriteValidationError) Cause() error

Cause function returns cause value.

func (SocketEvent_WriteValidationError) Error 

func (e SocketEvent_WriteValidationError) Error() string

Error satisfies the builtin error interface

func (SocketEvent_WriteValidationError) ErrorName 

func (e SocketEvent_WriteValidationError) ErrorName() string

ErrorName returns error name.

func (SocketEvent_WriteValidationError) Field 

func (e SocketEvent_WriteValidationError) Field() string

Field function returns field value.

func (SocketEvent_WriteValidationError) Key 

func (e SocketEvent_WriteValidationError) Key() bool

Key function returns key value.

func (SocketEvent_WriteValidationError) Reason 

func (e SocketEvent_WriteValidationError) Reason() string

Reason function returns reason value.

type SocketEvent_Write_ 

type SocketEvent_Write_ struct {
	Write *SocketEvent_Write `protobuf:"bytes,3,opt,name=write,proto3,oneof" json:"write,omitempty"`
}

func (*SocketEvent_Write_) MarshalTo 

func (m *SocketEvent_Write_) MarshalTo(dAtA []byte) (int, error)

func (*SocketEvent_Write_) MarshalToSizedBuffer 

func (m *SocketEvent_Write_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketEvent_Write_) Size 

func (m *SocketEvent_Write_) Size() (n int)

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"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

A streamed socket trace segment. Multiple segments make up a full trace.

func (*SocketStreamedTraceSegment) Descriptor 

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

func (*SocketStreamedTraceSegment) GetConnection 

func (m *SocketStreamedTraceSegment) GetConnection() *Connection

func (*SocketStreamedTraceSegment) GetEvent 

func (m *SocketStreamedTraceSegment) GetEvent() *SocketEvent

func (*SocketStreamedTraceSegment) GetMessagePiece 

func (m *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece

func (*SocketStreamedTraceSegment) GetTraceId 

func (m *SocketStreamedTraceSegment) GetTraceId() uint64

func (*SocketStreamedTraceSegment) Marshal 

func (m *SocketStreamedTraceSegment) Marshal() (dAtA []byte, err error)

func (*SocketStreamedTraceSegment) MarshalTo 

func (m *SocketStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)

func (*SocketStreamedTraceSegment) MarshalToSizedBuffer 

func (m *SocketStreamedTraceSegment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketStreamedTraceSegment) ProtoMessage 

func (*SocketStreamedTraceSegment) ProtoMessage()

func (*SocketStreamedTraceSegment) Reset 

func (m *SocketStreamedTraceSegment) Reset()

func (*SocketStreamedTraceSegment) Size 

func (m *SocketStreamedTraceSegment) Size() (n int)

func (*SocketStreamedTraceSegment) String 

func (m *SocketStreamedTraceSegment) String() string

func (*SocketStreamedTraceSegment) Unmarshal 

func (m *SocketStreamedTraceSegment) Unmarshal(dAtA []byte) error

func (*SocketStreamedTraceSegment) Validate 

func (m *SocketStreamedTraceSegment) Validate() error

Validate checks the field values on SocketStreamedTraceSegment with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SocketStreamedTraceSegment) XXX_DiscardUnknown 

func (m *SocketStreamedTraceSegment) XXX_DiscardUnknown()

func (*SocketStreamedTraceSegment) XXX_Marshal 

func (m *SocketStreamedTraceSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SocketStreamedTraceSegment) XXX_Merge 

func (m *SocketStreamedTraceSegment) XXX_Merge(src proto.Message)

func (*SocketStreamedTraceSegment) XXX_OneofWrappers 

func (*SocketStreamedTraceSegment) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SocketStreamedTraceSegment) XXX_Size 

func (m *SocketStreamedTraceSegment) XXX_Size() int

func (*SocketStreamedTraceSegment) XXX_Unmarshal 

func (m *SocketStreamedTraceSegment) XXX_Unmarshal(b []byte) error

type SocketStreamedTraceSegmentValidationError 

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

SocketStreamedTraceSegmentValidationError is the validation error returned by SocketStreamedTraceSegment.Validate if the designated constraints aren't met.

func (SocketStreamedTraceSegmentValidationError) Cause 

func (e SocketStreamedTraceSegmentValidationError) Cause() error

Cause function returns cause value.

func (SocketStreamedTraceSegmentValidationError) Error 

func (e SocketStreamedTraceSegmentValidationError) Error() string

Error satisfies the builtin error interface

func (SocketStreamedTraceSegmentValidationError) ErrorName 

func (e SocketStreamedTraceSegmentValidationError) ErrorName() string

ErrorName returns error name.

func (SocketStreamedTraceSegmentValidationError) Field 

func (e SocketStreamedTraceSegmentValidationError) Field() string

Field function returns field value.

func (SocketStreamedTraceSegmentValidationError) Key 

func (e SocketStreamedTraceSegmentValidationError) Key() bool

Key function returns key value.

func (SocketStreamedTraceSegmentValidationError) Reason 

func (e SocketStreamedTraceSegmentValidationError) Reason() string

Reason function returns reason value.

type SocketStreamedTraceSegment_Connection 

type SocketStreamedTraceSegment_Connection struct {
	Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3,oneof" json:"connection,omitempty"`
}

func (*SocketStreamedTraceSegment_Connection) MarshalTo 

func (m *SocketStreamedTraceSegment_Connection) MarshalTo(dAtA []byte) (int, error)

func (*SocketStreamedTraceSegment_Connection) MarshalToSizedBuffer 

func (m *SocketStreamedTraceSegment_Connection) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketStreamedTraceSegment_Connection) Size 

func (m *SocketStreamedTraceSegment_Connection) Size() (n int)

type SocketStreamedTraceSegment_Event 

type SocketStreamedTraceSegment_Event struct {
	Event *SocketEvent `protobuf:"bytes,3,opt,name=event,proto3,oneof" json:"event,omitempty"`
}

func (*SocketStreamedTraceSegment_Event) MarshalTo 

func (m *SocketStreamedTraceSegment_Event) MarshalTo(dAtA []byte) (int, error)

func (*SocketStreamedTraceSegment_Event) MarshalToSizedBuffer 

func (m *SocketStreamedTraceSegment_Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SocketStreamedTraceSegment_Event) Size 

func (m *SocketStreamedTraceSegment_Event) Size() (n int)

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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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 

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

func (*TraceWrapper) GetHttpBufferedTrace 

func (m *TraceWrapper) GetHttpBufferedTrace() *HttpBufferedTrace

func (*TraceWrapper) GetHttpStreamedTraceSegment 

func (m *TraceWrapper) GetHttpStreamedTraceSegment() *HttpStreamedTraceSegment

func (*TraceWrapper) GetSocketBufferedTrace 

func (m *TraceWrapper) GetSocketBufferedTrace() *SocketBufferedTrace

func (*TraceWrapper) GetSocketStreamedTraceSegment 

func (m *TraceWrapper) GetSocketStreamedTraceSegment() *SocketStreamedTraceSegment

func (*TraceWrapper) GetTrace 

func (m *TraceWrapper) GetTrace() isTraceWrapper_Trace

func (*TraceWrapper) Marshal 

func (m *TraceWrapper) Marshal() (dAtA []byte, err error)

func (*TraceWrapper) MarshalTo 

func (m *TraceWrapper) MarshalTo(dAtA []byte) (int, error)

func (*TraceWrapper) MarshalToSizedBuffer 

func (m *TraceWrapper) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TraceWrapper) ProtoMessage 

func (*TraceWrapper) ProtoMessage()

func (*TraceWrapper) Reset 

func (m *TraceWrapper) Reset()

func (*TraceWrapper) Size 

func (m *TraceWrapper) Size() (n int)

func (*TraceWrapper) String 

func (m *TraceWrapper) String() string

func (*TraceWrapper) Unmarshal 

func (m *TraceWrapper) Unmarshal(dAtA []byte) error

func (*TraceWrapper) Validate 

func (m *TraceWrapper) Validate() error

Validate checks the field values on TraceWrapper with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TraceWrapper) XXX_DiscardUnknown 

func (m *TraceWrapper) XXX_DiscardUnknown()

func (*TraceWrapper) XXX_Marshal 

func (m *TraceWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TraceWrapper) XXX_Merge 

func (m *TraceWrapper) XXX_Merge(src proto.Message)

func (*TraceWrapper) XXX_OneofWrappers 

func (*TraceWrapper) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TraceWrapper) XXX_Size 

func (m *TraceWrapper) XXX_Size() int

func (*TraceWrapper) XXX_Unmarshal 

func (m *TraceWrapper) XXX_Unmarshal(b []byte) error

type TraceWrapperValidationError 

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

TraceWrapperValidationError is the validation error returned by TraceWrapper.Validate if the designated constraints aren't met.

func (TraceWrapperValidationError) Cause 

func (e TraceWrapperValidationError) Cause() error

Cause function returns cause value.

func (TraceWrapperValidationError) Error 

func (e TraceWrapperValidationError) Error() string

Error satisfies the builtin error interface

func (TraceWrapperValidationError) ErrorName 

func (e TraceWrapperValidationError) ErrorName() string

ErrorName returns error name.

func (TraceWrapperValidationError) Field 

func (e TraceWrapperValidationError) Field() string

Field function returns field value.

func (TraceWrapperValidationError) Key 

func (e TraceWrapperValidationError) Key() bool

Key function returns key value.

func (TraceWrapperValidationError) Reason 

func (e TraceWrapperValidationError) Reason() string

Reason function returns reason value.

type TraceWrapper_HttpBufferedTrace 

type TraceWrapper_HttpBufferedTrace struct {
	HttpBufferedTrace *HttpBufferedTrace `protobuf:"bytes,1,opt,name=http_buffered_trace,json=httpBufferedTrace,proto3,oneof" json:"http_buffered_trace,omitempty"`
}

func (*TraceWrapper_HttpBufferedTrace) MarshalTo 

func (m *TraceWrapper_HttpBufferedTrace) MarshalTo(dAtA []byte) (int, error)

func (*TraceWrapper_HttpBufferedTrace) MarshalToSizedBuffer 

func (m *TraceWrapper_HttpBufferedTrace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TraceWrapper_HttpBufferedTrace) Size 

func (m *TraceWrapper_HttpBufferedTrace) Size() (n int)

type TraceWrapper_HttpStreamedTraceSegment 

type TraceWrapper_HttpStreamedTraceSegment struct {
	HttpStreamedTraceSegment *HttpStreamedTraceSegment `` /* 143-byte string literal not displayed */
}

func (*TraceWrapper_HttpStreamedTraceSegment) MarshalTo 

func (m *TraceWrapper_HttpStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)

func (*TraceWrapper_HttpStreamedTraceSegment) MarshalToSizedBuffer 

func (m *TraceWrapper_HttpStreamedTraceSegment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TraceWrapper_HttpStreamedTraceSegment) Size 

func (m *TraceWrapper_HttpStreamedTraceSegment) Size() (n int)

type TraceWrapper_SocketBufferedTrace 

type TraceWrapper_SocketBufferedTrace struct {
	SocketBufferedTrace *SocketBufferedTrace `` /* 126-byte string literal not displayed */
}

func (*TraceWrapper_SocketBufferedTrace) MarshalTo 

func (m *TraceWrapper_SocketBufferedTrace) MarshalTo(dAtA []byte) (int, error)

func (*TraceWrapper_SocketBufferedTrace) MarshalToSizedBuffer 

func (m *TraceWrapper_SocketBufferedTrace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TraceWrapper_SocketBufferedTrace) Size 

func (m *TraceWrapper_SocketBufferedTrace) Size() (n int)

type TraceWrapper_SocketStreamedTraceSegment 

type TraceWrapper_SocketStreamedTraceSegment struct {
	SocketStreamedTraceSegment *SocketStreamedTraceSegment `` /* 149-byte string literal not displayed */
}

func (*TraceWrapper_SocketStreamedTraceSegment) MarshalTo 

func (m *TraceWrapper_SocketStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)

func (*TraceWrapper_SocketStreamedTraceSegment) MarshalToSizedBuffer 

func (m *TraceWrapper_SocketStreamedTraceSegment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TraceWrapper_SocketStreamedTraceSegment) Size 

func (m *TraceWrapper_SocketStreamedTraceSegment) Size() (n int)

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.