v2

package
v0.6.3 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCapture = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCapture   = fmt.Errorf("proto: integer overflow")
)
View Source 
var FileSink_Format_name = map[int32]string{
	0: "PROTO_BINARY",
	1: "PROTO_TEXT",
}
View Source 
var FileSink_Format_value = map[string]int32{
	"PROTO_BINARY": 0,
	"PROTO_TEXT":   1,
}

Functions

This section is empty.

Types

type Capture 

type Capture struct {
	// Types that are valid to be assigned to SinkSelector:
	//	*Capture_FileSink
	SinkSelector isCapture_SinkSelector `protobuf_oneof:"sink_selector"`
	// The underlying transport socket being wrapped.
	TransportSocket      *core.TransportSocket `protobuf:"bytes,2,opt,name=transport_socket,json=transportSocket" json:"transport_socket,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Configuration for capture transport socket. This wraps another transport socket, providing the ability to interpose and record in plain text any traffic that is surfaced to Envoy.

func (*Capture) Descriptor 

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

func (*Capture) GetFileSink 

func (m *Capture) GetFileSink() *FileSink

func (*Capture) GetSinkSelector 

func (m *Capture) GetSinkSelector() isCapture_SinkSelector

func (*Capture) GetTransportSocket 

func (m *Capture) GetTransportSocket() *core.TransportSocket

func (*Capture) Marshal 

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

func (*Capture) MarshalTo 

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

func (*Capture) ProtoMessage 

func (*Capture) ProtoMessage()

func (*Capture) Reset 

func (m *Capture) Reset()

func (*Capture) Size 

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

func (*Capture) String 

func (m *Capture) String() string

func (*Capture) Unmarshal 

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

func (*Capture) Validate 

func (m *Capture) Validate() error

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

func (*Capture) XXX_DiscardUnknown 

func (m *Capture) XXX_DiscardUnknown()

func (*Capture) XXX_Marshal 

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

func (*Capture) XXX_Merge 

func (dst *Capture) XXX_Merge(src proto.Message)

func (*Capture) XXX_OneofFuncs 

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

func (m *Capture) XXX_Size() int

func (*Capture) XXX_Unmarshal 

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

type CaptureValidationError 

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

CaptureValidationError is the validation error returned by Capture.Validate if the designated constraints aren't met.

func (CaptureValidationError) Error 

func (e CaptureValidationError) Error() string

Error satisfies the builtin error interface

type Capture_FileSink 

type Capture_FileSink struct {
	FileSink *FileSink `protobuf:"bytes,1,opt,name=file_sink,json=fileSink,oneof"`
}

func (*Capture_FileSink) MarshalTo 

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

func (*Capture_FileSink) Size 

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

type FileSink 

type FileSink struct {
	// Path prefix. The output file will be of the form <path_prefix>_<id>.pb, where <id> is an
	// identifier distinguishing the recorded trace for individual socket instances (the Envoy
	// connection ID).
	PathPrefix           string          `protobuf:"bytes,1,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	Format               FileSink_Format `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

File sink.

.. warning:: 

The current file sink implementation buffers the entire trace in memory
prior to writing. This will OOM for long lived sockets and/or where there
is a large amount of traffic on the socket.

func (*FileSink) Descriptor 

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

func (*FileSink) GetFormat 

func (m *FileSink) GetFormat() FileSink_Format

func (*FileSink) GetPathPrefix 

func (m *FileSink) GetPathPrefix() string

func (*FileSink) Marshal 

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

func (*FileSink) MarshalTo 

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

func (*FileSink) ProtoMessage 

func (*FileSink) ProtoMessage()

func (*FileSink) Reset 

func (m *FileSink) Reset()

func (*FileSink) Size 

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

func (*FileSink) String 

func (m *FileSink) String() string

func (*FileSink) Unmarshal 

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

func (*FileSink) Validate 

func (m *FileSink) Validate() error

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

func (*FileSink) XXX_DiscardUnknown 

func (m *FileSink) XXX_DiscardUnknown()

func (*FileSink) XXX_Marshal 

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

func (*FileSink) XXX_Merge 

func (dst *FileSink) XXX_Merge(src proto.Message)

func (*FileSink) XXX_Size 

func (m *FileSink) XXX_Size() int

func (*FileSink) XXX_Unmarshal 

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

type FileSinkValidationError 

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

FileSinkValidationError is the validation error returned by FileSink.Validate if the designated constraints aren't met.

func (FileSinkValidationError) Error 

func (e FileSinkValidationError) Error() string

Error satisfies the builtin error interface

type FileSink_Format 

type FileSink_Format int32

File format. 

const (
	// Binary proto format as per :ref:`Trace
	// <envoy_api_msg_data.tap.v2alpha.Trace>`.
	FileSink_PROTO_BINARY FileSink_Format = 0
	// Text proto format as per :ref:`Trace
	// <envoy_api_msg_data.tap.v2alpha.Trace>`.
	FileSink_PROTO_TEXT FileSink_Format = 1
)

func (FileSink_Format) EnumDescriptor 

func (FileSink_Format) EnumDescriptor() ([]byte, []int)

func (FileSink_Format) String 

func (x FileSink_Format) String() string

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.