package v2

import "github.com/envoyproxy/go-control-plane/envoy/data/tap/v2alpha"

Index

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

Types

type Body

type Body struct {
	// Types that are valid to be assigned to BodyType:
	//	*Body_AsBytes
	//	*Body_AsString
	BodyType isBody_BodyType `protobuf_oneof:"body_type"`
	// Specifies whether body data has been truncated to fit within the specified
	// :ref:`max_buffered_rx_bytes
	// <envoy_api_field_service.tap.v2alpha.OutputConfig.max_buffered_rx_bytes>` and
	// :ref:`max_buffered_tx_bytes
	// <envoy_api_field_service.tap.v2alpha.OutputConfig.max_buffered_tx_bytes>` settings.
	Truncated            bool     `protobuf:"varint,3,opt,name=truncated,proto3" json:"truncated,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Body) Descriptor

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

func (*Body) GetAsBytes

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

func (*Body) GetAsString

func (m *Body) GetAsString() string

func (*Body) GetBodyType

func (m *Body) GetBodyType() isBody_BodyType

func (*Body) GetTruncated

func (m *Body) GetTruncated() bool

func (*Body) Marshal

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

func (*Body) MarshalTo

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

func (*Body) ProtoMessage

func (*Body) ProtoMessage()

func (*Body) Reset

func (m *Body) Reset()

func (*Body) Size

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

func (*Body) String

func (m *Body) String() string

func (*Body) Unmarshal

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

func (*Body) Validate

func (m *Body) Validate() error

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

func (*Body) XXX_DiscardUnknown

func (m *Body) XXX_DiscardUnknown()

func (*Body) XXX_Marshal

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

func (*Body) XXX_Merge

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

func (*Body) XXX_OneofFuncs

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

func (m *Body) XXX_Size() int

func (*Body) XXX_Unmarshal

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

type BodyValidationError

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

func (e BodyValidationError) Error() string

Error satisfies the builtin error interface

type Body_AsBytes

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

func (*Body_AsBytes) MarshalTo

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

func (*Body_AsBytes) Size

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

type Body_AsString

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

func (*Body_AsString) MarshalTo

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

func (*Body_AsString) Size

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

type Connection

type Connection struct {
	// Local address.
	LocalAddress *core.Address `protobuf:"bytes,2,opt,name=local_address,json=localAddress,proto3" json:"local_address,omitempty"`
	// Remote address.
	RemoteAddress        *core.Address `protobuf:"bytes,3,opt,name=remote_address,json=remoteAddress,proto3" json:"remote_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Connection properties.

func (*Connection) Descriptor

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

func (*Connection) GetLocalAddress

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

func (*Connection) GetRemoteAddress

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

func (*Connection) Marshal

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

func (*Connection) MarshalTo

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

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

Error satisfies the builtin error interface

type HttpBufferedTrace

type HttpBufferedTrace struct {
	// Request message.
	Request *HttpBufferedTrace_Message `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Response message.
	Response             *HttpBufferedTrace_Message `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

A fully buffered HTTP trace message.

func (*HttpBufferedTrace) Descriptor

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

func (*HttpBufferedTrace) GetRequest

func (*HttpBufferedTrace) GetResponse

func (m *HttpBufferedTrace) GetResponse() *HttpBufferedTrace_Message

func (*HttpBufferedTrace) Marshal

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

func (*HttpBufferedTrace) MarshalTo

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

func (*HttpBufferedTrace) ProtoMessage

func (*HttpBufferedTrace) ProtoMessage()

func (*HttpBufferedTrace) Reset

func (m *HttpBufferedTrace) Reset()

func (*HttpBufferedTrace) Size

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

func (*HttpBufferedTrace) String

func (m *HttpBufferedTrace) String() string

func (*HttpBufferedTrace) Unmarshal

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

func (*HttpBufferedTrace) Validate

func (m *HttpBufferedTrace) Validate() error

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

func (*HttpBufferedTrace) XXX_DiscardUnknown

func (m *HttpBufferedTrace) XXX_DiscardUnknown()

func (*HttpBufferedTrace) XXX_Marshal

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

func (*HttpBufferedTrace) XXX_Merge

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

func (*HttpBufferedTrace) XXX_Size

func (m *HttpBufferedTrace) XXX_Size() int

func (*HttpBufferedTrace) XXX_Unmarshal

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

type HttpBufferedTraceValidationError

type HttpBufferedTraceValidationError struct {
	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

Error satisfies the builtin error interface

type HttpBufferedTrace_Message

type HttpBufferedTrace_Message struct {
	// Message headers.
	Headers []*core.HeaderValue `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
	// Message body.
	Body *Body `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// Message trailers.
	Trailers             []*core.HeaderValue `protobuf:"bytes,3,rep,name=trailers,proto3" json:"trailers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

HTTP message wrapper.

func (*HttpBufferedTrace_Message) Descriptor

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

func (*HttpBufferedTrace_Message) GetBody

func (m *HttpBufferedTrace_Message) GetBody() *Body

func (*HttpBufferedTrace_Message) GetHeaders

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

func (*HttpBufferedTrace_Message) GetTrailers

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

func (*HttpBufferedTrace_Message) Marshal

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

func (*HttpBufferedTrace_Message) MarshalTo

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

func (*HttpBufferedTrace_Message) ProtoMessage

func (*HttpBufferedTrace_Message) ProtoMessage()

func (*HttpBufferedTrace_Message) Reset

func (m *HttpBufferedTrace_Message) Reset()

func (*HttpBufferedTrace_Message) Size

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

func (*HttpBufferedTrace_Message) String

func (m *HttpBufferedTrace_Message) String() string

func (*HttpBufferedTrace_Message) Unmarshal

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

func (*HttpBufferedTrace_Message) Validate

func (m *HttpBufferedTrace_Message) Validate() error

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

func (*HttpBufferedTrace_Message) XXX_DiscardUnknown

func (m *HttpBufferedTrace_Message) XXX_DiscardUnknown()

func (*HttpBufferedTrace_Message) XXX_Marshal

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

func (*HttpBufferedTrace_Message) XXX_Merge

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

func (*HttpBufferedTrace_Message) XXX_Size

func (m *HttpBufferedTrace_Message) XXX_Size() int

func (*HttpBufferedTrace_Message) XXX_Unmarshal

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

type HttpBufferedTrace_MessageValidationError

type HttpBufferedTrace_MessageValidationError struct {
	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

Error satisfies the builtin error interface

type HttpStreamedTraceSegment

type HttpStreamedTraceSegment struct {
	// Trace ID unique to the originating Envoy only. Trace IDs can repeat and should not be used
	// for long term stable uniqueness.
	TraceId uint64 `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// Types that are valid to be assigned to MessagePiece:
	//	*HttpStreamedTraceSegment_RequestHeaders
	//	*HttpStreamedTraceSegment_RequestBodyChunk
	//	*HttpStreamedTraceSegment_RequestTrailers
	//	*HttpStreamedTraceSegment_ResponseHeaders
	//	*HttpStreamedTraceSegment_ResponseBodyChunk
	//	*HttpStreamedTraceSegment_ResponseTrailers
	MessagePiece         isHttpStreamedTraceSegment_MessagePiece `protobuf_oneof:"message_piece"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

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

func (*HttpStreamedTraceSegment) Descriptor

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

func (*HttpStreamedTraceSegment) GetMessagePiece

func (m *HttpStreamedTraceSegment) GetMessagePiece() isHttpStreamedTraceSegment_MessagePiece

func (*HttpStreamedTraceSegment) GetRequestBodyChunk

func (m *HttpStreamedTraceSegment) GetRequestBodyChunk() *Body

func (*HttpStreamedTraceSegment) GetRequestHeaders

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

func (*HttpStreamedTraceSegment) GetRequestTrailers

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

func (*HttpStreamedTraceSegment) GetResponseBodyChunk

func (m *HttpStreamedTraceSegment) GetResponseBodyChunk() *Body

func (*HttpStreamedTraceSegment) GetResponseHeaders

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

func (*HttpStreamedTraceSegment) GetResponseTrailers

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

func (*HttpStreamedTraceSegment) GetTraceId

func (m *HttpStreamedTraceSegment) GetTraceId() uint64

func (*HttpStreamedTraceSegment) Marshal

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

func (*HttpStreamedTraceSegment) MarshalTo

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

func (*HttpStreamedTraceSegment) ProtoMessage

func (*HttpStreamedTraceSegment) ProtoMessage()

func (*HttpStreamedTraceSegment) Reset

func (m *HttpStreamedTraceSegment) Reset()

func (*HttpStreamedTraceSegment) Size

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

func (*HttpStreamedTraceSegment) String

func (m *HttpStreamedTraceSegment) String() string

func (*HttpStreamedTraceSegment) Unmarshal

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

func (*HttpStreamedTraceSegment) Validate

func (m *HttpStreamedTraceSegment) Validate() error

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

func (*HttpStreamedTraceSegment) XXX_DiscardUnknown

func (m *HttpStreamedTraceSegment) XXX_DiscardUnknown()

func (*HttpStreamedTraceSegment) XXX_Marshal

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

func (*HttpStreamedTraceSegment) XXX_Merge

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

func (*HttpStreamedTraceSegment) XXX_OneofFuncs

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

func (m *HttpStreamedTraceSegment) XXX_Size() int

func (*HttpStreamedTraceSegment) XXX_Unmarshal

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

type HttpStreamedTraceSegmentValidationError

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

Error satisfies the builtin error interface

type HttpStreamedTraceSegment_RequestBodyChunk

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

func (*HttpStreamedTraceSegment_RequestBodyChunk) MarshalTo

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

func (*HttpStreamedTraceSegment_RequestBodyChunk) Size

type HttpStreamedTraceSegment_RequestHeaders

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

func (*HttpStreamedTraceSegment_RequestHeaders) MarshalTo

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

func (*HttpStreamedTraceSegment_RequestHeaders) Size

type HttpStreamedTraceSegment_RequestTrailers

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

func (*HttpStreamedTraceSegment_RequestTrailers) MarshalTo

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

func (*HttpStreamedTraceSegment_RequestTrailers) Size

type HttpStreamedTraceSegment_ResponseBodyChunk

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

func (*HttpStreamedTraceSegment_ResponseBodyChunk) MarshalTo

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

func (*HttpStreamedTraceSegment_ResponseBodyChunk) Size

type HttpStreamedTraceSegment_ResponseHeaders

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

func (*HttpStreamedTraceSegment_ResponseHeaders) MarshalTo

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

func (*HttpStreamedTraceSegment_ResponseHeaders) Size

type HttpStreamedTraceSegment_ResponseTrailers

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

func (*HttpStreamedTraceSegment_ResponseTrailers) MarshalTo

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

func (*HttpStreamedTraceSegment_ResponseTrailers) Size

type SocketBufferedTrace

type SocketBufferedTrace struct {
	// Trace ID unique to the originating Envoy only. Trace IDs can repeat and should not be used
	// for long term stable uniqueness. Matches connection IDs used in Envoy logs.
	TraceId uint64 `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// Connection properties.
	Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	// Sequence of observed events.
	Events []*SocketEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	// Set to true if read events were truncated due to the :ref:`max_buffered_rx_bytes
	// <envoy_api_field_service.tap.v2alpha.OutputConfig.max_buffered_rx_bytes>` setting.
	ReadTruncated bool `protobuf:"varint,4,opt,name=read_truncated,json=readTruncated,proto3" json:"read_truncated,omitempty"`
	// Set to true if write events were truncated due to the :ref:`max_buffered_tx_bytes
	// <envoy_api_field_service.tap.v2alpha.OutputConfig.max_buffered_tx_bytes>` setting.
	WriteTruncated       bool     `protobuf:"varint,5,opt,name=write_truncated,json=writeTruncated,proto3" json:"write_truncated,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sequence of read/write events that constitute a buffered trace on a socket.

func (*SocketBufferedTrace) Descriptor

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

func (*SocketBufferedTrace) GetConnection

func (m *SocketBufferedTrace) GetConnection() *Connection

func (*SocketBufferedTrace) GetEvents

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

func (*SocketBufferedTrace) GetReadTruncated

func (m *SocketBufferedTrace) GetReadTruncated() bool

func (*SocketBufferedTrace) GetTraceId

func (m *SocketBufferedTrace) GetTraceId() uint64

func (*SocketBufferedTrace) GetWriteTruncated

func (m *SocketBufferedTrace) GetWriteTruncated() bool

func (*SocketBufferedTrace) Marshal

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

func (*SocketBufferedTrace) MarshalTo

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

func (*SocketBufferedTrace) ProtoMessage

func (*SocketBufferedTrace) ProtoMessage()

func (*SocketBufferedTrace) Reset

func (m *SocketBufferedTrace) Reset()

func (*SocketBufferedTrace) Size

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

func (*SocketBufferedTrace) String

func (m *SocketBufferedTrace) String() string

func (*SocketBufferedTrace) Unmarshal

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

func (*SocketBufferedTrace) Validate

func (m *SocketBufferedTrace) Validate() error

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

func (*SocketBufferedTrace) XXX_DiscardUnknown

func (m *SocketBufferedTrace) XXX_DiscardUnknown()

func (*SocketBufferedTrace) XXX_Marshal

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

func (*SocketBufferedTrace) XXX_Merge

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

func (*SocketBufferedTrace) XXX_Size

func (m *SocketBufferedTrace) XXX_Size() int

func (*SocketBufferedTrace) XXX_Unmarshal

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

type SocketBufferedTraceValidationError

type SocketBufferedTraceValidationError struct {
	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

Error satisfies the builtin error interface

type SocketEvent

type SocketEvent struct {
	// Timestamp for event.
	Timestamp *types.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Read or write with content as bytes string.
	//
	// Types that are valid to be assigned to EventSelector:
	//	*SocketEvent_Read_
	//	*SocketEvent_Write_
	//	*SocketEvent_Closed_
	EventSelector        isSocketEvent_EventSelector `protobuf_oneof:"event_selector"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Event in a socket trace.

func (*SocketEvent) Descriptor

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

func (*SocketEvent) GetClosed

func (m *SocketEvent) GetClosed() *SocketEvent_Closed

func (*SocketEvent) GetEventSelector

func (m *SocketEvent) GetEventSelector() isSocketEvent_EventSelector

func (*SocketEvent) GetRead

func (m *SocketEvent) GetRead() *SocketEvent_Read

func (*SocketEvent) GetTimestamp

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

func (*SocketEvent) GetWrite

func (m *SocketEvent) GetWrite() *SocketEvent_Write

func (*SocketEvent) Marshal

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

func (*SocketEvent) MarshalTo

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

func (*SocketEvent) ProtoMessage

func (*SocketEvent) ProtoMessage()

func (*SocketEvent) Reset

func (m *SocketEvent) Reset()

func (*SocketEvent) Size

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

func (*SocketEvent) String

func (m *SocketEvent) String() string

func (*SocketEvent) Unmarshal

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

func (*SocketEvent) Validate

func (m *SocketEvent) Validate() error

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

func (*SocketEvent) XXX_DiscardUnknown

func (m *SocketEvent) XXX_DiscardUnknown()

func (*SocketEvent) XXX_Marshal

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

func (*SocketEvent) XXX_Merge

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

func (*SocketEvent) XXX_OneofFuncs

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

func (m *SocketEvent) XXX_Size() int

func (*SocketEvent) XXX_Unmarshal

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

type SocketEventValidationError

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

Error satisfies the builtin error interface

type SocketEvent_Closed

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

The connection was closed.

func (*SocketEvent_Closed) Descriptor

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

func (*SocketEvent_Closed) Marshal

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

func (*SocketEvent_Closed) MarshalTo

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

func (*SocketEvent_Closed) ProtoMessage

func (*SocketEvent_Closed) ProtoMessage()

func (*SocketEvent_Closed) Reset

func (m *SocketEvent_Closed) Reset()

func (*SocketEvent_Closed) Size

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

func (*SocketEvent_Closed) String

func (m *SocketEvent_Closed) String() string

func (*SocketEvent_Closed) Unmarshal

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

func (*SocketEvent_Closed) Validate

func (m *SocketEvent_Closed) Validate() error

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

func (*SocketEvent_Closed) XXX_DiscardUnknown

func (m *SocketEvent_Closed) XXX_DiscardUnknown()

func (*SocketEvent_Closed) XXX_Marshal

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

func (*SocketEvent_Closed) XXX_Merge

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

func (*SocketEvent_Closed) XXX_Size

func (m *SocketEvent_Closed) XXX_Size() int

func (*SocketEvent_Closed) XXX_Unmarshal

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

type SocketEvent_ClosedValidationError

type SocketEvent_ClosedValidationError struct {
	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

Error satisfies the builtin error interface

type SocketEvent_Closed_

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

func (*SocketEvent_Closed_) MarshalTo

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

func (*SocketEvent_Closed_) Size

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

type SocketEvent_Read

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

Data read by Envoy from the transport socket.

func (*SocketEvent_Read) Descriptor

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

func (*SocketEvent_Read) GetData

func (m *SocketEvent_Read) GetData() *Body

func (*SocketEvent_Read) Marshal

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

func (*SocketEvent_Read) MarshalTo

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

func (*SocketEvent_Read) ProtoMessage

func (*SocketEvent_Read) ProtoMessage()

func (*SocketEvent_Read) Reset

func (m *SocketEvent_Read) Reset()

func (*SocketEvent_Read) Size

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

func (*SocketEvent_Read) String

func (m *SocketEvent_Read) String() string

func (*SocketEvent_Read) Unmarshal

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

func (*SocketEvent_Read) Validate

func (m *SocketEvent_Read) Validate() error

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

func (*SocketEvent_Read) XXX_DiscardUnknown

func (m *SocketEvent_Read) XXX_DiscardUnknown()

func (*SocketEvent_Read) XXX_Marshal

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

func (*SocketEvent_Read) XXX_Merge

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

func (*SocketEvent_Read) XXX_Size

func (m *SocketEvent_Read) XXX_Size() int

func (*SocketEvent_Read) XXX_Unmarshal

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

type SocketEvent_ReadValidationError

type SocketEvent_ReadValidationError struct {
	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

Error satisfies the builtin error interface

type SocketEvent_Read_

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

func (*SocketEvent_Read_) MarshalTo

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

func (*SocketEvent_Read_) Size

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

type SocketEvent_Write

type SocketEvent_Write struct {
	// Binary data written.
	Data *Body `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Stream was half closed after this write.
	EndStream            bool     `protobuf:"varint,2,opt,name=end_stream,json=endStream,proto3" json:"end_stream,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Data written by Envoy to the transport socket.

func (*SocketEvent_Write) Descriptor

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

func (*SocketEvent_Write) GetData

func (m *SocketEvent_Write) GetData() *Body

func (*SocketEvent_Write) GetEndStream

func (m *SocketEvent_Write) GetEndStream() bool

func (*SocketEvent_Write) Marshal

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

func (*SocketEvent_Write) MarshalTo

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

func (*SocketEvent_Write) ProtoMessage

func (*SocketEvent_Write) ProtoMessage()

func (*SocketEvent_Write) Reset

func (m *SocketEvent_Write) Reset()

func (*SocketEvent_Write) Size

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

func (*SocketEvent_Write) String

func (m *SocketEvent_Write) String() string

func (*SocketEvent_Write) Unmarshal

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

func (*SocketEvent_Write) Validate

func (m *SocketEvent_Write) Validate() error

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

func (*SocketEvent_Write) XXX_DiscardUnknown

func (m *SocketEvent_Write) XXX_DiscardUnknown()

func (*SocketEvent_Write) XXX_Marshal

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

func (*SocketEvent_Write) XXX_Merge

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

func (*SocketEvent_Write) XXX_Size

func (m *SocketEvent_Write) XXX_Size() int

func (*SocketEvent_Write) XXX_Unmarshal

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

type SocketEvent_WriteValidationError

type SocketEvent_WriteValidationError struct {
	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

Error satisfies the builtin error interface

type SocketEvent_Write_

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

func (*SocketEvent_Write_) MarshalTo

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

func (*SocketEvent_Write_) Size

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

type SocketStreamedTraceSegment

type SocketStreamedTraceSegment struct {
	// Trace ID unique to the originating Envoy only. Trace IDs can repeat and should not be used
	// for long term stable uniqueness. Matches connection IDs used in Envoy logs.
	TraceId uint64 `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// Types that are valid to be assigned to MessagePiece:
	//	*SocketStreamedTraceSegment_Connection
	//	*SocketStreamedTraceSegment_Event
	MessagePiece         isSocketStreamedTraceSegment_MessagePiece `protobuf_oneof:"message_piece"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

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

func (*SocketStreamedTraceSegment) Descriptor

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

func (*SocketStreamedTraceSegment) GetConnection

func (m *SocketStreamedTraceSegment) GetConnection() *Connection

func (*SocketStreamedTraceSegment) GetEvent

func (m *SocketStreamedTraceSegment) GetEvent() *SocketEvent

func (*SocketStreamedTraceSegment) GetMessagePiece

func (m *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece

func (*SocketStreamedTraceSegment) GetTraceId

func (m *SocketStreamedTraceSegment) GetTraceId() uint64

func (*SocketStreamedTraceSegment) Marshal

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

func (*SocketStreamedTraceSegment) MarshalTo

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

func (*SocketStreamedTraceSegment) ProtoMessage

func (*SocketStreamedTraceSegment) ProtoMessage()

func (*SocketStreamedTraceSegment) Reset

func (m *SocketStreamedTraceSegment) Reset()

func (*SocketStreamedTraceSegment) Size

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

func (*SocketStreamedTraceSegment) String

func (m *SocketStreamedTraceSegment) String() string

func (*SocketStreamedTraceSegment) Unmarshal

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

func (*SocketStreamedTraceSegment) Validate

func (m *SocketStreamedTraceSegment) Validate() error

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

func (*SocketStreamedTraceSegment) XXX_DiscardUnknown

func (m *SocketStreamedTraceSegment) XXX_DiscardUnknown()

func (*SocketStreamedTraceSegment) XXX_Marshal

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

func (*SocketStreamedTraceSegment) XXX_Merge

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

func (*SocketStreamedTraceSegment) XXX_OneofFuncs

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

func (m *SocketStreamedTraceSegment) XXX_Size() int

func (*SocketStreamedTraceSegment) XXX_Unmarshal

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

type SocketStreamedTraceSegmentValidationError

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

Error satisfies the builtin error interface

type SocketStreamedTraceSegment_Connection

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

func (*SocketStreamedTraceSegment_Connection) MarshalTo

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

func (*SocketStreamedTraceSegment_Connection) Size

type SocketStreamedTraceSegment_Event

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

func (*SocketStreamedTraceSegment_Event) MarshalTo

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

func (*SocketStreamedTraceSegment_Event) Size

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

type TraceWrapper

type TraceWrapper struct {
	// Types that are valid to be assigned to Trace:
	//	*TraceWrapper_HttpBufferedTrace
	//	*TraceWrapper_HttpStreamedTraceSegment
	//	*TraceWrapper_SocketBufferedTrace
	//	*TraceWrapper_SocketStreamedTraceSegment
	Trace                isTraceWrapper_Trace `protobuf_oneof:"trace"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Wrapper for all fully buffered and streamed tap traces that Envoy emits. This is required for sending traces over gRPC APIs or more easily persisting binary messages to files.

func (*TraceWrapper) Descriptor

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

func (*TraceWrapper) GetHttpBufferedTrace

func (m *TraceWrapper) GetHttpBufferedTrace() *HttpBufferedTrace

func (*TraceWrapper) GetHttpStreamedTraceSegment

func (m *TraceWrapper) GetHttpStreamedTraceSegment() *HttpStreamedTraceSegment

func (*TraceWrapper) GetSocketBufferedTrace

func (m *TraceWrapper) GetSocketBufferedTrace() *SocketBufferedTrace

func (*TraceWrapper) GetSocketStreamedTraceSegment

func (m *TraceWrapper) GetSocketStreamedTraceSegment() *SocketStreamedTraceSegment

func (*TraceWrapper) GetTrace

func (m *TraceWrapper) GetTrace() isTraceWrapper_Trace

func (*TraceWrapper) Marshal

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

func (*TraceWrapper) MarshalTo

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

func (*TraceWrapper) ProtoMessage

func (*TraceWrapper) ProtoMessage()

func (*TraceWrapper) Reset

func (m *TraceWrapper) Reset()

func (*TraceWrapper) Size

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

func (*TraceWrapper) String

func (m *TraceWrapper) String() string

func (*TraceWrapper) Unmarshal

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

func (*TraceWrapper) Validate

func (m *TraceWrapper) Validate() error

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

func (*TraceWrapper) XXX_DiscardUnknown

func (m *TraceWrapper) XXX_DiscardUnknown()

func (*TraceWrapper) XXX_Marshal

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

func (*TraceWrapper) XXX_Merge

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

func (*TraceWrapper) XXX_OneofFuncs

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

func (m *TraceWrapper) XXX_Size() int

func (*TraceWrapper) XXX_Unmarshal

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

type TraceWrapperValidationError

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

Error satisfies the builtin error interface

type TraceWrapper_HttpBufferedTrace

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

func (*TraceWrapper_HttpBufferedTrace) MarshalTo

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

func (*TraceWrapper_HttpBufferedTrace) Size

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

type TraceWrapper_HttpStreamedTraceSegment

type TraceWrapper_HttpStreamedTraceSegment struct {
	HttpStreamedTraceSegment *HttpStreamedTraceSegment `protobuf:"bytes,2,opt,name=http_streamed_trace_segment,json=httpStreamedTraceSegment,proto3,oneof"`
}

func (*TraceWrapper_HttpStreamedTraceSegment) MarshalTo

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

func (*TraceWrapper_HttpStreamedTraceSegment) Size

type TraceWrapper_SocketBufferedTrace

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

func (*TraceWrapper_SocketBufferedTrace) MarshalTo

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

func (*TraceWrapper_SocketBufferedTrace) Size

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

type TraceWrapper_SocketStreamedTraceSegment

type TraceWrapper_SocketStreamedTraceSegment struct {
	SocketStreamedTraceSegment *SocketStreamedTraceSegment `protobuf:"bytes,4,opt,name=socket_streamed_trace_segment,json=socketStreamedTraceSegment,proto3,oneof"`
}

func (*TraceWrapper_SocketStreamedTraceSegment) MarshalTo

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

func (*TraceWrapper_SocketStreamedTraceSegment) Size

Source Files

common.pb.go common.pb.validate.go http.pb.go http.pb.validate.go transport.pb.go transport.pb.validate.go wrapper.pb.go wrapper.pb.validate.go

Version
v0.6.9
Published
Mar 11, 2019
Platform
darwin/amd64
Imports
16 packages
Last checked
57 minutes ago

Tools for package owners.