Documentation ¶
Index ¶
- Variables
- type Body
- func (*Body) Descriptor() ([]byte, []int)
- func (m *Body) GetAsBytes() []byte
- func (m *Body) GetAsString() string
- func (m *Body) GetBodyType() isBody_BodyType
- func (m *Body) GetTruncated() bool
- func (m *Body) Marshal() (dAtA []byte, err error)
- func (m *Body) MarshalTo(dAtA []byte) (int, error)
- func (*Body) ProtoMessage()
- func (m *Body) Reset()
- func (m *Body) Size() (n int)
- func (m *Body) String() string
- func (m *Body) Unmarshal(dAtA []byte) error
- func (m *Body) Validate() error
- func (m *Body) XXX_DiscardUnknown()
- func (m *Body) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Body) XXX_Merge(src proto.Message)
- func (*Body) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Body) XXX_Size() int
- func (m *Body) XXX_Unmarshal(b []byte) error
- type BodyValidationError
- type Body_AsBytes
- type Body_AsString
- type Connection
- func (*Connection) Descriptor() ([]byte, []int)
- func (m *Connection) GetLocalAddress() *core.Address
- func (m *Connection) GetRemoteAddress() *core.Address
- func (m *Connection) Marshal() (dAtA []byte, err error)
- func (m *Connection) MarshalTo(dAtA []byte) (int, error)
- func (*Connection) ProtoMessage()
- func (m *Connection) Reset()
- func (m *Connection) Size() (n int)
- func (m *Connection) String() string
- func (m *Connection) Unmarshal(dAtA []byte) error
- func (m *Connection) Validate() error
- func (m *Connection) XXX_DiscardUnknown()
- func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Connection) XXX_Merge(src proto.Message)
- func (m *Connection) XXX_Size() int
- func (m *Connection) XXX_Unmarshal(b []byte) error
- type ConnectionValidationError
- type HttpBufferedTrace
- func (*HttpBufferedTrace) Descriptor() ([]byte, []int)
- func (m *HttpBufferedTrace) GetRequest() *HttpBufferedTrace_Message
- func (m *HttpBufferedTrace) GetResponse() *HttpBufferedTrace_Message
- func (m *HttpBufferedTrace) Marshal() (dAtA []byte, err error)
- func (m *HttpBufferedTrace) MarshalTo(dAtA []byte) (int, error)
- func (*HttpBufferedTrace) ProtoMessage()
- func (m *HttpBufferedTrace) Reset()
- func (m *HttpBufferedTrace) Size() (n int)
- func (m *HttpBufferedTrace) String() string
- func (m *HttpBufferedTrace) Unmarshal(dAtA []byte) error
- func (m *HttpBufferedTrace) Validate() error
- func (m *HttpBufferedTrace) XXX_DiscardUnknown()
- func (m *HttpBufferedTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HttpBufferedTrace) XXX_Merge(src proto.Message)
- func (m *HttpBufferedTrace) XXX_Size() int
- func (m *HttpBufferedTrace) XXX_Unmarshal(b []byte) error
- type HttpBufferedTraceValidationError
- func (e HttpBufferedTraceValidationError) Cause() error
- func (e HttpBufferedTraceValidationError) Error() string
- func (e HttpBufferedTraceValidationError) ErrorName() string
- func (e HttpBufferedTraceValidationError) Field() string
- func (e HttpBufferedTraceValidationError) Key() bool
- func (e HttpBufferedTraceValidationError) Reason() string
- type HttpBufferedTrace_Message
- func (*HttpBufferedTrace_Message) Descriptor() ([]byte, []int)
- func (m *HttpBufferedTrace_Message) GetBody() *Body
- func (m *HttpBufferedTrace_Message) GetHeaders() []*core.HeaderValue
- func (m *HttpBufferedTrace_Message) GetTrailers() []*core.HeaderValue
- func (m *HttpBufferedTrace_Message) Marshal() (dAtA []byte, err error)
- func (m *HttpBufferedTrace_Message) MarshalTo(dAtA []byte) (int, error)
- func (*HttpBufferedTrace_Message) ProtoMessage()
- func (m *HttpBufferedTrace_Message) Reset()
- func (m *HttpBufferedTrace_Message) Size() (n int)
- func (m *HttpBufferedTrace_Message) String() string
- func (m *HttpBufferedTrace_Message) Unmarshal(dAtA []byte) error
- func (m *HttpBufferedTrace_Message) Validate() error
- func (m *HttpBufferedTrace_Message) XXX_DiscardUnknown()
- func (m *HttpBufferedTrace_Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HttpBufferedTrace_Message) XXX_Merge(src proto.Message)
- func (m *HttpBufferedTrace_Message) XXX_Size() int
- func (m *HttpBufferedTrace_Message) XXX_Unmarshal(b []byte) error
- type HttpBufferedTrace_MessageValidationError
- func (e HttpBufferedTrace_MessageValidationError) Cause() error
- func (e HttpBufferedTrace_MessageValidationError) Error() string
- func (e HttpBufferedTrace_MessageValidationError) ErrorName() string
- func (e HttpBufferedTrace_MessageValidationError) Field() string
- func (e HttpBufferedTrace_MessageValidationError) Key() bool
- func (e HttpBufferedTrace_MessageValidationError) Reason() string
- type HttpStreamedTraceSegment
- func (*HttpStreamedTraceSegment) Descriptor() ([]byte, []int)
- func (m *HttpStreamedTraceSegment) GetMessagePiece() isHttpStreamedTraceSegment_MessagePiece
- func (m *HttpStreamedTraceSegment) GetRequestBodyChunk() *Body
- func (m *HttpStreamedTraceSegment) GetRequestHeaders() *core.HeaderMap
- func (m *HttpStreamedTraceSegment) GetRequestTrailers() *core.HeaderMap
- func (m *HttpStreamedTraceSegment) GetResponseBodyChunk() *Body
- func (m *HttpStreamedTraceSegment) GetResponseHeaders() *core.HeaderMap
- func (m *HttpStreamedTraceSegment) GetResponseTrailers() *core.HeaderMap
- func (m *HttpStreamedTraceSegment) GetTraceId() uint64
- func (m *HttpStreamedTraceSegment) Marshal() (dAtA []byte, err error)
- func (m *HttpStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)
- func (*HttpStreamedTraceSegment) ProtoMessage()
- func (m *HttpStreamedTraceSegment) Reset()
- func (m *HttpStreamedTraceSegment) Size() (n int)
- func (m *HttpStreamedTraceSegment) String() string
- func (m *HttpStreamedTraceSegment) Unmarshal(dAtA []byte) error
- func (m *HttpStreamedTraceSegment) Validate() error
- func (m *HttpStreamedTraceSegment) XXX_DiscardUnknown()
- func (m *HttpStreamedTraceSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HttpStreamedTraceSegment) XXX_Merge(src proto.Message)
- func (*HttpStreamedTraceSegment) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *HttpStreamedTraceSegment) XXX_Size() int
- func (m *HttpStreamedTraceSegment) XXX_Unmarshal(b []byte) error
- type HttpStreamedTraceSegmentValidationError
- func (e HttpStreamedTraceSegmentValidationError) Cause() error
- func (e HttpStreamedTraceSegmentValidationError) Error() string
- func (e HttpStreamedTraceSegmentValidationError) ErrorName() string
- func (e HttpStreamedTraceSegmentValidationError) Field() string
- func (e HttpStreamedTraceSegmentValidationError) Key() bool
- func (e HttpStreamedTraceSegmentValidationError) Reason() string
- type HttpStreamedTraceSegment_RequestBodyChunk
- type HttpStreamedTraceSegment_RequestHeaders
- type HttpStreamedTraceSegment_RequestTrailers
- type HttpStreamedTraceSegment_ResponseBodyChunk
- type HttpStreamedTraceSegment_ResponseHeaders
- type HttpStreamedTraceSegment_ResponseTrailers
- type SocketBufferedTrace
- func (*SocketBufferedTrace) Descriptor() ([]byte, []int)
- func (m *SocketBufferedTrace) GetConnection() *Connection
- func (m *SocketBufferedTrace) GetEvents() []*SocketEvent
- func (m *SocketBufferedTrace) GetReadTruncated() bool
- func (m *SocketBufferedTrace) GetTraceId() uint64
- func (m *SocketBufferedTrace) GetWriteTruncated() bool
- func (m *SocketBufferedTrace) Marshal() (dAtA []byte, err error)
- func (m *SocketBufferedTrace) MarshalTo(dAtA []byte) (int, error)
- func (*SocketBufferedTrace) ProtoMessage()
- func (m *SocketBufferedTrace) Reset()
- func (m *SocketBufferedTrace) Size() (n int)
- func (m *SocketBufferedTrace) String() string
- func (m *SocketBufferedTrace) Unmarshal(dAtA []byte) error
- func (m *SocketBufferedTrace) Validate() error
- func (m *SocketBufferedTrace) XXX_DiscardUnknown()
- func (m *SocketBufferedTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SocketBufferedTrace) XXX_Merge(src proto.Message)
- func (m *SocketBufferedTrace) XXX_Size() int
- func (m *SocketBufferedTrace) XXX_Unmarshal(b []byte) error
- type SocketBufferedTraceValidationError
- func (e SocketBufferedTraceValidationError) Cause() error
- func (e SocketBufferedTraceValidationError) Error() string
- func (e SocketBufferedTraceValidationError) ErrorName() string
- func (e SocketBufferedTraceValidationError) Field() string
- func (e SocketBufferedTraceValidationError) Key() bool
- func (e SocketBufferedTraceValidationError) Reason() string
- type SocketEvent
- func (*SocketEvent) Descriptor() ([]byte, []int)
- func (m *SocketEvent) GetClosed() *SocketEvent_Closed
- func (m *SocketEvent) GetEventSelector() isSocketEvent_EventSelector
- func (m *SocketEvent) GetRead() *SocketEvent_Read
- func (m *SocketEvent) GetTimestamp() *types.Timestamp
- func (m *SocketEvent) GetWrite() *SocketEvent_Write
- func (m *SocketEvent) Marshal() (dAtA []byte, err error)
- func (m *SocketEvent) MarshalTo(dAtA []byte) (int, error)
- func (*SocketEvent) ProtoMessage()
- func (m *SocketEvent) Reset()
- func (m *SocketEvent) Size() (n int)
- func (m *SocketEvent) String() string
- func (m *SocketEvent) Unmarshal(dAtA []byte) error
- func (m *SocketEvent) Validate() error
- func (m *SocketEvent) XXX_DiscardUnknown()
- func (m *SocketEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SocketEvent) XXX_Merge(src proto.Message)
- func (*SocketEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *SocketEvent) XXX_Size() int
- func (m *SocketEvent) XXX_Unmarshal(b []byte) error
- type SocketEventValidationError
- func (e SocketEventValidationError) Cause() error
- func (e SocketEventValidationError) Error() string
- func (e SocketEventValidationError) ErrorName() string
- func (e SocketEventValidationError) Field() string
- func (e SocketEventValidationError) Key() bool
- func (e SocketEventValidationError) Reason() string
- type SocketEvent_Closed
- func (*SocketEvent_Closed) Descriptor() ([]byte, []int)
- func (m *SocketEvent_Closed) Marshal() (dAtA []byte, err error)
- func (m *SocketEvent_Closed) MarshalTo(dAtA []byte) (int, error)
- func (*SocketEvent_Closed) ProtoMessage()
- func (m *SocketEvent_Closed) Reset()
- func (m *SocketEvent_Closed) Size() (n int)
- func (m *SocketEvent_Closed) String() string
- func (m *SocketEvent_Closed) Unmarshal(dAtA []byte) error
- func (m *SocketEvent_Closed) Validate() error
- func (m *SocketEvent_Closed) XXX_DiscardUnknown()
- func (m *SocketEvent_Closed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SocketEvent_Closed) XXX_Merge(src proto.Message)
- func (m *SocketEvent_Closed) XXX_Size() int
- func (m *SocketEvent_Closed) XXX_Unmarshal(b []byte) error
- type SocketEvent_ClosedValidationError
- func (e SocketEvent_ClosedValidationError) Cause() error
- func (e SocketEvent_ClosedValidationError) Error() string
- func (e SocketEvent_ClosedValidationError) ErrorName() string
- func (e SocketEvent_ClosedValidationError) Field() string
- func (e SocketEvent_ClosedValidationError) Key() bool
- func (e SocketEvent_ClosedValidationError) Reason() string
- type SocketEvent_Closed_
- type SocketEvent_Read
- func (*SocketEvent_Read) Descriptor() ([]byte, []int)
- func (m *SocketEvent_Read) GetData() *Body
- func (m *SocketEvent_Read) Marshal() (dAtA []byte, err error)
- func (m *SocketEvent_Read) MarshalTo(dAtA []byte) (int, error)
- func (*SocketEvent_Read) ProtoMessage()
- func (m *SocketEvent_Read) Reset()
- func (m *SocketEvent_Read) Size() (n int)
- func (m *SocketEvent_Read) String() string
- func (m *SocketEvent_Read) Unmarshal(dAtA []byte) error
- func (m *SocketEvent_Read) Validate() error
- func (m *SocketEvent_Read) XXX_DiscardUnknown()
- func (m *SocketEvent_Read) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SocketEvent_Read) XXX_Merge(src proto.Message)
- func (m *SocketEvent_Read) XXX_Size() int
- func (m *SocketEvent_Read) XXX_Unmarshal(b []byte) error
- type SocketEvent_ReadValidationError
- func (e SocketEvent_ReadValidationError) Cause() error
- func (e SocketEvent_ReadValidationError) Error() string
- func (e SocketEvent_ReadValidationError) ErrorName() string
- func (e SocketEvent_ReadValidationError) Field() string
- func (e SocketEvent_ReadValidationError) Key() bool
- func (e SocketEvent_ReadValidationError) Reason() string
- type SocketEvent_Read_
- type SocketEvent_Write
- func (*SocketEvent_Write) Descriptor() ([]byte, []int)
- func (m *SocketEvent_Write) GetData() *Body
- func (m *SocketEvent_Write) GetEndStream() bool
- func (m *SocketEvent_Write) Marshal() (dAtA []byte, err error)
- func (m *SocketEvent_Write) MarshalTo(dAtA []byte) (int, error)
- func (*SocketEvent_Write) ProtoMessage()
- func (m *SocketEvent_Write) Reset()
- func (m *SocketEvent_Write) Size() (n int)
- func (m *SocketEvent_Write) String() string
- func (m *SocketEvent_Write) Unmarshal(dAtA []byte) error
- func (m *SocketEvent_Write) Validate() error
- func (m *SocketEvent_Write) XXX_DiscardUnknown()
- func (m *SocketEvent_Write) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SocketEvent_Write) XXX_Merge(src proto.Message)
- func (m *SocketEvent_Write) XXX_Size() int
- func (m *SocketEvent_Write) XXX_Unmarshal(b []byte) error
- type SocketEvent_WriteValidationError
- func (e SocketEvent_WriteValidationError) Cause() error
- func (e SocketEvent_WriteValidationError) Error() string
- func (e SocketEvent_WriteValidationError) ErrorName() string
- func (e SocketEvent_WriteValidationError) Field() string
- func (e SocketEvent_WriteValidationError) Key() bool
- func (e SocketEvent_WriteValidationError) Reason() string
- type SocketEvent_Write_
- type SocketStreamedTraceSegment
- func (*SocketStreamedTraceSegment) Descriptor() ([]byte, []int)
- func (m *SocketStreamedTraceSegment) GetConnection() *Connection
- func (m *SocketStreamedTraceSegment) GetEvent() *SocketEvent
- func (m *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece
- func (m *SocketStreamedTraceSegment) GetTraceId() uint64
- func (m *SocketStreamedTraceSegment) Marshal() (dAtA []byte, err error)
- func (m *SocketStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)
- func (*SocketStreamedTraceSegment) ProtoMessage()
- func (m *SocketStreamedTraceSegment) Reset()
- func (m *SocketStreamedTraceSegment) Size() (n int)
- func (m *SocketStreamedTraceSegment) String() string
- func (m *SocketStreamedTraceSegment) Unmarshal(dAtA []byte) error
- func (m *SocketStreamedTraceSegment) Validate() error
- func (m *SocketStreamedTraceSegment) XXX_DiscardUnknown()
- func (m *SocketStreamedTraceSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SocketStreamedTraceSegment) XXX_Merge(src proto.Message)
- func (*SocketStreamedTraceSegment) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *SocketStreamedTraceSegment) XXX_Size() int
- func (m *SocketStreamedTraceSegment) XXX_Unmarshal(b []byte) error
- type SocketStreamedTraceSegmentValidationError
- func (e SocketStreamedTraceSegmentValidationError) Cause() error
- func (e SocketStreamedTraceSegmentValidationError) Error() string
- func (e SocketStreamedTraceSegmentValidationError) ErrorName() string
- func (e SocketStreamedTraceSegmentValidationError) Field() string
- func (e SocketStreamedTraceSegmentValidationError) Key() bool
- func (e SocketStreamedTraceSegmentValidationError) Reason() string
- type SocketStreamedTraceSegment_Connection
- type SocketStreamedTraceSegment_Event
- type TraceWrapper
- func (*TraceWrapper) Descriptor() ([]byte, []int)
- func (m *TraceWrapper) GetDestination() *TraceWrapper_Destination
- func (m *TraceWrapper) GetDownstreamRemoteAddress() *core.Address
- func (m *TraceWrapper) GetHttpBufferedTrace() *HttpBufferedTrace
- func (m *TraceWrapper) GetHttpStreamedTraceSegment() *HttpStreamedTraceSegment
- func (m *TraceWrapper) GetSocketBufferedTrace() *SocketBufferedTrace
- func (m *TraceWrapper) GetSocketStreamedTraceSegment() *SocketStreamedTraceSegment
- func (m *TraceWrapper) GetTrace() isTraceWrapper_Trace
- func (m *TraceWrapper) Marshal() (dAtA []byte, err error)
- func (m *TraceWrapper) MarshalTo(dAtA []byte) (int, error)
- func (*TraceWrapper) ProtoMessage()
- func (m *TraceWrapper) Reset()
- func (m *TraceWrapper) Size() (n int)
- func (m *TraceWrapper) String() string
- func (m *TraceWrapper) Unmarshal(dAtA []byte) error
- func (m *TraceWrapper) Validate() error
- func (m *TraceWrapper) XXX_DiscardUnknown()
- func (m *TraceWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TraceWrapper) XXX_Merge(src proto.Message)
- func (*TraceWrapper) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *TraceWrapper) XXX_Size() int
- func (m *TraceWrapper) XXX_Unmarshal(b []byte) error
- type TraceWrapperValidationError
- func (e TraceWrapperValidationError) Cause() error
- func (e TraceWrapperValidationError) Error() string
- func (e TraceWrapperValidationError) ErrorName() string
- func (e TraceWrapperValidationError) Field() string
- func (e TraceWrapperValidationError) Key() bool
- func (e TraceWrapperValidationError) Reason() string
- type TraceWrapper_Destination
- func (*TraceWrapper_Destination) Descriptor() ([]byte, []int)
- func (m *TraceWrapper_Destination) GetClusterMetadata() *types.Struct
- func (m *TraceWrapper_Destination) GetClusterName() string
- func (m *TraceWrapper_Destination) GetHostAddress() *core.Address
- func (m *TraceWrapper_Destination) GetHostMetadata() *types.Struct
- func (m *TraceWrapper_Destination) Marshal() (dAtA []byte, err error)
- func (m *TraceWrapper_Destination) MarshalTo(dAtA []byte) (int, error)
- func (*TraceWrapper_Destination) ProtoMessage()
- func (m *TraceWrapper_Destination) Reset()
- func (m *TraceWrapper_Destination) Size() (n int)
- func (m *TraceWrapper_Destination) String() string
- func (m *TraceWrapper_Destination) Unmarshal(dAtA []byte) error
- func (m *TraceWrapper_Destination) Validate() error
- func (m *TraceWrapper_Destination) XXX_DiscardUnknown()
- func (m *TraceWrapper_Destination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TraceWrapper_Destination) XXX_Merge(src proto.Message)
- func (m *TraceWrapper_Destination) XXX_Size() int
- func (m *TraceWrapper_Destination) XXX_Unmarshal(b []byte) error
- type TraceWrapper_DestinationValidationError
- func (e TraceWrapper_DestinationValidationError) Cause() error
- func (e TraceWrapper_DestinationValidationError) Error() string
- func (e TraceWrapper_DestinationValidationError) ErrorName() string
- func (e TraceWrapper_DestinationValidationError) Field() string
- func (e TraceWrapper_DestinationValidationError) Key() bool
- func (e TraceWrapper_DestinationValidationError) Reason() string
- type TraceWrapper_HttpBufferedTrace
- type TraceWrapper_HttpStreamedTraceSegment
- type TraceWrapper_SocketBufferedTrace
- type TraceWrapper_SocketStreamedTraceSegment
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthCommon = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCommon = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthHttp = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHttp = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthTransport = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTransport = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthWrapper = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowWrapper = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type Body ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (*Body) GetAsBytes ¶ added in v0.6.10
func (*Body) GetAsString ¶ added in v0.6.10
func (*Body) GetBodyType ¶ added in v0.6.10
func (m *Body) GetBodyType() isBody_BodyType
func (*Body) GetTruncated ¶ added in v0.6.10
func (*Body) ProtoMessage ¶ added in v0.6.10
func (*Body) ProtoMessage()
func (*Body) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *Body) XXX_DiscardUnknown()
func (*Body) XXX_Marshal ¶ added in v0.6.10
func (*Body) XXX_OneofFuncs ¶ added in v0.6.10
func (*Body) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Body) XXX_Unmarshal ¶ added in v0.6.10
type BodyValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e BodyValidationError) Cause() error
Cause function returns cause value.
func (BodyValidationError) Error ¶ added in v0.6.10
func (e BodyValidationError) Error() string
Error satisfies the builtin error interface
func (BodyValidationError) ErrorName ¶ added in v0.6.100
func (e BodyValidationError) ErrorName() string
ErrorName returns error name.
func (BodyValidationError) Field ¶ added in v0.6.10
func (e BodyValidationError) Field() string
Field function returns field value.
func (BodyValidationError) Key ¶ added in v0.6.10
func (e BodyValidationError) Key() bool
Key function returns key value.
func (BodyValidationError) Reason ¶ added in v0.6.10
func (e BodyValidationError) Reason() string
Reason function returns reason value.
type Body_AsBytes ¶ added in v0.6.10
type Body_AsBytes struct {
AsBytes []byte `protobuf:"bytes,1,opt,name=as_bytes,json=asBytes,proto3,oneof"`
}
func (*Body_AsBytes) MarshalTo ¶ added in v0.6.10
func (m *Body_AsBytes) MarshalTo(dAtA []byte) (int, error)
func (*Body_AsBytes) Size ¶ added in v0.6.10
func (m *Body_AsBytes) Size() (n int)
type Body_AsString ¶ added in v0.6.10
type Body_AsString struct {
AsString string `protobuf:"bytes,2,opt,name=as_string,json=asString,proto3,oneof"`
}
func (*Body_AsString) MarshalTo ¶ added in v0.6.10
func (m *Body_AsString) MarshalTo(dAtA []byte) (int, error)
func (*Body_AsString) Size ¶ added in v0.6.10
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) 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 ¶ added in v0.6.100
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 ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (*HttpBufferedTrace) Descriptor() ([]byte, []int)
func (*HttpBufferedTrace) GetRequest ¶ added in v0.6.10
func (m *HttpBufferedTrace) GetRequest() *HttpBufferedTrace_Message
func (*HttpBufferedTrace) GetResponse ¶ added in v0.6.10
func (m *HttpBufferedTrace) GetResponse() *HttpBufferedTrace_Message
func (*HttpBufferedTrace) Marshal ¶ added in v0.6.10
func (m *HttpBufferedTrace) Marshal() (dAtA []byte, err error)
func (*HttpBufferedTrace) MarshalTo ¶ added in v0.6.10
func (m *HttpBufferedTrace) MarshalTo(dAtA []byte) (int, error)
func (*HttpBufferedTrace) ProtoMessage ¶ added in v0.6.10
func (*HttpBufferedTrace) ProtoMessage()
func (*HttpBufferedTrace) Reset ¶ added in v0.6.10
func (m *HttpBufferedTrace) Reset()
func (*HttpBufferedTrace) Size ¶ added in v0.6.10
func (m *HttpBufferedTrace) Size() (n int)
func (*HttpBufferedTrace) String ¶ added in v0.6.10
func (m *HttpBufferedTrace) String() string
func (*HttpBufferedTrace) Unmarshal ¶ added in v0.6.10
func (m *HttpBufferedTrace) Unmarshal(dAtA []byte) error
func (*HttpBufferedTrace) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *HttpBufferedTrace) XXX_DiscardUnknown()
func (*HttpBufferedTrace) XXX_Marshal ¶ added in v0.6.10
func (m *HttpBufferedTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HttpBufferedTrace) XXX_Merge ¶ added in v0.6.10
func (m *HttpBufferedTrace) XXX_Merge(src proto.Message)
func (*HttpBufferedTrace) XXX_Size ¶ added in v0.6.10
func (m *HttpBufferedTrace) XXX_Size() int
func (*HttpBufferedTrace) XXX_Unmarshal ¶ added in v0.6.10
func (m *HttpBufferedTrace) XXX_Unmarshal(b []byte) error
type HttpBufferedTraceValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e HttpBufferedTraceValidationError) Cause() error
Cause function returns cause value.
func (HttpBufferedTraceValidationError) Error ¶ added in v0.6.10
func (e HttpBufferedTraceValidationError) Error() string
Error satisfies the builtin error interface
func (HttpBufferedTraceValidationError) ErrorName ¶ added in v0.6.100
func (e HttpBufferedTraceValidationError) ErrorName() string
ErrorName returns error name.
func (HttpBufferedTraceValidationError) Field ¶ added in v0.6.10
func (e HttpBufferedTraceValidationError) Field() string
Field function returns field value.
func (HttpBufferedTraceValidationError) Key ¶ added in v0.6.10
func (e HttpBufferedTraceValidationError) Key() bool
Key function returns key value.
func (HttpBufferedTraceValidationError) Reason ¶ added in v0.6.10
func (e HttpBufferedTraceValidationError) Reason() string
Reason function returns reason value.
type HttpBufferedTrace_Message ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (*HttpBufferedTrace_Message) Descriptor() ([]byte, []int)
func (*HttpBufferedTrace_Message) GetBody ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) GetBody() *Body
func (*HttpBufferedTrace_Message) GetHeaders ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) GetHeaders() []*core.HeaderValue
func (*HttpBufferedTrace_Message) GetTrailers ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) GetTrailers() []*core.HeaderValue
func (*HttpBufferedTrace_Message) Marshal ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) Marshal() (dAtA []byte, err error)
func (*HttpBufferedTrace_Message) MarshalTo ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) MarshalTo(dAtA []byte) (int, error)
func (*HttpBufferedTrace_Message) ProtoMessage ¶ added in v0.6.10
func (*HttpBufferedTrace_Message) ProtoMessage()
func (*HttpBufferedTrace_Message) Reset ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) Reset()
func (*HttpBufferedTrace_Message) Size ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) Size() (n int)
func (*HttpBufferedTrace_Message) String ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) String() string
func (*HttpBufferedTrace_Message) Unmarshal ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) Unmarshal(dAtA []byte) error
func (*HttpBufferedTrace_Message) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) XXX_DiscardUnknown()
func (*HttpBufferedTrace_Message) XXX_Marshal ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HttpBufferedTrace_Message) XXX_Merge ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) XXX_Merge(src proto.Message)
func (*HttpBufferedTrace_Message) XXX_Size ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) XXX_Size() int
func (*HttpBufferedTrace_Message) XXX_Unmarshal ¶ added in v0.6.10
func (m *HttpBufferedTrace_Message) XXX_Unmarshal(b []byte) error
type HttpBufferedTrace_MessageValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e HttpBufferedTrace_MessageValidationError) Cause() error
Cause function returns cause value.
func (HttpBufferedTrace_MessageValidationError) Error ¶ added in v0.6.10
func (e HttpBufferedTrace_MessageValidationError) Error() string
Error satisfies the builtin error interface
func (HttpBufferedTrace_MessageValidationError) ErrorName ¶ added in v0.6.100
func (e HttpBufferedTrace_MessageValidationError) ErrorName() string
ErrorName returns error name.
func (HttpBufferedTrace_MessageValidationError) Field ¶ added in v0.6.10
func (e HttpBufferedTrace_MessageValidationError) Field() string
Field function returns field value.
func (HttpBufferedTrace_MessageValidationError) Key ¶ added in v0.6.10
func (e HttpBufferedTrace_MessageValidationError) Key() bool
Key function returns key value.
func (HttpBufferedTrace_MessageValidationError) Reason ¶ added in v0.6.10
func (e HttpBufferedTrace_MessageValidationError) Reason() string
Reason function returns reason value.
type HttpStreamedTraceSegment ¶ added in v0.6.10
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.
func (*HttpStreamedTraceSegment) Descriptor ¶ added in v0.6.10
func (*HttpStreamedTraceSegment) Descriptor() ([]byte, []int)
func (*HttpStreamedTraceSegment) GetMessagePiece ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) GetMessagePiece() isHttpStreamedTraceSegment_MessagePiece
func (*HttpStreamedTraceSegment) GetRequestBodyChunk ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) GetRequestBodyChunk() *Body
func (*HttpStreamedTraceSegment) GetRequestHeaders ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) GetRequestHeaders() *core.HeaderMap
func (*HttpStreamedTraceSegment) GetRequestTrailers ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) GetRequestTrailers() *core.HeaderMap
func (*HttpStreamedTraceSegment) GetResponseBodyChunk ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) GetResponseBodyChunk() *Body
func (*HttpStreamedTraceSegment) GetResponseHeaders ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) GetResponseHeaders() *core.HeaderMap
func (*HttpStreamedTraceSegment) GetResponseTrailers ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) GetResponseTrailers() *core.HeaderMap
func (*HttpStreamedTraceSegment) GetTraceId ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) GetTraceId() uint64
func (*HttpStreamedTraceSegment) Marshal ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) Marshal() (dAtA []byte, err error)
func (*HttpStreamedTraceSegment) MarshalTo ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)
func (*HttpStreamedTraceSegment) ProtoMessage ¶ added in v0.6.10
func (*HttpStreamedTraceSegment) ProtoMessage()
func (*HttpStreamedTraceSegment) Reset ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) Reset()
func (*HttpStreamedTraceSegment) Size ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) Size() (n int)
func (*HttpStreamedTraceSegment) String ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) String() string
func (*HttpStreamedTraceSegment) Unmarshal ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) Unmarshal(dAtA []byte) error
func (*HttpStreamedTraceSegment) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) XXX_DiscardUnknown()
func (*HttpStreamedTraceSegment) XXX_Marshal ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HttpStreamedTraceSegment) XXX_Merge ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) XXX_Merge(src proto.Message)
func (*HttpStreamedTraceSegment) XXX_OneofFuncs ¶ added in v0.6.10
func (*HttpStreamedTraceSegment) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*HttpStreamedTraceSegment) XXX_Size ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) XXX_Size() int
func (*HttpStreamedTraceSegment) XXX_Unmarshal ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment) XXX_Unmarshal(b []byte) error
type HttpStreamedTraceSegmentValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e HttpStreamedTraceSegmentValidationError) Cause() error
Cause function returns cause value.
func (HttpStreamedTraceSegmentValidationError) Error ¶ added in v0.6.10
func (e HttpStreamedTraceSegmentValidationError) Error() string
Error satisfies the builtin error interface
func (HttpStreamedTraceSegmentValidationError) ErrorName ¶ added in v0.6.100
func (e HttpStreamedTraceSegmentValidationError) ErrorName() string
ErrorName returns error name.
func (HttpStreamedTraceSegmentValidationError) Field ¶ added in v0.6.10
func (e HttpStreamedTraceSegmentValidationError) Field() string
Field function returns field value.
func (HttpStreamedTraceSegmentValidationError) Key ¶ added in v0.6.10
func (e HttpStreamedTraceSegmentValidationError) Key() bool
Key function returns key value.
func (HttpStreamedTraceSegmentValidationError) Reason ¶ added in v0.6.10
func (e HttpStreamedTraceSegmentValidationError) Reason() string
Reason function returns reason value.
type HttpStreamedTraceSegment_RequestBodyChunk ¶ added in v0.6.10
type HttpStreamedTraceSegment_RequestBodyChunk struct {
RequestBodyChunk *Body `protobuf:"bytes,3,opt,name=request_body_chunk,json=requestBodyChunk,proto3,oneof"`
}
func (*HttpStreamedTraceSegment_RequestBodyChunk) MarshalTo ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_RequestBodyChunk) MarshalTo(dAtA []byte) (int, error)
func (*HttpStreamedTraceSegment_RequestBodyChunk) Size ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_RequestBodyChunk) Size() (n int)
type HttpStreamedTraceSegment_RequestHeaders ¶ added in v0.6.10
type HttpStreamedTraceSegment_RequestHeaders struct {
RequestHeaders *core.HeaderMap `protobuf:"bytes,2,opt,name=request_headers,json=requestHeaders,proto3,oneof"`
}
func (*HttpStreamedTraceSegment_RequestHeaders) MarshalTo ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_RequestHeaders) MarshalTo(dAtA []byte) (int, error)
func (*HttpStreamedTraceSegment_RequestHeaders) Size ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_RequestHeaders) Size() (n int)
type HttpStreamedTraceSegment_RequestTrailers ¶ added in v0.6.10
type HttpStreamedTraceSegment_RequestTrailers struct {
RequestTrailers *core.HeaderMap `protobuf:"bytes,4,opt,name=request_trailers,json=requestTrailers,proto3,oneof"`
}
func (*HttpStreamedTraceSegment_RequestTrailers) MarshalTo ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_RequestTrailers) MarshalTo(dAtA []byte) (int, error)
func (*HttpStreamedTraceSegment_RequestTrailers) Size ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_RequestTrailers) Size() (n int)
type HttpStreamedTraceSegment_ResponseBodyChunk ¶ added in v0.6.10
type HttpStreamedTraceSegment_ResponseBodyChunk struct {
ResponseBodyChunk *Body `protobuf:"bytes,6,opt,name=response_body_chunk,json=responseBodyChunk,proto3,oneof"`
}
func (*HttpStreamedTraceSegment_ResponseBodyChunk) MarshalTo ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_ResponseBodyChunk) MarshalTo(dAtA []byte) (int, error)
func (*HttpStreamedTraceSegment_ResponseBodyChunk) Size ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_ResponseBodyChunk) Size() (n int)
type HttpStreamedTraceSegment_ResponseHeaders ¶ added in v0.6.10
type HttpStreamedTraceSegment_ResponseHeaders struct {
ResponseHeaders *core.HeaderMap `protobuf:"bytes,5,opt,name=response_headers,json=responseHeaders,proto3,oneof"`
}
func (*HttpStreamedTraceSegment_ResponseHeaders) MarshalTo ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_ResponseHeaders) MarshalTo(dAtA []byte) (int, error)
func (*HttpStreamedTraceSegment_ResponseHeaders) Size ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_ResponseHeaders) Size() (n int)
type HttpStreamedTraceSegment_ResponseTrailers ¶ added in v0.6.10
type HttpStreamedTraceSegment_ResponseTrailers struct {
ResponseTrailers *core.HeaderMap `protobuf:"bytes,7,opt,name=response_trailers,json=responseTrailers,proto3,oneof"`
}
func (*HttpStreamedTraceSegment_ResponseTrailers) MarshalTo ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_ResponseTrailers) MarshalTo(dAtA []byte) (int, error)
func (*HttpStreamedTraceSegment_ResponseTrailers) Size ¶ added in v0.6.10
func (m *HttpStreamedTraceSegment_ResponseTrailers) Size() (n int)
type SocketBufferedTrace ¶ added in v0.6.10
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.
func (*SocketBufferedTrace) Descriptor ¶ added in v0.6.10
func (*SocketBufferedTrace) Descriptor() ([]byte, []int)
func (*SocketBufferedTrace) GetConnection ¶ added in v0.6.10
func (m *SocketBufferedTrace) GetConnection() *Connection
func (*SocketBufferedTrace) GetEvents ¶ added in v0.6.10
func (m *SocketBufferedTrace) GetEvents() []*SocketEvent
func (*SocketBufferedTrace) GetReadTruncated ¶ added in v0.6.10
func (m *SocketBufferedTrace) GetReadTruncated() bool
func (*SocketBufferedTrace) GetTraceId ¶ added in v0.6.10
func (m *SocketBufferedTrace) GetTraceId() uint64
func (*SocketBufferedTrace) GetWriteTruncated ¶ added in v0.6.10
func (m *SocketBufferedTrace) GetWriteTruncated() bool
func (*SocketBufferedTrace) Marshal ¶ added in v0.6.10
func (m *SocketBufferedTrace) Marshal() (dAtA []byte, err error)
func (*SocketBufferedTrace) MarshalTo ¶ added in v0.6.10
func (m *SocketBufferedTrace) MarshalTo(dAtA []byte) (int, error)
func (*SocketBufferedTrace) ProtoMessage ¶ added in v0.6.10
func (*SocketBufferedTrace) ProtoMessage()
func (*SocketBufferedTrace) Reset ¶ added in v0.6.10
func (m *SocketBufferedTrace) Reset()
func (*SocketBufferedTrace) Size ¶ added in v0.6.10
func (m *SocketBufferedTrace) Size() (n int)
func (*SocketBufferedTrace) String ¶ added in v0.6.10
func (m *SocketBufferedTrace) String() string
func (*SocketBufferedTrace) Unmarshal ¶ added in v0.6.10
func (m *SocketBufferedTrace) Unmarshal(dAtA []byte) error
func (*SocketBufferedTrace) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *SocketBufferedTrace) XXX_DiscardUnknown()
func (*SocketBufferedTrace) XXX_Marshal ¶ added in v0.6.10
func (m *SocketBufferedTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SocketBufferedTrace) XXX_Merge ¶ added in v0.6.10
func (m *SocketBufferedTrace) XXX_Merge(src proto.Message)
func (*SocketBufferedTrace) XXX_Size ¶ added in v0.6.10
func (m *SocketBufferedTrace) XXX_Size() int
func (*SocketBufferedTrace) XXX_Unmarshal ¶ added in v0.6.10
func (m *SocketBufferedTrace) XXX_Unmarshal(b []byte) error
type SocketBufferedTraceValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e SocketBufferedTraceValidationError) Cause() error
Cause function returns cause value.
func (SocketBufferedTraceValidationError) Error ¶ added in v0.6.10
func (e SocketBufferedTraceValidationError) Error() string
Error satisfies the builtin error interface
func (SocketBufferedTraceValidationError) ErrorName ¶ added in v0.6.100
func (e SocketBufferedTraceValidationError) ErrorName() string
ErrorName returns error name.
func (SocketBufferedTraceValidationError) Field ¶ added in v0.6.10
func (e SocketBufferedTraceValidationError) Field() string
Field function returns field value.
func (SocketBufferedTraceValidationError) Key ¶ added in v0.6.10
func (e SocketBufferedTraceValidationError) Key() bool
Key function returns key value.
func (SocketBufferedTraceValidationError) Reason ¶ added in v0.6.10
func (e SocketBufferedTraceValidationError) Reason() string
Reason function returns reason value.
type SocketEvent ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (*SocketEvent) Descriptor() ([]byte, []int)
func (*SocketEvent) GetClosed ¶ added in v0.6.10
func (m *SocketEvent) GetClosed() *SocketEvent_Closed
func (*SocketEvent) GetEventSelector ¶ added in v0.6.10
func (m *SocketEvent) GetEventSelector() isSocketEvent_EventSelector
func (*SocketEvent) GetRead ¶ added in v0.6.10
func (m *SocketEvent) GetRead() *SocketEvent_Read
func (*SocketEvent) GetTimestamp ¶ added in v0.6.10
func (m *SocketEvent) GetTimestamp() *types.Timestamp
func (*SocketEvent) GetWrite ¶ added in v0.6.10
func (m *SocketEvent) GetWrite() *SocketEvent_Write
func (*SocketEvent) Marshal ¶ added in v0.6.10
func (m *SocketEvent) Marshal() (dAtA []byte, err error)
func (*SocketEvent) MarshalTo ¶ added in v0.6.10
func (m *SocketEvent) MarshalTo(dAtA []byte) (int, error)
func (*SocketEvent) ProtoMessage ¶ added in v0.6.10
func (*SocketEvent) ProtoMessage()
func (*SocketEvent) Reset ¶ added in v0.6.10
func (m *SocketEvent) Reset()
func (*SocketEvent) Size ¶ added in v0.6.10
func (m *SocketEvent) Size() (n int)
func (*SocketEvent) String ¶ added in v0.6.10
func (m *SocketEvent) String() string
func (*SocketEvent) Unmarshal ¶ added in v0.6.10
func (m *SocketEvent) Unmarshal(dAtA []byte) error
func (*SocketEvent) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *SocketEvent) XXX_DiscardUnknown()
func (*SocketEvent) XXX_Marshal ¶ added in v0.6.10
func (m *SocketEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SocketEvent) XXX_Merge ¶ added in v0.6.10
func (m *SocketEvent) XXX_Merge(src proto.Message)
func (*SocketEvent) XXX_OneofFuncs ¶ added in v0.6.10
func (*SocketEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*SocketEvent) XXX_Size ¶ added in v0.6.10
func (m *SocketEvent) XXX_Size() int
func (*SocketEvent) XXX_Unmarshal ¶ added in v0.6.10
func (m *SocketEvent) XXX_Unmarshal(b []byte) error
type SocketEventValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e SocketEventValidationError) Cause() error
Cause function returns cause value.
func (SocketEventValidationError) Error ¶ added in v0.6.10
func (e SocketEventValidationError) Error() string
Error satisfies the builtin error interface
func (SocketEventValidationError) ErrorName ¶ added in v0.6.100
func (e SocketEventValidationError) ErrorName() string
ErrorName returns error name.
func (SocketEventValidationError) Field ¶ added in v0.6.10
func (e SocketEventValidationError) Field() string
Field function returns field value.
func (SocketEventValidationError) Key ¶ added in v0.6.10
func (e SocketEventValidationError) Key() bool
Key function returns key value.
func (SocketEventValidationError) Reason ¶ added in v0.6.10
func (e SocketEventValidationError) Reason() string
Reason function returns reason value.
type SocketEvent_Closed ¶ added in v0.6.10
type SocketEvent_Closed struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The connection was closed.
func (*SocketEvent_Closed) Descriptor ¶ added in v0.6.10
func (*SocketEvent_Closed) Descriptor() ([]byte, []int)
func (*SocketEvent_Closed) Marshal ¶ added in v0.6.10
func (m *SocketEvent_Closed) Marshal() (dAtA []byte, err error)
func (*SocketEvent_Closed) MarshalTo ¶ added in v0.6.10
func (m *SocketEvent_Closed) MarshalTo(dAtA []byte) (int, error)
func (*SocketEvent_Closed) ProtoMessage ¶ added in v0.6.10
func (*SocketEvent_Closed) ProtoMessage()
func (*SocketEvent_Closed) Reset ¶ added in v0.6.10
func (m *SocketEvent_Closed) Reset()
func (*SocketEvent_Closed) Size ¶ added in v0.6.10
func (m *SocketEvent_Closed) Size() (n int)
func (*SocketEvent_Closed) String ¶ added in v0.6.10
func (m *SocketEvent_Closed) String() string
func (*SocketEvent_Closed) Unmarshal ¶ added in v0.6.10
func (m *SocketEvent_Closed) Unmarshal(dAtA []byte) error
func (*SocketEvent_Closed) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *SocketEvent_Closed) XXX_DiscardUnknown()
func (*SocketEvent_Closed) XXX_Marshal ¶ added in v0.6.10
func (m *SocketEvent_Closed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SocketEvent_Closed) XXX_Merge ¶ added in v0.6.10
func (m *SocketEvent_Closed) XXX_Merge(src proto.Message)
func (*SocketEvent_Closed) XXX_Size ¶ added in v0.6.10
func (m *SocketEvent_Closed) XXX_Size() int
func (*SocketEvent_Closed) XXX_Unmarshal ¶ added in v0.6.10
func (m *SocketEvent_Closed) XXX_Unmarshal(b []byte) error
type SocketEvent_ClosedValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e SocketEvent_ClosedValidationError) Cause() error
Cause function returns cause value.
func (SocketEvent_ClosedValidationError) Error ¶ added in v0.6.10
func (e SocketEvent_ClosedValidationError) Error() string
Error satisfies the builtin error interface
func (SocketEvent_ClosedValidationError) ErrorName ¶ added in v0.6.100
func (e SocketEvent_ClosedValidationError) ErrorName() string
ErrorName returns error name.
func (SocketEvent_ClosedValidationError) Field ¶ added in v0.6.10
func (e SocketEvent_ClosedValidationError) Field() string
Field function returns field value.
func (SocketEvent_ClosedValidationError) Key ¶ added in v0.6.10
func (e SocketEvent_ClosedValidationError) Key() bool
Key function returns key value.
func (SocketEvent_ClosedValidationError) Reason ¶ added in v0.6.10
func (e SocketEvent_ClosedValidationError) Reason() string
Reason function returns reason value.
type SocketEvent_Closed_ ¶ added in v0.6.10
type SocketEvent_Closed_ struct {
Closed *SocketEvent_Closed `protobuf:"bytes,4,opt,name=closed,proto3,oneof"`
}
func (*SocketEvent_Closed_) MarshalTo ¶ added in v0.6.10
func (m *SocketEvent_Closed_) MarshalTo(dAtA []byte) (int, error)
func (*SocketEvent_Closed_) Size ¶ added in v0.6.10
func (m *SocketEvent_Closed_) Size() (n int)
type SocketEvent_Read ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (*SocketEvent_Read) Descriptor() ([]byte, []int)
func (*SocketEvent_Read) GetData ¶ added in v0.6.10
func (m *SocketEvent_Read) GetData() *Body
func (*SocketEvent_Read) Marshal ¶ added in v0.6.10
func (m *SocketEvent_Read) Marshal() (dAtA []byte, err error)
func (*SocketEvent_Read) MarshalTo ¶ added in v0.6.10
func (m *SocketEvent_Read) MarshalTo(dAtA []byte) (int, error)
func (*SocketEvent_Read) ProtoMessage ¶ added in v0.6.10
func (*SocketEvent_Read) ProtoMessage()
func (*SocketEvent_Read) Reset ¶ added in v0.6.10
func (m *SocketEvent_Read) Reset()
func (*SocketEvent_Read) Size ¶ added in v0.6.10
func (m *SocketEvent_Read) Size() (n int)
func (*SocketEvent_Read) String ¶ added in v0.6.10
func (m *SocketEvent_Read) String() string
func (*SocketEvent_Read) Unmarshal ¶ added in v0.6.10
func (m *SocketEvent_Read) Unmarshal(dAtA []byte) error
func (*SocketEvent_Read) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *SocketEvent_Read) XXX_DiscardUnknown()
func (*SocketEvent_Read) XXX_Marshal ¶ added in v0.6.10
func (m *SocketEvent_Read) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SocketEvent_Read) XXX_Merge ¶ added in v0.6.10
func (m *SocketEvent_Read) XXX_Merge(src proto.Message)
func (*SocketEvent_Read) XXX_Size ¶ added in v0.6.10
func (m *SocketEvent_Read) XXX_Size() int
func (*SocketEvent_Read) XXX_Unmarshal ¶ added in v0.6.10
func (m *SocketEvent_Read) XXX_Unmarshal(b []byte) error
type SocketEvent_ReadValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e SocketEvent_ReadValidationError) Cause() error
Cause function returns cause value.
func (SocketEvent_ReadValidationError) Error ¶ added in v0.6.10
func (e SocketEvent_ReadValidationError) Error() string
Error satisfies the builtin error interface
func (SocketEvent_ReadValidationError) ErrorName ¶ added in v0.6.100
func (e SocketEvent_ReadValidationError) ErrorName() string
ErrorName returns error name.
func (SocketEvent_ReadValidationError) Field ¶ added in v0.6.10
func (e SocketEvent_ReadValidationError) Field() string
Field function returns field value.
func (SocketEvent_ReadValidationError) Key ¶ added in v0.6.10
func (e SocketEvent_ReadValidationError) Key() bool
Key function returns key value.
func (SocketEvent_ReadValidationError) Reason ¶ added in v0.6.10
func (e SocketEvent_ReadValidationError) Reason() string
Reason function returns reason value.
type SocketEvent_Read_ ¶ added in v0.6.10
type SocketEvent_Read_ struct {
Read *SocketEvent_Read `protobuf:"bytes,2,opt,name=read,proto3,oneof"`
}
func (*SocketEvent_Read_) MarshalTo ¶ added in v0.6.10
func (m *SocketEvent_Read_) MarshalTo(dAtA []byte) (int, error)
func (*SocketEvent_Read_) Size ¶ added in v0.6.10
func (m *SocketEvent_Read_) Size() (n int)
type SocketEvent_Write ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (*SocketEvent_Write) Descriptor() ([]byte, []int)
func (*SocketEvent_Write) GetData ¶ added in v0.6.10
func (m *SocketEvent_Write) GetData() *Body
func (*SocketEvent_Write) GetEndStream ¶ added in v0.6.10
func (m *SocketEvent_Write) GetEndStream() bool
func (*SocketEvent_Write) Marshal ¶ added in v0.6.10
func (m *SocketEvent_Write) Marshal() (dAtA []byte, err error)
func (*SocketEvent_Write) MarshalTo ¶ added in v0.6.10
func (m *SocketEvent_Write) MarshalTo(dAtA []byte) (int, error)
func (*SocketEvent_Write) ProtoMessage ¶ added in v0.6.10
func (*SocketEvent_Write) ProtoMessage()
func (*SocketEvent_Write) Reset ¶ added in v0.6.10
func (m *SocketEvent_Write) Reset()
func (*SocketEvent_Write) Size ¶ added in v0.6.10
func (m *SocketEvent_Write) Size() (n int)
func (*SocketEvent_Write) String ¶ added in v0.6.10
func (m *SocketEvent_Write) String() string
func (*SocketEvent_Write) Unmarshal ¶ added in v0.6.10
func (m *SocketEvent_Write) Unmarshal(dAtA []byte) error
func (*SocketEvent_Write) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *SocketEvent_Write) XXX_DiscardUnknown()
func (*SocketEvent_Write) XXX_Marshal ¶ added in v0.6.10
func (m *SocketEvent_Write) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SocketEvent_Write) XXX_Merge ¶ added in v0.6.10
func (m *SocketEvent_Write) XXX_Merge(src proto.Message)
func (*SocketEvent_Write) XXX_Size ¶ added in v0.6.10
func (m *SocketEvent_Write) XXX_Size() int
func (*SocketEvent_Write) XXX_Unmarshal ¶ added in v0.6.10
func (m *SocketEvent_Write) XXX_Unmarshal(b []byte) error
type SocketEvent_WriteValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e SocketEvent_WriteValidationError) Cause() error
Cause function returns cause value.
func (SocketEvent_WriteValidationError) Error ¶ added in v0.6.10
func (e SocketEvent_WriteValidationError) Error() string
Error satisfies the builtin error interface
func (SocketEvent_WriteValidationError) ErrorName ¶ added in v0.6.100
func (e SocketEvent_WriteValidationError) ErrorName() string
ErrorName returns error name.
func (SocketEvent_WriteValidationError) Field ¶ added in v0.6.10
func (e SocketEvent_WriteValidationError) Field() string
Field function returns field value.
func (SocketEvent_WriteValidationError) Key ¶ added in v0.6.10
func (e SocketEvent_WriteValidationError) Key() bool
Key function returns key value.
func (SocketEvent_WriteValidationError) Reason ¶ added in v0.6.10
func (e SocketEvent_WriteValidationError) Reason() string
Reason function returns reason value.
type SocketEvent_Write_ ¶ added in v0.6.10
type SocketEvent_Write_ struct {
Write *SocketEvent_Write `protobuf:"bytes,3,opt,name=write,proto3,oneof"`
}
func (*SocketEvent_Write_) MarshalTo ¶ added in v0.6.10
func (m *SocketEvent_Write_) MarshalTo(dAtA []byte) (int, error)
func (*SocketEvent_Write_) Size ¶ added in v0.6.10
func (m *SocketEvent_Write_) Size() (n int)
type SocketStreamedTraceSegment ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (*SocketStreamedTraceSegment) Descriptor() ([]byte, []int)
func (*SocketStreamedTraceSegment) GetConnection ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) GetConnection() *Connection
func (*SocketStreamedTraceSegment) GetEvent ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) GetEvent() *SocketEvent
func (*SocketStreamedTraceSegment) GetMessagePiece ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece
func (*SocketStreamedTraceSegment) GetTraceId ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) GetTraceId() uint64
func (*SocketStreamedTraceSegment) Marshal ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) Marshal() (dAtA []byte, err error)
func (*SocketStreamedTraceSegment) MarshalTo ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)
func (*SocketStreamedTraceSegment) ProtoMessage ¶ added in v0.6.10
func (*SocketStreamedTraceSegment) ProtoMessage()
func (*SocketStreamedTraceSegment) Reset ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) Reset()
func (*SocketStreamedTraceSegment) Size ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) Size() (n int)
func (*SocketStreamedTraceSegment) String ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) String() string
func (*SocketStreamedTraceSegment) Unmarshal ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) Unmarshal(dAtA []byte) error
func (*SocketStreamedTraceSegment) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) XXX_DiscardUnknown()
func (*SocketStreamedTraceSegment) XXX_Marshal ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SocketStreamedTraceSegment) XXX_Merge ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) XXX_Merge(src proto.Message)
func (*SocketStreamedTraceSegment) XXX_OneofFuncs ¶ added in v0.6.10
func (*SocketStreamedTraceSegment) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*SocketStreamedTraceSegment) XXX_Size ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) XXX_Size() int
func (*SocketStreamedTraceSegment) XXX_Unmarshal ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment) XXX_Unmarshal(b []byte) error
type SocketStreamedTraceSegmentValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e SocketStreamedTraceSegmentValidationError) Cause() error
Cause function returns cause value.
func (SocketStreamedTraceSegmentValidationError) Error ¶ added in v0.6.10
func (e SocketStreamedTraceSegmentValidationError) Error() string
Error satisfies the builtin error interface
func (SocketStreamedTraceSegmentValidationError) ErrorName ¶ added in v0.6.100
func (e SocketStreamedTraceSegmentValidationError) ErrorName() string
ErrorName returns error name.
func (SocketStreamedTraceSegmentValidationError) Field ¶ added in v0.6.10
func (e SocketStreamedTraceSegmentValidationError) Field() string
Field function returns field value.
func (SocketStreamedTraceSegmentValidationError) Key ¶ added in v0.6.10
func (e SocketStreamedTraceSegmentValidationError) Key() bool
Key function returns key value.
func (SocketStreamedTraceSegmentValidationError) Reason ¶ added in v0.6.10
func (e SocketStreamedTraceSegmentValidationError) Reason() string
Reason function returns reason value.
type SocketStreamedTraceSegment_Connection ¶ added in v0.6.10
type SocketStreamedTraceSegment_Connection struct {
Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3,oneof"`
}
func (*SocketStreamedTraceSegment_Connection) MarshalTo ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment_Connection) MarshalTo(dAtA []byte) (int, error)
func (*SocketStreamedTraceSegment_Connection) Size ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment_Connection) Size() (n int)
type SocketStreamedTraceSegment_Event ¶ added in v0.6.10
type SocketStreamedTraceSegment_Event struct {
Event *SocketEvent `protobuf:"bytes,3,opt,name=event,proto3,oneof"`
}
func (*SocketStreamedTraceSegment_Event) MarshalTo ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment_Event) MarshalTo(dAtA []byte) (int, error)
func (*SocketStreamedTraceSegment_Event) Size ¶ added in v0.6.10
func (m *SocketStreamedTraceSegment_Event) Size() (n int)
type TraceWrapper ¶ added in v0.6.10
type TraceWrapper struct { // if trace is streaming, this may only be sent once. Destination *TraceWrapper_Destination `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"` DownstreamRemoteAddress *core.Address `` /* 132-byte string literal not displayed */ // 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 ¶ added in v0.6.10
func (*TraceWrapper) Descriptor() ([]byte, []int)
func (*TraceWrapper) GetDestination ¶ added in v0.6.100
func (m *TraceWrapper) GetDestination() *TraceWrapper_Destination
func (*TraceWrapper) GetDownstreamRemoteAddress ¶ added in v0.6.100
func (m *TraceWrapper) GetDownstreamRemoteAddress() *core.Address
func (*TraceWrapper) GetHttpBufferedTrace ¶ added in v0.6.10
func (m *TraceWrapper) GetHttpBufferedTrace() *HttpBufferedTrace
func (*TraceWrapper) GetHttpStreamedTraceSegment ¶ added in v0.6.10
func (m *TraceWrapper) GetHttpStreamedTraceSegment() *HttpStreamedTraceSegment
func (*TraceWrapper) GetSocketBufferedTrace ¶ added in v0.6.10
func (m *TraceWrapper) GetSocketBufferedTrace() *SocketBufferedTrace
func (*TraceWrapper) GetSocketStreamedTraceSegment ¶ added in v0.6.10
func (m *TraceWrapper) GetSocketStreamedTraceSegment() *SocketStreamedTraceSegment
func (*TraceWrapper) GetTrace ¶ added in v0.6.10
func (m *TraceWrapper) GetTrace() isTraceWrapper_Trace
func (*TraceWrapper) Marshal ¶ added in v0.6.10
func (m *TraceWrapper) Marshal() (dAtA []byte, err error)
func (*TraceWrapper) MarshalTo ¶ added in v0.6.10
func (m *TraceWrapper) MarshalTo(dAtA []byte) (int, error)
func (*TraceWrapper) ProtoMessage ¶ added in v0.6.10
func (*TraceWrapper) ProtoMessage()
func (*TraceWrapper) Reset ¶ added in v0.6.10
func (m *TraceWrapper) Reset()
func (*TraceWrapper) Size ¶ added in v0.6.10
func (m *TraceWrapper) Size() (n int)
func (*TraceWrapper) String ¶ added in v0.6.10
func (m *TraceWrapper) String() string
func (*TraceWrapper) Unmarshal ¶ added in v0.6.10
func (m *TraceWrapper) Unmarshal(dAtA []byte) error
func (*TraceWrapper) Validate ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (m *TraceWrapper) XXX_DiscardUnknown()
func (*TraceWrapper) XXX_Marshal ¶ added in v0.6.10
func (m *TraceWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TraceWrapper) XXX_Merge ¶ added in v0.6.10
func (m *TraceWrapper) XXX_Merge(src proto.Message)
func (*TraceWrapper) XXX_OneofFuncs ¶ added in v0.6.10
func (*TraceWrapper) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*TraceWrapper) XXX_Size ¶ added in v0.6.10
func (m *TraceWrapper) XXX_Size() int
func (*TraceWrapper) XXX_Unmarshal ¶ added in v0.6.10
func (m *TraceWrapper) XXX_Unmarshal(b []byte) error
type TraceWrapperValidationError ¶ added in v0.6.10
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 ¶ added in v0.6.10
func (e TraceWrapperValidationError) Cause() error
Cause function returns cause value.
func (TraceWrapperValidationError) Error ¶ added in v0.6.10
func (e TraceWrapperValidationError) Error() string
Error satisfies the builtin error interface
func (TraceWrapperValidationError) ErrorName ¶ added in v0.6.100
func (e TraceWrapperValidationError) ErrorName() string
ErrorName returns error name.
func (TraceWrapperValidationError) Field ¶ added in v0.6.10
func (e TraceWrapperValidationError) Field() string
Field function returns field value.
func (TraceWrapperValidationError) Key ¶ added in v0.6.10
func (e TraceWrapperValidationError) Key() bool
Key function returns key value.
func (TraceWrapperValidationError) Reason ¶ added in v0.6.10
func (e TraceWrapperValidationError) Reason() string
Reason function returns reason value.
type TraceWrapper_Destination ¶ added in v0.6.100
type TraceWrapper_Destination struct { ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` ClusterMetadata *types.Struct `protobuf:"bytes,2,opt,name=cluster_metadata,json=clusterMetadata,proto3" json:"cluster_metadata,omitempty"` HostAddress *core.Address `protobuf:"bytes,3,opt,name=host_address,json=hostAddress,proto3" json:"host_address,omitempty"` HostMetadata *types.Struct `protobuf:"bytes,4,opt,name=host_metadata,json=hostMetadata,proto3" json:"host_metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TraceWrapper_Destination) Descriptor ¶ added in v0.6.100
func (*TraceWrapper_Destination) Descriptor() ([]byte, []int)
func (*TraceWrapper_Destination) GetClusterMetadata ¶ added in v0.6.100
func (m *TraceWrapper_Destination) GetClusterMetadata() *types.Struct
func (*TraceWrapper_Destination) GetClusterName ¶ added in v0.6.100
func (m *TraceWrapper_Destination) GetClusterName() string
func (*TraceWrapper_Destination) GetHostAddress ¶ added in v0.6.100
func (m *TraceWrapper_Destination) GetHostAddress() *core.Address
func (*TraceWrapper_Destination) GetHostMetadata ¶ added in v0.6.100
func (m *TraceWrapper_Destination) GetHostMetadata() *types.Struct
func (*TraceWrapper_Destination) Marshal ¶ added in v0.6.100
func (m *TraceWrapper_Destination) Marshal() (dAtA []byte, err error)
func (*TraceWrapper_Destination) MarshalTo ¶ added in v0.6.100
func (m *TraceWrapper_Destination) MarshalTo(dAtA []byte) (int, error)
func (*TraceWrapper_Destination) ProtoMessage ¶ added in v0.6.100
func (*TraceWrapper_Destination) ProtoMessage()
func (*TraceWrapper_Destination) Reset ¶ added in v0.6.100
func (m *TraceWrapper_Destination) Reset()
func (*TraceWrapper_Destination) Size ¶ added in v0.6.100
func (m *TraceWrapper_Destination) Size() (n int)
func (*TraceWrapper_Destination) String ¶ added in v0.6.100
func (m *TraceWrapper_Destination) String() string
func (*TraceWrapper_Destination) Unmarshal ¶ added in v0.6.100
func (m *TraceWrapper_Destination) Unmarshal(dAtA []byte) error
func (*TraceWrapper_Destination) Validate ¶ added in v0.6.100
func (m *TraceWrapper_Destination) Validate() error
Validate checks the field values on TraceWrapper_Destination with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*TraceWrapper_Destination) XXX_DiscardUnknown ¶ added in v0.6.100
func (m *TraceWrapper_Destination) XXX_DiscardUnknown()
func (*TraceWrapper_Destination) XXX_Marshal ¶ added in v0.6.100
func (m *TraceWrapper_Destination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TraceWrapper_Destination) XXX_Merge ¶ added in v0.6.100
func (m *TraceWrapper_Destination) XXX_Merge(src proto.Message)
func (*TraceWrapper_Destination) XXX_Size ¶ added in v0.6.100
func (m *TraceWrapper_Destination) XXX_Size() int
func (*TraceWrapper_Destination) XXX_Unmarshal ¶ added in v0.6.100
func (m *TraceWrapper_Destination) XXX_Unmarshal(b []byte) error
type TraceWrapper_DestinationValidationError ¶ added in v0.6.100
type TraceWrapper_DestinationValidationError struct {
// contains filtered or unexported fields
}
TraceWrapper_DestinationValidationError is the validation error returned by TraceWrapper_Destination.Validate if the designated constraints aren't met.
func (TraceWrapper_DestinationValidationError) Cause ¶ added in v0.6.100
func (e TraceWrapper_DestinationValidationError) Cause() error
Cause function returns cause value.
func (TraceWrapper_DestinationValidationError) Error ¶ added in v0.6.100
func (e TraceWrapper_DestinationValidationError) Error() string
Error satisfies the builtin error interface
func (TraceWrapper_DestinationValidationError) ErrorName ¶ added in v0.6.100
func (e TraceWrapper_DestinationValidationError) ErrorName() string
ErrorName returns error name.
func (TraceWrapper_DestinationValidationError) Field ¶ added in v0.6.100
func (e TraceWrapper_DestinationValidationError) Field() string
Field function returns field value.
func (TraceWrapper_DestinationValidationError) Key ¶ added in v0.6.100
func (e TraceWrapper_DestinationValidationError) Key() bool
Key function returns key value.
func (TraceWrapper_DestinationValidationError) Reason ¶ added in v0.6.100
func (e TraceWrapper_DestinationValidationError) Reason() string
Reason function returns reason value.
type TraceWrapper_HttpBufferedTrace ¶ added in v0.6.10
type TraceWrapper_HttpBufferedTrace struct {
HttpBufferedTrace *HttpBufferedTrace `protobuf:"bytes,1,opt,name=http_buffered_trace,json=httpBufferedTrace,proto3,oneof"`
}
func (*TraceWrapper_HttpBufferedTrace) MarshalTo ¶ added in v0.6.10
func (m *TraceWrapper_HttpBufferedTrace) MarshalTo(dAtA []byte) (int, error)
func (*TraceWrapper_HttpBufferedTrace) Size ¶ added in v0.6.10
func (m *TraceWrapper_HttpBufferedTrace) Size() (n int)
type TraceWrapper_HttpStreamedTraceSegment ¶ added in v0.6.10
type TraceWrapper_HttpStreamedTraceSegment struct {
HttpStreamedTraceSegment *HttpStreamedTraceSegment `protobuf:"bytes,2,opt,name=http_streamed_trace_segment,json=httpStreamedTraceSegment,proto3,oneof"`
}
func (*TraceWrapper_HttpStreamedTraceSegment) MarshalTo ¶ added in v0.6.10
func (m *TraceWrapper_HttpStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)
func (*TraceWrapper_HttpStreamedTraceSegment) Size ¶ added in v0.6.10
func (m *TraceWrapper_HttpStreamedTraceSegment) Size() (n int)
type TraceWrapper_SocketBufferedTrace ¶ added in v0.6.10
type TraceWrapper_SocketBufferedTrace struct {
SocketBufferedTrace *SocketBufferedTrace `protobuf:"bytes,3,opt,name=socket_buffered_trace,json=socketBufferedTrace,proto3,oneof"`
}
func (*TraceWrapper_SocketBufferedTrace) MarshalTo ¶ added in v0.6.10
func (m *TraceWrapper_SocketBufferedTrace) MarshalTo(dAtA []byte) (int, error)
func (*TraceWrapper_SocketBufferedTrace) Size ¶ added in v0.6.10
func (m *TraceWrapper_SocketBufferedTrace) Size() (n int)
type TraceWrapper_SocketStreamedTraceSegment ¶ added in v0.6.10
type TraceWrapper_SocketStreamedTraceSegment struct {
SocketStreamedTraceSegment *SocketStreamedTraceSegment `protobuf:"bytes,4,opt,name=socket_streamed_trace_segment,json=socketStreamedTraceSegment,proto3,oneof"`
}
func (*TraceWrapper_SocketStreamedTraceSegment) MarshalTo ¶ added in v0.6.10
func (m *TraceWrapper_SocketStreamedTraceSegment) MarshalTo(dAtA []byte) (int, error)
func (*TraceWrapper_SocketStreamedTraceSegment) Size ¶ added in v0.6.10
func (m *TraceWrapper_SocketStreamedTraceSegment) Size() (n int)