Documentation ¶
Index ¶
- Variables
- type Connection
- func (*Connection) Descriptor() ([]byte, []int)
- func (m *Connection) GetId() uint64
- func (m *Connection) GetLocalAddress() *core.Address
- func (m *Connection) GetRemoteAddress() *core.Address
- func (m *Connection) Marshal() (dAtA []byte, err error)
- func (m *Connection) MarshalTo(dAtA []byte) (int, error)
- func (*Connection) ProtoMessage()
- func (m *Connection) Reset()
- func (m *Connection) Size() (n int)
- func (m *Connection) String() string
- func (m *Connection) Unmarshal(dAtA []byte) error
- func (m *Connection) Validate() error
- func (m *Connection) XXX_DiscardUnknown()
- func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Connection) XXX_Merge(src proto.Message)
- func (m *Connection) XXX_Size() int
- func (m *Connection) XXX_Unmarshal(b []byte) error
- type ConnectionValidationError
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetEventSelector() isEvent_EventSelector
- func (m *Event) GetRead() *Event_Read
- func (m *Event) GetTimestamp() *types.Timestamp
- func (m *Event) GetWrite() *Event_Write
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) Validate() error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Event) XXX_Merge(src proto.Message)
- func (*Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type EventValidationError
- type Event_Read
- func (*Event_Read) Descriptor() ([]byte, []int)
- func (m *Event_Read) GetData() []byte
- func (m *Event_Read) Marshal() (dAtA []byte, err error)
- func (m *Event_Read) MarshalTo(dAtA []byte) (int, error)
- func (*Event_Read) ProtoMessage()
- func (m *Event_Read) Reset()
- func (m *Event_Read) Size() (n int)
- func (m *Event_Read) String() string
- func (m *Event_Read) Unmarshal(dAtA []byte) error
- func (m *Event_Read) Validate() error
- func (m *Event_Read) XXX_DiscardUnknown()
- func (m *Event_Read) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Event_Read) XXX_Merge(src proto.Message)
- func (m *Event_Read) XXX_Size() int
- func (m *Event_Read) XXX_Unmarshal(b []byte) error
- type Event_ReadValidationError
- type Event_Read_
- type Event_Write
- func (*Event_Write) Descriptor() ([]byte, []int)
- func (m *Event_Write) GetData() []byte
- func (m *Event_Write) GetEndStream() bool
- func (m *Event_Write) Marshal() (dAtA []byte, err error)
- func (m *Event_Write) MarshalTo(dAtA []byte) (int, error)
- func (*Event_Write) ProtoMessage()
- func (m *Event_Write) Reset()
- func (m *Event_Write) Size() (n int)
- func (m *Event_Write) String() string
- func (m *Event_Write) Unmarshal(dAtA []byte) error
- func (m *Event_Write) Validate() error
- func (m *Event_Write) XXX_DiscardUnknown()
- func (m *Event_Write) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Event_Write) XXX_Merge(src proto.Message)
- func (m *Event_Write) XXX_Size() int
- func (m *Event_Write) XXX_Unmarshal(b []byte) error
- type Event_WriteValidationError
- type Event_Write_
- type Trace
- func (*Trace) Descriptor() ([]byte, []int)
- func (m *Trace) GetConnection() *Connection
- func (m *Trace) GetEvents() []*Event
- func (m *Trace) Marshal() (dAtA []byte, err error)
- func (m *Trace) MarshalTo(dAtA []byte) (int, error)
- func (*Trace) ProtoMessage()
- func (m *Trace) Reset()
- func (m *Trace) Size() (n int)
- func (m *Trace) String() string
- func (m *Trace) Unmarshal(dAtA []byte) error
- func (m *Trace) Validate() error
- func (m *Trace) XXX_DiscardUnknown()
- func (m *Trace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trace) XXX_Merge(src proto.Message)
- func (m *Trace) XXX_Size() int
- func (m *Trace) XXX_Unmarshal(b []byte) error
- type TraceValidationError
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthCapture = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCapture = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct { // Global unique connection ID for Envoy session. Matches connection IDs used // in Envoy logs. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // Local address. LocalAddress *core.Address `protobuf:"bytes,2,opt,name=local_address,json=localAddress" json:"local_address,omitempty"` // Remote address. RemoteAddress *core.Address `protobuf:"bytes,3,opt,name=remote_address,json=remoteAddress" 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) GetId ¶ added in v0.5.0
func (m *Connection) GetId() uint64
func (*Connection) GetLocalAddress ¶
func (m *Connection) GetLocalAddress() *core.Address
func (*Connection) GetRemoteAddress ¶
func (m *Connection) GetRemoteAddress() *core.Address
func (*Connection) Marshal ¶ added in v0.5.0
func (m *Connection) Marshal() (dAtA []byte, err error)
func (*Connection) MarshalTo ¶ added in v0.5.0
func (m *Connection) MarshalTo(dAtA []byte) (int, error)
func (*Connection) ProtoMessage ¶
func (*Connection) ProtoMessage()
func (*Connection) Reset ¶
func (m *Connection) Reset()
func (*Connection) Size ¶ added in v0.5.0
func (m *Connection) Size() (n int)
func (*Connection) String ¶
func (m *Connection) String() string
func (*Connection) Unmarshal ¶ added in v0.5.0
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 ¶ added in v0.5.0
func (m *Connection) XXX_DiscardUnknown()
func (*Connection) XXX_Marshal ¶ added in v0.5.0
func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Connection) XXX_Merge ¶ added in v0.5.0
func (dst *Connection) XXX_Merge(src proto.Message)
func (*Connection) XXX_Size ¶ added in v0.5.0
func (m *Connection) XXX_Size() int
func (*Connection) XXX_Unmarshal ¶ added in v0.5.0
func (m *Connection) XXX_Unmarshal(b []byte) error
type ConnectionValidationError ¶
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 Event ¶ added in v0.5.0
type Event struct { // Timestamp for event. Timestamp *types.Timestamp `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty"` // Read or write with content as bytes string. // // Types that are valid to be assigned to EventSelector: // *Event_Read_ // *Event_Write_ EventSelector isEvent_EventSelector `protobuf_oneof:"event_selector"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Event in a capture trace.
func (*Event) Descriptor ¶ added in v0.5.0
func (*Event) GetEventSelector ¶ added in v0.5.0
func (m *Event) GetEventSelector() isEvent_EventSelector
func (*Event) GetRead ¶ added in v0.5.0
func (m *Event) GetRead() *Event_Read
func (*Event) GetTimestamp ¶ added in v0.5.0
func (*Event) GetWrite ¶ added in v0.5.0
func (m *Event) GetWrite() *Event_Write
func (*Event) ProtoMessage ¶ added in v0.5.0
func (*Event) ProtoMessage()
func (*Event) Validate ¶ added in v0.5.0
Validate checks the field values on Event with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Event) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶ added in v0.5.0
func (*Event) XXX_OneofFuncs ¶ added in v0.5.0
func (*Event) 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 (*Event) XXX_Unmarshal ¶ added in v0.5.0
type EventValidationError ¶ added in v0.5.0
EventValidationError is the validation error returned by Event.Validate if the designated constraints aren't met.
func (EventValidationError) Error ¶ added in v0.5.0
func (e EventValidationError) Error() string
Error satisfies the builtin error interface
type Event_Read ¶ added in v0.5.0
type Event_Read struct { // Binary data read. Data []byte `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 (*Event_Read) Descriptor ¶ added in v0.5.0
func (*Event_Read) Descriptor() ([]byte, []int)
func (*Event_Read) GetData ¶ added in v0.5.0
func (m *Event_Read) GetData() []byte
func (*Event_Read) Marshal ¶ added in v0.5.0
func (m *Event_Read) Marshal() (dAtA []byte, err error)
func (*Event_Read) MarshalTo ¶ added in v0.5.0
func (m *Event_Read) MarshalTo(dAtA []byte) (int, error)
func (*Event_Read) ProtoMessage ¶ added in v0.5.0
func (*Event_Read) ProtoMessage()
func (*Event_Read) Reset ¶ added in v0.5.0
func (m *Event_Read) Reset()
func (*Event_Read) Size ¶ added in v0.5.0
func (m *Event_Read) Size() (n int)
func (*Event_Read) String ¶ added in v0.5.0
func (m *Event_Read) String() string
func (*Event_Read) Unmarshal ¶ added in v0.5.0
func (m *Event_Read) Unmarshal(dAtA []byte) error
func (*Event_Read) Validate ¶ added in v0.5.0
func (m *Event_Read) Validate() error
Validate checks the field values on Event_Read with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Event_Read) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *Event_Read) XXX_DiscardUnknown()
func (*Event_Read) XXX_Marshal ¶ added in v0.5.0
func (m *Event_Read) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_Read) XXX_Merge ¶ added in v0.5.0
func (dst *Event_Read) XXX_Merge(src proto.Message)
func (*Event_Read) XXX_Size ¶ added in v0.5.0
func (m *Event_Read) XXX_Size() int
func (*Event_Read) XXX_Unmarshal ¶ added in v0.5.0
func (m *Event_Read) XXX_Unmarshal(b []byte) error
type Event_ReadValidationError ¶ added in v0.5.0
Event_ReadValidationError is the validation error returned by Event_Read.Validate if the designated constraints aren't met.
func (Event_ReadValidationError) Error ¶ added in v0.5.0
func (e Event_ReadValidationError) Error() string
Error satisfies the builtin error interface
type Event_Read_ ¶ added in v0.5.0
type Event_Read_ struct {
Read *Event_Read `protobuf:"bytes,2,opt,name=read,oneof"`
}
func (*Event_Read_) MarshalTo ¶ added in v0.5.0
func (m *Event_Read_) MarshalTo(dAtA []byte) (int, error)
func (*Event_Read_) Size ¶ added in v0.5.0
func (m *Event_Read_) Size() (n int)
type Event_Write ¶ added in v0.5.0
type Event_Write struct { // Binary data written. Data []byte `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 (*Event_Write) Descriptor ¶ added in v0.5.0
func (*Event_Write) Descriptor() ([]byte, []int)
func (*Event_Write) GetData ¶ added in v0.5.0
func (m *Event_Write) GetData() []byte
func (*Event_Write) GetEndStream ¶ added in v0.5.0
func (m *Event_Write) GetEndStream() bool
func (*Event_Write) Marshal ¶ added in v0.5.0
func (m *Event_Write) Marshal() (dAtA []byte, err error)
func (*Event_Write) MarshalTo ¶ added in v0.5.0
func (m *Event_Write) MarshalTo(dAtA []byte) (int, error)
func (*Event_Write) ProtoMessage ¶ added in v0.5.0
func (*Event_Write) ProtoMessage()
func (*Event_Write) Reset ¶ added in v0.5.0
func (m *Event_Write) Reset()
func (*Event_Write) Size ¶ added in v0.5.0
func (m *Event_Write) Size() (n int)
func (*Event_Write) String ¶ added in v0.5.0
func (m *Event_Write) String() string
func (*Event_Write) Unmarshal ¶ added in v0.5.0
func (m *Event_Write) Unmarshal(dAtA []byte) error
func (*Event_Write) Validate ¶ added in v0.5.0
func (m *Event_Write) Validate() error
Validate checks the field values on Event_Write with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Event_Write) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *Event_Write) XXX_DiscardUnknown()
func (*Event_Write) XXX_Marshal ¶ added in v0.5.0
func (m *Event_Write) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_Write) XXX_Merge ¶ added in v0.5.0
func (dst *Event_Write) XXX_Merge(src proto.Message)
func (*Event_Write) XXX_Size ¶ added in v0.5.0
func (m *Event_Write) XXX_Size() int
func (*Event_Write) XXX_Unmarshal ¶ added in v0.5.0
func (m *Event_Write) XXX_Unmarshal(b []byte) error
type Event_WriteValidationError ¶ added in v0.5.0
Event_WriteValidationError is the validation error returned by Event_Write.Validate if the designated constraints aren't met.
func (Event_WriteValidationError) Error ¶ added in v0.5.0
func (e Event_WriteValidationError) Error() string
Error satisfies the builtin error interface
type Event_Write_ ¶ added in v0.5.0
type Event_Write_ struct {
Write *Event_Write `protobuf:"bytes,3,opt,name=write,oneof"`
}
func (*Event_Write_) MarshalTo ¶ added in v0.5.0
func (m *Event_Write_) MarshalTo(dAtA []byte) (int, error)
func (*Event_Write_) Size ¶ added in v0.5.0
func (m *Event_Write_) Size() (n int)
type Trace ¶ added in v0.5.0
type Trace struct { // Connection properties. Connection *Connection `protobuf:"bytes,1,opt,name=connection" json:"connection,omitempty"` // Sequence of observed events. Events []*Event `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Sequence of read/write events that constitute a captured trace on a socket. Multiple Trace messages might be emitted for a given connection ID, with the sink (e.g. file set, network) responsible for later reassembly.
func (*Trace) Descriptor ¶ added in v0.5.0
func (*Trace) GetConnection ¶ added in v0.5.0
func (m *Trace) GetConnection() *Connection
func (*Trace) ProtoMessage ¶ added in v0.5.0
func (*Trace) ProtoMessage()
func (*Trace) Validate ¶ added in v0.5.0
Validate checks the field values on Trace with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*Trace) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *Trace) XXX_DiscardUnknown()
func (*Trace) XXX_Marshal ¶ added in v0.5.0
func (*Trace) XXX_Unmarshal ¶ added in v0.5.0
type TraceValidationError ¶ added in v0.5.0
TraceValidationError is the validation error returned by Trace.Validate if the designated constraints aren't met.
func (TraceValidationError) Error ¶ added in v0.5.0
func (e TraceValidationError) Error() string
Error satisfies the builtin error interface