v2

package
v0.6.9 Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2019 License: Apache-2.0 Imports: 16 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 added in v0.6.8 

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.8 

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

func (*Body) GetAsBytes added in v0.6.8 

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

func (*Body) GetAsString added in v0.6.8 

func (m *Body) GetAsString() string

func (*Body) GetBodyType added in v0.6.8 

func (m *Body) GetBodyType() isBody_BodyType

func (*Body) GetTruncated added in v0.6.8 

func (m *Body) GetTruncated() bool

func (*Body) Marshal added in v0.6.8 

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

func (*Body) MarshalTo added in v0.6.8 

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

func (*Body) ProtoMessage added in v0.6.8 

func (*Body) ProtoMessage()

func (*Body) Reset added in v0.6.8 

func (m *Body) Reset()

func (*Body) Size added in v0.6.8 

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

func (*Body) String added in v0.6.8 

func (m *Body) String() string

func (*Body) Unmarshal added in v0.6.8 

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

func (*Body) Validate added in v0.6.8 

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 added in v0.6.8 

func (m *Body) XXX_DiscardUnknown()

func (*Body) XXX_Marshal added in v0.6.8 

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

func (*Body) XXX_Merge added in v0.6.8 

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

func (*Body) XXX_OneofFuncs added in v0.6.8 

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_Size added in v0.6.8 

func (m *Body) XXX_Size() int

func (*Body) XXX_Unmarshal added in v0.6.8 

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

type BodyValidationError added in v0.6.8 

type BodyValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (BodyValidationError) Error added in v0.6.8 

func (e BodyValidationError) Error() string

Error satisfies the builtin error interface

type Body_AsBytes added in v0.6.8 

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.8 

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

func (*Body_AsBytes) Size added in v0.6.8 

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

type Body_AsString added in v0.6.8 

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.8 

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

func (*Body_AsString) Size added in v0.6.8 

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) 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 {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (ConnectionValidationError) Error 

func (e ConnectionValidationError) Error() string

Error satisfies the builtin error interface

type HttpBufferedTrace added in v0.6.8 

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.8 

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

func (*HttpBufferedTrace) GetRequest added in v0.6.8 

func (m *HttpBufferedTrace) GetRequest() *HttpBufferedTrace_Message

func (*HttpBufferedTrace) GetResponse added in v0.6.8 

func (m *HttpBufferedTrace) GetResponse() *HttpBufferedTrace_Message

func (*HttpBufferedTrace) Marshal added in v0.6.8 

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

func (*HttpBufferedTrace) MarshalTo added in v0.6.8 

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

func (*HttpBufferedTrace) ProtoMessage added in v0.6.8 

func (*HttpBufferedTrace) ProtoMessage()

func (*HttpBufferedTrace) Reset added in v0.6.8 

func (m *HttpBufferedTrace) Reset()

func (*HttpBufferedTrace) Size added in v0.6.8 

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

func (*HttpBufferedTrace) String added in v0.6.8 

func (m *HttpBufferedTrace) String() string

func (*HttpBufferedTrace) Unmarshal added in v0.6.8 

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

func (*HttpBufferedTrace) Validate added in v0.6.8 

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.8 

func (m *HttpBufferedTrace) XXX_DiscardUnknown()

func (*HttpBufferedTrace) XXX_Marshal added in v0.6.8 

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

func (*HttpBufferedTrace) XXX_Merge added in v0.6.8 

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

func (*HttpBufferedTrace) XXX_Size added in v0.6.8 

func (m *HttpBufferedTrace) XXX_Size() int

func (*HttpBufferedTrace) XXX_Unmarshal added in v0.6.8 

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

type HttpBufferedTraceValidationError added in v0.6.8 

type HttpBufferedTraceValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (HttpBufferedTraceValidationError) Error added in v0.6.8 

func (e HttpBufferedTraceValidationError) Error() string

Error satisfies the builtin error interface

type HttpBufferedTrace_Message added in v0.6.8 

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.8 

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

func (*HttpBufferedTrace_Message) GetBody added in v0.6.8 

func (m *HttpBufferedTrace_Message) GetBody() *Body

func (*HttpBufferedTrace_Message) GetHeaders added in v0.6.8 

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

func (*HttpBufferedTrace_Message) GetTrailers added in v0.6.8 

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

func (*HttpBufferedTrace_Message) Marshal added in v0.6.8 

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

func (*HttpBufferedTrace_Message) MarshalTo added in v0.6.8 

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

func (*HttpBufferedTrace_Message) ProtoMessage added in v0.6.8 

func (*HttpBufferedTrace_Message) ProtoMessage()

func (*HttpBufferedTrace_Message) Reset added in v0.6.8 

func (m *HttpBufferedTrace_Message) Reset()

func (*HttpBufferedTrace_Message) Size added in v0.6.8 

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

func (*HttpBufferedTrace_Message) String added in v0.6.8 

func (m *HttpBufferedTrace_Message) String() string

func (*HttpBufferedTrace_Message) Unmarshal added in v0.6.8 

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

func (*HttpBufferedTrace_Message) Validate added in v0.6.8 

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.8 

func (m *HttpBufferedTrace_Message) XXX_DiscardUnknown()

func (*HttpBufferedTrace_Message) XXX_Marshal added in v0.6.8 

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

func (*HttpBufferedTrace_Message) XXX_Merge added in v0.6.8 

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

func (*HttpBufferedTrace_Message) XXX_Size added in v0.6.8 

func (m *HttpBufferedTrace_Message) XXX_Size() int

func (*HttpBufferedTrace_Message) XXX_Unmarshal added in v0.6.8 

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

type HttpBufferedTrace_MessageValidationError added in v0.6.8 

type HttpBufferedTrace_MessageValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (HttpBufferedTrace_MessageValidationError) Error added in v0.6.8 

func (e HttpBufferedTrace_MessageValidationError) Error() string

Error satisfies the builtin error interface

type HttpStreamedTraceSegment added in v0.6.9 

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.9 

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

func (*HttpStreamedTraceSegment) GetMessagePiece added in v0.6.9 

func (m *HttpStreamedTraceSegment) GetMessagePiece() isHttpStreamedTraceSegment_MessagePiece

func (*HttpStreamedTraceSegment) GetRequestBodyChunk added in v0.6.9 

func (m *HttpStreamedTraceSegment) GetRequestBodyChunk() *Body

func (*HttpStreamedTraceSegment) GetRequestHeaders added in v0.6.9 

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

func (*HttpStreamedTraceSegment) GetRequestTrailers added in v0.6.9 

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

func (*HttpStreamedTraceSegment) GetResponseBodyChunk added in v0.6.9 

func (m *HttpStreamedTraceSegment) GetResponseBodyChunk() *Body

func (*HttpStreamedTraceSegment) GetResponseHeaders added in v0.6.9 

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

func (*HttpStreamedTraceSegment) GetResponseTrailers added in v0.6.9 

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

func (*HttpStreamedTraceSegment) GetTraceId added in v0.6.9 

func (m *HttpStreamedTraceSegment) GetTraceId() uint64

func (*HttpStreamedTraceSegment) Marshal added in v0.6.9 

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

func (*HttpStreamedTraceSegment) MarshalTo added in v0.6.9 

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

func (*HttpStreamedTraceSegment) ProtoMessage added in v0.6.9 

func (*HttpStreamedTraceSegment) ProtoMessage()

func (*HttpStreamedTraceSegment) Reset added in v0.6.9 

func (m *HttpStreamedTraceSegment) Reset()

func (*HttpStreamedTraceSegment) Size added in v0.6.9 

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

func (*HttpStreamedTraceSegment) String added in v0.6.9 

func (m *HttpStreamedTraceSegment) String() string

func (*HttpStreamedTraceSegment) Unmarshal added in v0.6.9 

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

func (*HttpStreamedTraceSegment) Validate added in v0.6.9 

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.9 

func (m *HttpStreamedTraceSegment) XXX_DiscardUnknown()

func (*HttpStreamedTraceSegment) XXX_Marshal added in v0.6.9 

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

func (*HttpStreamedTraceSegment) XXX_Merge added in v0.6.9 

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

func (*HttpStreamedTraceSegment) XXX_OneofFuncs added in v0.6.9 

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.9 

func (m *HttpStreamedTraceSegment) XXX_Size() int

func (*HttpStreamedTraceSegment) XXX_Unmarshal added in v0.6.9 

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

type HttpStreamedTraceSegmentValidationError added in v0.6.9 

type HttpStreamedTraceSegmentValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (HttpStreamedTraceSegmentValidationError) Error added in v0.6.9 

func (e HttpStreamedTraceSegmentValidationError) Error() string

Error satisfies the builtin error interface

type HttpStreamedTraceSegment_RequestBodyChunk added in v0.6.9 

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.9 

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

func (*HttpStreamedTraceSegment_RequestBodyChunk) Size added in v0.6.9 

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

type HttpStreamedTraceSegment_RequestHeaders added in v0.6.9 

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.9 

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

func (*HttpStreamedTraceSegment_RequestHeaders) Size added in v0.6.9 

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

type HttpStreamedTraceSegment_RequestTrailers added in v0.6.9 

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.9 

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

func (*HttpStreamedTraceSegment_RequestTrailers) Size added in v0.6.9 

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

type HttpStreamedTraceSegment_ResponseBodyChunk added in v0.6.9 

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.9 

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

func (*HttpStreamedTraceSegment_ResponseBodyChunk) Size added in v0.6.9 

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

type HttpStreamedTraceSegment_ResponseHeaders added in v0.6.9 

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.9 

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

func (*HttpStreamedTraceSegment_ResponseHeaders) Size added in v0.6.9 

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

type HttpStreamedTraceSegment_ResponseTrailers added in v0.6.9 

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.9 

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

func (*HttpStreamedTraceSegment_ResponseTrailers) Size added in v0.6.9 

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

type SocketBufferedTrace added in v0.6.9 

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.9 

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

func (*SocketBufferedTrace) GetConnection added in v0.6.9 

func (m *SocketBufferedTrace) GetConnection() *Connection

func (*SocketBufferedTrace) GetEvents added in v0.6.9 

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

func (*SocketBufferedTrace) GetReadTruncated added in v0.6.9 

func (m *SocketBufferedTrace) GetReadTruncated() bool

func (*SocketBufferedTrace) GetTraceId added in v0.6.9 

func (m *SocketBufferedTrace) GetTraceId() uint64

func (*SocketBufferedTrace) GetWriteTruncated added in v0.6.9 

func (m *SocketBufferedTrace) GetWriteTruncated() bool

func (*SocketBufferedTrace) Marshal added in v0.6.9 

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

func (*SocketBufferedTrace) MarshalTo added in v0.6.9 

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

func (*SocketBufferedTrace) ProtoMessage added in v0.6.9 

func (*SocketBufferedTrace) ProtoMessage()

func (*SocketBufferedTrace) Reset added in v0.6.9 

func (m *SocketBufferedTrace) Reset()

func (*SocketBufferedTrace) Size added in v0.6.9 

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

func (*SocketBufferedTrace) String added in v0.6.9 

func (m *SocketBufferedTrace) String() string

func (*SocketBufferedTrace) Unmarshal added in v0.6.9 

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

func (*SocketBufferedTrace) Validate added in v0.6.9 

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.9 

func (m *SocketBufferedTrace) XXX_DiscardUnknown()

func (*SocketBufferedTrace) XXX_Marshal added in v0.6.9 

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

func (*SocketBufferedTrace) XXX_Merge added in v0.6.9 

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

func (*SocketBufferedTrace) XXX_Size added in v0.6.9 

func (m *SocketBufferedTrace) XXX_Size() int

func (*SocketBufferedTrace) XXX_Unmarshal added in v0.6.9 

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

type SocketBufferedTraceValidationError added in v0.6.9 

type SocketBufferedTraceValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (SocketBufferedTraceValidationError) Error added in v0.6.9 

func (e SocketBufferedTraceValidationError) Error() string

Error satisfies the builtin error interface

type SocketEvent added in v0.6.8 

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.8 

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

func (*SocketEvent) GetClosed added in v0.6.9 

func (m *SocketEvent) GetClosed() *SocketEvent_Closed

func (*SocketEvent) GetEventSelector added in v0.6.8 

func (m *SocketEvent) GetEventSelector() isSocketEvent_EventSelector

func (*SocketEvent) GetRead added in v0.6.8 

func (m *SocketEvent) GetRead() *SocketEvent_Read

func (*SocketEvent) GetTimestamp added in v0.6.8 

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

func (*SocketEvent) GetWrite added in v0.6.8 

func (m *SocketEvent) GetWrite() *SocketEvent_Write

func (*SocketEvent) Marshal added in v0.6.8 

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

func (*SocketEvent) MarshalTo added in v0.6.8 

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

func (*SocketEvent) ProtoMessage added in v0.6.8 

func (*SocketEvent) ProtoMessage()

func (*SocketEvent) Reset added in v0.6.8 

func (m *SocketEvent) Reset()

func (*SocketEvent) Size added in v0.6.8 

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

func (*SocketEvent) String added in v0.6.8 

func (m *SocketEvent) String() string

func (*SocketEvent) Unmarshal added in v0.6.8 

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

func (*SocketEvent) Validate added in v0.6.8 

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.8 

func (m *SocketEvent) XXX_DiscardUnknown()

func (*SocketEvent) XXX_Marshal added in v0.6.8 

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

func (*SocketEvent) XXX_Merge added in v0.6.8 

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

func (*SocketEvent) XXX_OneofFuncs added in v0.6.8 

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.8 

func (m *SocketEvent) XXX_Size() int

func (*SocketEvent) XXX_Unmarshal added in v0.6.8 

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

type SocketEventValidationError added in v0.6.8 

type SocketEventValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (SocketEventValidationError) Error added in v0.6.8 

func (e SocketEventValidationError) Error() string

Error satisfies the builtin error interface

type SocketEvent_Closed added in v0.6.9 

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.9 

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

func (*SocketEvent_Closed) Marshal added in v0.6.9 

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

func (*SocketEvent_Closed) MarshalTo added in v0.6.9 

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

func (*SocketEvent_Closed) ProtoMessage added in v0.6.9 

func (*SocketEvent_Closed) ProtoMessage()

func (*SocketEvent_Closed) Reset added in v0.6.9 

func (m *SocketEvent_Closed) Reset()

func (*SocketEvent_Closed) Size added in v0.6.9 

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

func (*SocketEvent_Closed) String added in v0.6.9 

func (m *SocketEvent_Closed) String() string

func (*SocketEvent_Closed) Unmarshal added in v0.6.9 

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

func (*SocketEvent_Closed) Validate added in v0.6.9 

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.9 

func (m *SocketEvent_Closed) XXX_DiscardUnknown()

func (*SocketEvent_Closed) XXX_Marshal added in v0.6.9 

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

func (*SocketEvent_Closed) XXX_Merge added in v0.6.9 

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

func (*SocketEvent_Closed) XXX_Size added in v0.6.9 

func (m *SocketEvent_Closed) XXX_Size() int

func (*SocketEvent_Closed) XXX_Unmarshal added in v0.6.9 

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

type SocketEvent_ClosedValidationError added in v0.6.9 

type SocketEvent_ClosedValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (SocketEvent_ClosedValidationError) Error added in v0.6.9 

func (e SocketEvent_ClosedValidationError) Error() string

Error satisfies the builtin error interface

type SocketEvent_Closed_ added in v0.6.9 

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

func (*SocketEvent_Closed_) MarshalTo added in v0.6.9 

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

func (*SocketEvent_Closed_) Size added in v0.6.9 

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

type SocketEvent_Read added in v0.6.8 

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.8 

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

func (*SocketEvent_Read) GetData added in v0.6.8 

func (m *SocketEvent_Read) GetData() *Body

func (*SocketEvent_Read) Marshal added in v0.6.8 

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

func (*SocketEvent_Read) MarshalTo added in v0.6.8 

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

func (*SocketEvent_Read) ProtoMessage added in v0.6.8 

func (*SocketEvent_Read) ProtoMessage()

func (*SocketEvent_Read) Reset added in v0.6.8 

func (m *SocketEvent_Read) Reset()

func (*SocketEvent_Read) Size added in v0.6.8 

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

func (*SocketEvent_Read) String added in v0.6.8 

func (m *SocketEvent_Read) String() string

func (*SocketEvent_Read) Unmarshal added in v0.6.8 

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

func (*SocketEvent_Read) Validate added in v0.6.8 

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.8 

func (m *SocketEvent_Read) XXX_DiscardUnknown()

func (*SocketEvent_Read) XXX_Marshal added in v0.6.8 

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

func (*SocketEvent_Read) XXX_Merge added in v0.6.8 

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

func (*SocketEvent_Read) XXX_Size added in v0.6.8 

func (m *SocketEvent_Read) XXX_Size() int

func (*SocketEvent_Read) XXX_Unmarshal added in v0.6.8 

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

type SocketEvent_ReadValidationError added in v0.6.8 

type SocketEvent_ReadValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (SocketEvent_ReadValidationError) Error added in v0.6.8 

func (e SocketEvent_ReadValidationError) Error() string

Error satisfies the builtin error interface

type SocketEvent_Read_ added in v0.6.8 

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

func (*SocketEvent_Read_) MarshalTo added in v0.6.8 

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

func (*SocketEvent_Read_) Size added in v0.6.8 

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

type SocketEvent_Write added in v0.6.8 

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.8 

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

func (*SocketEvent_Write) GetData added in v0.6.8 

func (m *SocketEvent_Write) GetData() *Body

func (*SocketEvent_Write) GetEndStream added in v0.6.8 

func (m *SocketEvent_Write) GetEndStream() bool

func (*SocketEvent_Write) Marshal added in v0.6.8 

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

func (*SocketEvent_Write) MarshalTo added in v0.6.8 

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

func (*SocketEvent_Write) ProtoMessage added in v0.6.8 

func (*SocketEvent_Write) ProtoMessage()

func (*SocketEvent_Write) Reset added in v0.6.8 

func (m *SocketEvent_Write) Reset()

func (*SocketEvent_Write) Size added in v0.6.8 

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

func (*SocketEvent_Write) String added in v0.6.8 

func (m *SocketEvent_Write) String() string

func (*SocketEvent_Write) Unmarshal added in v0.6.8 

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

func (*SocketEvent_Write) Validate added in v0.6.8 

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.8 

func (m *SocketEvent_Write) XXX_DiscardUnknown()

func (*SocketEvent_Write) XXX_Marshal added in v0.6.8 

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

func (*SocketEvent_Write) XXX_Merge added in v0.6.8 

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

func (*SocketEvent_Write) XXX_Size added in v0.6.8 

func (m *SocketEvent_Write) XXX_Size() int

func (*SocketEvent_Write) XXX_Unmarshal added in v0.6.8 

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

type SocketEvent_WriteValidationError added in v0.6.8 

type SocketEvent_WriteValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (SocketEvent_WriteValidationError) Error added in v0.6.8 

func (e SocketEvent_WriteValidationError) Error() string

Error satisfies the builtin error interface

type SocketEvent_Write_ added in v0.6.8 

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

func (*SocketEvent_Write_) MarshalTo added in v0.6.8 

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

func (*SocketEvent_Write_) Size added in v0.6.8 

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

type SocketStreamedTraceSegment added in v0.6.9 

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.9 

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

func (*SocketStreamedTraceSegment) GetConnection added in v0.6.9 

func (m *SocketStreamedTraceSegment) GetConnection() *Connection

func (*SocketStreamedTraceSegment) GetEvent added in v0.6.9 

func (m *SocketStreamedTraceSegment) GetEvent() *SocketEvent

func (*SocketStreamedTraceSegment) GetMessagePiece added in v0.6.9 

func (m *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece

func (*SocketStreamedTraceSegment) GetTraceId added in v0.6.9 

func (m *SocketStreamedTraceSegment) GetTraceId() uint64

func (*SocketStreamedTraceSegment) Marshal added in v0.6.9 

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

func (*SocketStreamedTraceSegment) MarshalTo added in v0.6.9 

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

func (*SocketStreamedTraceSegment) ProtoMessage added in v0.6.9 

func (*SocketStreamedTraceSegment) ProtoMessage()

func (*SocketStreamedTraceSegment) Reset added in v0.6.9 

func (m *SocketStreamedTraceSegment) Reset()

func (*SocketStreamedTraceSegment) Size added in v0.6.9 

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

func (*SocketStreamedTraceSegment) String added in v0.6.9 

func (m *SocketStreamedTraceSegment) String() string

func (*SocketStreamedTraceSegment) Unmarshal added in v0.6.9 

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

func (*SocketStreamedTraceSegment) Validate added in v0.6.9 

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.9 

func (m *SocketStreamedTraceSegment) XXX_DiscardUnknown()

func (*SocketStreamedTraceSegment) XXX_Marshal added in v0.6.9 

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

func (*SocketStreamedTraceSegment) XXX_Merge added in v0.6.9 

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

func (*SocketStreamedTraceSegment) XXX_OneofFuncs added in v0.6.9 

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.9 

func (m *SocketStreamedTraceSegment) XXX_Size() int

func (*SocketStreamedTraceSegment) XXX_Unmarshal added in v0.6.9 

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

type SocketStreamedTraceSegmentValidationError added in v0.6.9 

type SocketStreamedTraceSegmentValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (SocketStreamedTraceSegmentValidationError) Error added in v0.6.9 

func (e SocketStreamedTraceSegmentValidationError) Error() string

Error satisfies the builtin error interface

type SocketStreamedTraceSegment_Connection added in v0.6.9 

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

func (*SocketStreamedTraceSegment_Connection) MarshalTo added in v0.6.9 

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

func (*SocketStreamedTraceSegment_Connection) Size added in v0.6.9 

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

type SocketStreamedTraceSegment_Event added in v0.6.9 

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

func (*SocketStreamedTraceSegment_Event) MarshalTo added in v0.6.9 

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

func (*SocketStreamedTraceSegment_Event) Size added in v0.6.9 

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

type TraceWrapper added in v0.6.9 

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 added in v0.6.9 

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

func (*TraceWrapper) GetHttpBufferedTrace added in v0.6.9 

func (m *TraceWrapper) GetHttpBufferedTrace() *HttpBufferedTrace

func (*TraceWrapper) GetHttpStreamedTraceSegment added in v0.6.9 

func (m *TraceWrapper) GetHttpStreamedTraceSegment() *HttpStreamedTraceSegment

func (*TraceWrapper) GetSocketBufferedTrace added in v0.6.9 

func (m *TraceWrapper) GetSocketBufferedTrace() *SocketBufferedTrace

func (*TraceWrapper) GetSocketStreamedTraceSegment added in v0.6.9 

func (m *TraceWrapper) GetSocketStreamedTraceSegment() *SocketStreamedTraceSegment

func (*TraceWrapper) GetTrace added in v0.6.9 

func (m *TraceWrapper) GetTrace() isTraceWrapper_Trace

func (*TraceWrapper) Marshal added in v0.6.9 

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

func (*TraceWrapper) MarshalTo added in v0.6.9 

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

func (*TraceWrapper) ProtoMessage added in v0.6.9 

func (*TraceWrapper) ProtoMessage()

func (*TraceWrapper) Reset added in v0.6.9 

func (m *TraceWrapper) Reset()

func (*TraceWrapper) Size added in v0.6.9 

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

func (*TraceWrapper) String added in v0.6.9 

func (m *TraceWrapper) String() string

func (*TraceWrapper) Unmarshal added in v0.6.9 

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

func (*TraceWrapper) Validate added in v0.6.9 

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.9 

func (m *TraceWrapper) XXX_DiscardUnknown()

func (*TraceWrapper) XXX_Marshal added in v0.6.9 

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

func (*TraceWrapper) XXX_Merge added in v0.6.9 

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

func (*TraceWrapper) XXX_OneofFuncs added in v0.6.9 

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.9 

func (m *TraceWrapper) XXX_Size() int

func (*TraceWrapper) XXX_Unmarshal added in v0.6.9 

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

type TraceWrapperValidationError added in v0.6.9 

type TraceWrapperValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

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

func (TraceWrapperValidationError) Error added in v0.6.9 

func (e TraceWrapperValidationError) Error() string

Error satisfies the builtin error interface

type TraceWrapper_HttpBufferedTrace added in v0.6.9 

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.9 

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

func (*TraceWrapper_HttpBufferedTrace) Size added in v0.6.9 

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

type TraceWrapper_HttpStreamedTraceSegment added in v0.6.9 

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.9 

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

func (*TraceWrapper_HttpStreamedTraceSegment) Size added in v0.6.9 

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

type TraceWrapper_SocketBufferedTrace added in v0.6.9 

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.9 

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

func (*TraceWrapper_SocketBufferedTrace) Size added in v0.6.9 

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

type TraceWrapper_SocketStreamedTraceSegment added in v0.6.9 

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.9 

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

func (*TraceWrapper_SocketStreamedTraceSegment) Size added in v0.6.9 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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