envoy_data_tap_v2alpha

package
v1.4.2-rc.0 Latest Latest
Warning

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

Go to latest
Published: Apr 21, 2020 License: Apache-2.0 Imports: 17 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")
)
View Source
var (
	ErrInvalidLengthHttp = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHttp   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthTransport = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTransport   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthWrapper = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWrapper   = fmt.Errorf("proto: integer overflow")
)

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

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

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

Error satisfies the builtin error interface

func (ConnectionValidationError) ErrorName

func (e ConnectionValidationError) ErrorName() string

ErrorName returns error name.

func (ConnectionValidationError) Field

Field function returns field value.

func (ConnectionValidationError) Key

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 (*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

Cause function returns cause value.

func (HttpBufferedTraceValidationError) Error

Error satisfies the builtin error interface

func (HttpBufferedTraceValidationError) ErrorName

ErrorName returns error name.

func (HttpBufferedTraceValidationError) Field

Field function returns field value.

func (HttpBufferedTraceValidationError) Key

Key function returns key value.

func (HttpBufferedTraceValidationError) Reason

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

Cause function returns cause value.

func (HttpBufferedTrace_MessageValidationError) Error

Error satisfies the builtin error interface

func (HttpBufferedTrace_MessageValidationError) ErrorName

ErrorName returns error name.

func (HttpBufferedTrace_MessageValidationError) Field

Field function returns field value.

func (HttpBufferedTrace_MessageValidationError) Key

Key function returns key value.

func (HttpBufferedTrace_MessageValidationError) Reason

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

Cause function returns cause value.

func (HttpStreamedTraceSegmentValidationError) Error

Error satisfies the builtin error interface

func (HttpStreamedTraceSegmentValidationError) ErrorName

ErrorName returns error name.

func (HttpStreamedTraceSegmentValidationError) Field

Field function returns field value.

func (HttpStreamedTraceSegmentValidationError) Key

Key function returns key value.

func (HttpStreamedTraceSegmentValidationError) Reason

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

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

type HttpStreamedTraceSegment_RequestHeaders

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

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

type HttpStreamedTraceSegment_RequestTrailers

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

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

type HttpStreamedTraceSegment_ResponseBodyChunk

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

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

type HttpStreamedTraceSegment_ResponseHeaders

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

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

type HttpStreamedTraceSegment_ResponseTrailers

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

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

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

Cause function returns cause value.

func (SocketBufferedTraceValidationError) Error

Error satisfies the builtin error interface

func (SocketBufferedTraceValidationError) ErrorName

ErrorName returns error name.

func (SocketBufferedTraceValidationError) Field

Field function returns field value.

func (SocketBufferedTraceValidationError) Key

Key function returns key value.

func (SocketBufferedTraceValidationError) Reason

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

Cause function returns cause value.

func (SocketEventValidationError) Error

Error satisfies the builtin error interface

func (SocketEventValidationError) ErrorName

func (e SocketEventValidationError) ErrorName() string

ErrorName returns error name.

func (SocketEventValidationError) Field

Field function returns field value.

func (SocketEventValidationError) Key

Key function returns key value.

func (SocketEventValidationError) Reason

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

Cause function returns cause value.

func (SocketEvent_ClosedValidationError) Error

Error satisfies the builtin error interface

func (SocketEvent_ClosedValidationError) ErrorName

ErrorName returns error name.

func (SocketEvent_ClosedValidationError) Field

Field function returns field value.

func (SocketEvent_ClosedValidationError) Key

Key function returns key value.

func (SocketEvent_ClosedValidationError) Reason

Reason function returns reason value.

type SocketEvent_Closed_

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

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

Cause function returns cause value.

func (SocketEvent_ReadValidationError) Error

Error satisfies the builtin error interface

func (SocketEvent_ReadValidationError) ErrorName

ErrorName returns error name.

func (SocketEvent_ReadValidationError) Field

Field function returns field value.

func (SocketEvent_ReadValidationError) Key

Key function returns key value.

func (SocketEvent_ReadValidationError) Reason

Reason function returns reason value.

type SocketEvent_Read_

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

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

Cause function returns cause value.

func (SocketEvent_WriteValidationError) Error

Error satisfies the builtin error interface

func (SocketEvent_WriteValidationError) ErrorName

ErrorName returns error name.

func (SocketEvent_WriteValidationError) Field

Field function returns field value.

func (SocketEvent_WriteValidationError) Key

Key function returns key value.

func (SocketEvent_WriteValidationError) Reason

Reason function returns reason value.

type SocketEvent_Write_

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

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

Cause function returns cause value.

func (SocketStreamedTraceSegmentValidationError) Error

Error satisfies the builtin error interface

func (SocketStreamedTraceSegmentValidationError) ErrorName

ErrorName returns error name.

func (SocketStreamedTraceSegmentValidationError) Field

Field function returns field value.

func (SocketStreamedTraceSegmentValidationError) Key

Key function returns key value.

func (SocketStreamedTraceSegmentValidationError) Reason

Reason function returns reason value.

type SocketStreamedTraceSegment_Connection

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

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

type SocketStreamedTraceSegment_Event

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

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

Cause function returns cause value.

func (TraceWrapperValidationError) Error

Error satisfies the builtin error interface

func (TraceWrapperValidationError) ErrorName

func (e TraceWrapperValidationError) ErrorName() string

ErrorName returns error name.

func (TraceWrapperValidationError) Field

Field function returns field value.

func (TraceWrapperValidationError) Key

Key function returns key value.

func (TraceWrapperValidationError) Reason

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

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 `protobuf:"bytes,2,opt,name=http_streamed_trace_segment,json=httpStreamedTraceSegment,proto3,oneof"`
}

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

type TraceWrapper_SocketBufferedTrace

type TraceWrapper_SocketBufferedTrace struct {
	SocketBufferedTrace *SocketBufferedTrace `protobuf:"bytes,3,opt,name=socket_buffered_trace,json=socketBufferedTrace,proto3,oneof"`
}

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 `protobuf:"bytes,4,opt,name=socket_streamed_trace_segment,json=socketStreamedTraceSegment,proto3,oneof"`
}

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL