core

package
v10.240.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2019 License: Apache-2.0 Imports: 12 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAddress = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAddress   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthBase = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBase   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthHttpUri = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHttpUri   = fmt.Errorf("proto: integer overflow")
)
View Source 
var RequestMethod_name = map[int32]string{
	0: "METHOD_UNSPECIFIED",
	1: "GET",
	2: "HEAD",
	3: "POST",
	4: "PUT",
	5: "DELETE",
	6: "CONNECT",
	7: "OPTIONS",
	8: "TRACE",
	9: "PATCH",
}
View Source 
var RequestMethod_value = map[string]int32{
	"METHOD_UNSPECIFIED": 0,
	"GET":                1,
	"HEAD":               2,
	"POST":               3,
	"PUT":                4,
	"DELETE":             5,
	"CONNECT":            6,
	"OPTIONS":            7,
	"TRACE":              8,
	"PATCH":              9,
}
View Source 
var RoutingPriority_name = map[int32]string{
	0: "DEFAULT",
	1: "HIGH",
}
View Source 
var RoutingPriority_value = map[string]int32{
	"DEFAULT": 0,
	"HIGH":    1,
}
View Source 
var SocketAddress_Protocol_name = map[int32]string{
	0: "TCP",
	1: "UDP",
}
View Source 
var SocketAddress_Protocol_value = map[string]int32{
	"TCP": 0,
	"UDP": 1,
}
View Source 
var SocketOption_SocketState_name = map[int32]string{
	0: "STATE_PREBIND",
	1: "STATE_BOUND",
	2: "STATE_LISTENING",
}
View Source 
var SocketOption_SocketState_value = map[string]int32{
	"STATE_PREBIND":   0,
	"STATE_BOUND":     1,
	"STATE_LISTENING": 2,
}
View Source 
var TrafficDirection_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "INBOUND",
	2: "OUTBOUND",
}
View Source 
var TrafficDirection_value = map[string]int32{
	"UNSPECIFIED": 0,
	"INBOUND":     1,
	"OUTBOUND":    2,
}

Functions

This section is empty.

Types

type Address 

type Address struct {
	// Types that are valid to be assigned to Address:
	//	*Address_SocketAddress
	//	*Address_Pipe
	Address              isAddress_Address `protobuf_oneof:"address"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Addresses specify either a logical or physical address and port, which are used to tell Envoy where to bind/listen, connect to upstream and find management servers.

func (*Address) Descriptor 

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

func (*Address) Equal 

func (this *Address) Equal(that interface{}) bool

func (*Address) GetAddress 

func (m *Address) GetAddress() isAddress_Address

func (*Address) GetPipe 

func (m *Address) GetPipe() *Pipe

func (*Address) GetSocketAddress 

func (m *Address) GetSocketAddress() *SocketAddress

func (*Address) Marshal 

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

func (*Address) MarshalTo 

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

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) Reset 

func (m *Address) Reset()

func (*Address) Size 

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

func (*Address) String 

func (m *Address) String() string

func (*Address) Unmarshal 

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

func (*Address) XXX_DiscardUnknown 

func (m *Address) XXX_DiscardUnknown()

func (*Address) XXX_Marshal 

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

func (*Address) XXX_Merge 

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

func (*Address) XXX_OneofFuncs 

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

func (m *Address) XXX_Size() int

func (*Address) XXX_Unmarshal 

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

type Address_Pipe 

type Address_Pipe struct {
	Pipe *Pipe `protobuf:"bytes,2,opt,name=pipe,proto3,oneof"`
}

func (*Address_Pipe) Equal 

func (this *Address_Pipe) Equal(that interface{}) bool

func (*Address_Pipe) MarshalTo 

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

func (*Address_Pipe) Size 

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

type Address_SocketAddress 

type Address_SocketAddress struct {
	SocketAddress *SocketAddress `protobuf:"bytes,1,opt,name=socket_address,json=socketAddress,proto3,oneof"`
}

func (*Address_SocketAddress) Equal 

func (this *Address_SocketAddress) Equal(that interface{}) bool

func (*Address_SocketAddress) MarshalTo 

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

func (*Address_SocketAddress) Size 

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

type AsyncDataSource 

type AsyncDataSource struct {
	// Types that are valid to be assigned to Specifier:
	//	*AsyncDataSource_Local
	//	*AsyncDataSource_Remote
	Specifier            isAsyncDataSource_Specifier `protobuf_oneof:"specifier"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Async data source which support async data fetch.

func (*AsyncDataSource) Descriptor 

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

func (*AsyncDataSource) Equal 

func (this *AsyncDataSource) Equal(that interface{}) bool

func (*AsyncDataSource) GetLocal 

func (m *AsyncDataSource) GetLocal() *DataSource

func (*AsyncDataSource) GetRemote 

func (m *AsyncDataSource) GetRemote() *RemoteDataSource

func (*AsyncDataSource) GetSpecifier 

func (m *AsyncDataSource) GetSpecifier() isAsyncDataSource_Specifier

func (*AsyncDataSource) Marshal 

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

func (*AsyncDataSource) MarshalTo 

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

func (*AsyncDataSource) ProtoMessage 

func (*AsyncDataSource) ProtoMessage()

func (*AsyncDataSource) Reset 

func (m *AsyncDataSource) Reset()

func (*AsyncDataSource) Size 

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

func (*AsyncDataSource) String 

func (m *AsyncDataSource) String() string

func (*AsyncDataSource) Unmarshal 

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

func (*AsyncDataSource) XXX_DiscardUnknown 

func (m *AsyncDataSource) XXX_DiscardUnknown()

func (*AsyncDataSource) XXX_Marshal 

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

func (*AsyncDataSource) XXX_Merge 

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

func (*AsyncDataSource) XXX_OneofFuncs 

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

func (m *AsyncDataSource) XXX_Size() int

func (*AsyncDataSource) XXX_Unmarshal 

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

type AsyncDataSource_Local 

type AsyncDataSource_Local struct {
	Local *DataSource `protobuf:"bytes,1,opt,name=local,proto3,oneof"`
}

func (*AsyncDataSource_Local) Equal 

func (this *AsyncDataSource_Local) Equal(that interface{}) bool

func (*AsyncDataSource_Local) MarshalTo 

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

func (*AsyncDataSource_Local) Size 

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

type AsyncDataSource_Remote 

type AsyncDataSource_Remote struct {
	Remote *RemoteDataSource `protobuf:"bytes,2,opt,name=remote,proto3,oneof"`
}

func (*AsyncDataSource_Remote) Equal 

func (this *AsyncDataSource_Remote) Equal(that interface{}) bool

func (*AsyncDataSource_Remote) MarshalTo 

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

func (*AsyncDataSource_Remote) Size 

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

type BindConfig 

type BindConfig struct {
	// The address to bind to when creating a socket.
	SourceAddress *SocketAddress `protobuf:"bytes,1,opt,name=source_address,json=sourceAddress,proto3" json:"source_address,omitempty"`
	// Whether to set the *IP_FREEBIND* option when creating the socket. When this
	// flag is set to true, allows the :ref:`source_address
	// <envoy_api_field_UpstreamBindConfig.source_address>` to be an IP address
	// that is not configured on the system running Envoy. When this flag is set
	// to false, the option *IP_FREEBIND* is disabled on the socket. When this
	// flag is not set (default), the socket is not modified, i.e. the option is
	// neither enabled nor disabled.
	Freebind *types.BoolValue `protobuf:"bytes,2,opt,name=freebind,proto3" json:"freebind,omitempty"`
	// Additional socket options that may not be present in Envoy source code or
	// precompiled binaries.
	SocketOptions        []*SocketOption `protobuf:"bytes,3,rep,name=socket_options,json=socketOptions,proto3" json:"socket_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*BindConfig) Descriptor 

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

func (*BindConfig) Equal 

func (this *BindConfig) Equal(that interface{}) bool

func (*BindConfig) GetFreebind 

func (m *BindConfig) GetFreebind() *types.BoolValue

func (*BindConfig) GetSocketOptions 

func (m *BindConfig) GetSocketOptions() []*SocketOption

func (*BindConfig) GetSourceAddress 

func (m *BindConfig) GetSourceAddress() *SocketAddress

func (*BindConfig) Marshal 

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

func (*BindConfig) MarshalTo 

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

func (*BindConfig) ProtoMessage 

func (*BindConfig) ProtoMessage()

func (*BindConfig) Reset 

func (m *BindConfig) Reset()

func (*BindConfig) Size 

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

func (*BindConfig) String 

func (m *BindConfig) String() string

func (*BindConfig) Unmarshal 

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

func (*BindConfig) XXX_DiscardUnknown 

func (m *BindConfig) XXX_DiscardUnknown()

func (*BindConfig) XXX_Marshal 

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

func (*BindConfig) XXX_Merge 

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

func (*BindConfig) XXX_Size 

func (m *BindConfig) XXX_Size() int

func (*BindConfig) XXX_Unmarshal 

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

type CidrRange 

type CidrRange struct {
	// IPv4 or IPv6 address, e.g. “192.0.0.0“ or “2001:db8::“.
	AddressPrefix string `protobuf:"bytes,1,opt,name=address_prefix,json=addressPrefix,proto3" json:"address_prefix,omitempty"`
	// Length of prefix, e.g. 0, 32.
	PrefixLen            *types.UInt32Value `protobuf:"bytes,2,opt,name=prefix_len,json=prefixLen,proto3" json:"prefix_len,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

CidrRange specifies an IP Address and a prefix length to construct the subnet mask for a `CIDR <https://tools.ietf.org/html/rfc4632>`_ range.

func (*CidrRange) Descriptor 

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

func (*CidrRange) Equal 

func (this *CidrRange) Equal(that interface{}) bool

func (*CidrRange) GetAddressPrefix 

func (m *CidrRange) GetAddressPrefix() string

func (*CidrRange) GetPrefixLen 

func (m *CidrRange) GetPrefixLen() *types.UInt32Value

func (*CidrRange) Marshal 

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

func (*CidrRange) MarshalTo 

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

func (*CidrRange) ProtoMessage 

func (*CidrRange) ProtoMessage()

func (*CidrRange) Reset 

func (m *CidrRange) Reset()

func (*CidrRange) Size 

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

func (*CidrRange) String 

func (m *CidrRange) String() string

func (*CidrRange) Unmarshal 

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

func (*CidrRange) XXX_DiscardUnknown 

func (m *CidrRange) XXX_DiscardUnknown()

func (*CidrRange) XXX_Marshal 

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

func (*CidrRange) XXX_Merge 

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

func (*CidrRange) XXX_Size 

func (m *CidrRange) XXX_Size() int

func (*CidrRange) XXX_Unmarshal 

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

type ControlPlane 

type ControlPlane struct {
	// An opaque control plane identifier that uniquely identifies an instance
	// of control plane. This can be used to identify which control plane instance,
	// the Envoy is connected to.
	Identifier           string   `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identifies a specific ControlPlane instance that Envoy is connected to.

func (*ControlPlane) Descriptor 

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

func (*ControlPlane) Equal 

func (this *ControlPlane) Equal(that interface{}) bool

func (*ControlPlane) GetIdentifier 

func (m *ControlPlane) GetIdentifier() string

func (*ControlPlane) Marshal 

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

func (*ControlPlane) MarshalTo 

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

func (*ControlPlane) ProtoMessage 

func (*ControlPlane) ProtoMessage()

func (*ControlPlane) Reset 

func (m *ControlPlane) Reset()

func (*ControlPlane) Size 

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

func (*ControlPlane) String 

func (m *ControlPlane) String() string

func (*ControlPlane) Unmarshal 

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

func (*ControlPlane) XXX_DiscardUnknown 

func (m *ControlPlane) XXX_DiscardUnknown()

func (*ControlPlane) XXX_Marshal 

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

func (*ControlPlane) XXX_Merge 

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

func (*ControlPlane) XXX_Size 

func (m *ControlPlane) XXX_Size() int

func (*ControlPlane) XXX_Unmarshal 

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

type DataSource 

type DataSource struct {
	// Types that are valid to be assigned to Specifier:
	//	*DataSource_Filename
	//	*DataSource_InlineBytes
	//	*DataSource_InlineString
	Specifier            isDataSource_Specifier `protobuf_oneof:"specifier"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Data source consisting of either a file or an inline value.

func (*DataSource) Descriptor 

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

func (*DataSource) Equal 

func (this *DataSource) Equal(that interface{}) bool

func (*DataSource) GetFilename 

func (m *DataSource) GetFilename() string

func (*DataSource) GetInlineBytes 

func (m *DataSource) GetInlineBytes() []byte

func (*DataSource) GetInlineString 

func (m *DataSource) GetInlineString() string

func (*DataSource) GetSpecifier 

func (m *DataSource) GetSpecifier() isDataSource_Specifier

func (*DataSource) Marshal 

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

func (*DataSource) MarshalTo 

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

func (*DataSource) ProtoMessage 

func (*DataSource) ProtoMessage()

func (*DataSource) Reset 

func (m *DataSource) Reset()

func (*DataSource) Size 

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

func (*DataSource) String 

func (m *DataSource) String() string

func (*DataSource) Unmarshal 

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

func (*DataSource) XXX_DiscardUnknown 

func (m *DataSource) XXX_DiscardUnknown()

func (*DataSource) XXX_Marshal 

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

func (*DataSource) XXX_Merge 

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

func (*DataSource) XXX_OneofFuncs 

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

func (m *DataSource) XXX_Size() int

func (*DataSource) XXX_Unmarshal 

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

type DataSource_Filename 

type DataSource_Filename struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3,oneof"`
}

func (*DataSource_Filename) Equal 

func (this *DataSource_Filename) Equal(that interface{}) bool

func (*DataSource_Filename) MarshalTo 

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

func (*DataSource_Filename) Size 

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

type DataSource_InlineBytes 

type DataSource_InlineBytes struct {
	InlineBytes []byte `protobuf:"bytes,2,opt,name=inline_bytes,json=inlineBytes,proto3,oneof"`
}

func (*DataSource_InlineBytes) Equal 

func (this *DataSource_InlineBytes) Equal(that interface{}) bool

func (*DataSource_InlineBytes) MarshalTo 

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

func (*DataSource_InlineBytes) Size 

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

type DataSource_InlineString 

type DataSource_InlineString struct {
	InlineString string `protobuf:"bytes,3,opt,name=inline_string,json=inlineString,proto3,oneof"`
}

func (*DataSource_InlineString) Equal 

func (this *DataSource_InlineString) Equal(that interface{}) bool

func (*DataSource_InlineString) MarshalTo 

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

func (*DataSource_InlineString) Size 

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

type HeaderMap 

type HeaderMap struct {
	Headers              []*HeaderValue `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Wrapper for a set of headers.

func (*HeaderMap) Descriptor 

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

func (*HeaderMap) Equal 

func (this *HeaderMap) Equal(that interface{}) bool

func (*HeaderMap) GetHeaders 

func (m *HeaderMap) GetHeaders() []*HeaderValue

func (*HeaderMap) Marshal 

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

func (*HeaderMap) MarshalTo 

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

func (*HeaderMap) ProtoMessage 

func (*HeaderMap) ProtoMessage()

func (*HeaderMap) Reset 

func (m *HeaderMap) Reset()

func (*HeaderMap) Size 

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

func (*HeaderMap) String 

func (m *HeaderMap) String() string

func (*HeaderMap) Unmarshal 

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

func (*HeaderMap) XXX_DiscardUnknown 

func (m *HeaderMap) XXX_DiscardUnknown()

func (*HeaderMap) XXX_Marshal 

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

func (*HeaderMap) XXX_Merge 

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

func (*HeaderMap) XXX_Size 

func (m *HeaderMap) XXX_Size() int

func (*HeaderMap) XXX_Unmarshal 

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

type HeaderValue 

type HeaderValue struct {
	// Header name.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Header value.
	//
	// The same :ref:`format specifier <config_access_log_format>` as used for
	// :ref:`HTTP access logging <config_access_log>` applies here, however
	// unknown header values are replaced with the empty string instead of `-`.
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Header name/value pair.

func (*HeaderValue) Descriptor 

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

func (*HeaderValue) Equal 

func (this *HeaderValue) Equal(that interface{}) bool

func (*HeaderValue) GetKey 

func (m *HeaderValue) GetKey() string

func (*HeaderValue) GetValue 

func (m *HeaderValue) GetValue() string

func (*HeaderValue) Marshal 

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

func (*HeaderValue) MarshalTo 

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

func (*HeaderValue) ProtoMessage 

func (*HeaderValue) ProtoMessage()

func (*HeaderValue) Reset 

func (m *HeaderValue) Reset()

func (*HeaderValue) Size 

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

func (*HeaderValue) String 

func (m *HeaderValue) String() string

func (*HeaderValue) Unmarshal 

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

func (*HeaderValue) XXX_DiscardUnknown 

func (m *HeaderValue) XXX_DiscardUnknown()

func (*HeaderValue) XXX_Marshal 

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

func (*HeaderValue) XXX_Merge 

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

func (*HeaderValue) XXX_Size 

func (m *HeaderValue) XXX_Size() int

func (*HeaderValue) XXX_Unmarshal 

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

type HeaderValueOption 

type HeaderValueOption struct {
	// Header name/value pair that this option applies to.
	Header *HeaderValue `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Should the value be appended? If true (default), the value is appended to
	// existing values.
	Append               *types.BoolValue `protobuf:"bytes,2,opt,name=append,proto3" json:"append,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Header name/value pair plus option to control append behavior.

func (*HeaderValueOption) Descriptor 

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

func (*HeaderValueOption) Equal 

func (this *HeaderValueOption) Equal(that interface{}) bool

func (*HeaderValueOption) GetAppend 

func (m *HeaderValueOption) GetAppend() *types.BoolValue

func (*HeaderValueOption) GetHeader 

func (m *HeaderValueOption) GetHeader() *HeaderValue

func (*HeaderValueOption) Marshal 

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

func (*HeaderValueOption) MarshalTo 

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

func (*HeaderValueOption) ProtoMessage 

func (*HeaderValueOption) ProtoMessage()

func (*HeaderValueOption) Reset 

func (m *HeaderValueOption) Reset()

func (*HeaderValueOption) Size 

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

func (*HeaderValueOption) String 

func (m *HeaderValueOption) String() string

func (*HeaderValueOption) Unmarshal 

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

func (*HeaderValueOption) XXX_DiscardUnknown 

func (m *HeaderValueOption) XXX_DiscardUnknown()

func (*HeaderValueOption) XXX_Marshal 

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

func (*HeaderValueOption) XXX_Merge 

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

func (*HeaderValueOption) XXX_Size 

func (m *HeaderValueOption) XXX_Size() int

func (*HeaderValueOption) XXX_Unmarshal 

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

type HttpUri 

type HttpUri struct {
	// The HTTP server URI. It should be a full FQDN with protocol, host and path.
	//
	// Example:
	//
	// .. code-block:: yaml
	//
	//    uri: https://www.googleapis.com/oauth2/v1/certs
	//
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// Specify how `uri` is to be fetched. Today, this requires an explicit
	// cluster, but in the future we may support dynamic cluster creation or
	// inline DNS resolution. See `issue
	// <https://github.com/envoyproxy/envoy/issues/1606>`_.
	//
	// Types that are valid to be assigned to HttpUpstreamType:
	//	*HttpUri_Cluster
	HttpUpstreamType isHttpUri_HttpUpstreamType `protobuf_oneof:"http_upstream_type"`
	// Sets the maximum duration in milliseconds that a response can take to arrive upon request.
	Timeout              *time.Duration `protobuf:"bytes,3,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Envoy external URI descriptor

func (*HttpUri) Descriptor 

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

func (*HttpUri) Equal 

func (this *HttpUri) Equal(that interface{}) bool

func (*HttpUri) GetCluster 

func (m *HttpUri) GetCluster() string

func (*HttpUri) GetHttpUpstreamType 

func (m *HttpUri) GetHttpUpstreamType() isHttpUri_HttpUpstreamType

func (*HttpUri) GetTimeout 

func (m *HttpUri) GetTimeout() *time.Duration

func (*HttpUri) GetUri 

func (m *HttpUri) GetUri() string

func (*HttpUri) Marshal 

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

func (*HttpUri) MarshalTo 

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

func (*HttpUri) ProtoMessage 

func (*HttpUri) ProtoMessage()

func (*HttpUri) Reset 

func (m *HttpUri) Reset()

func (*HttpUri) Size 

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

func (*HttpUri) String 

func (m *HttpUri) String() string

func (*HttpUri) Unmarshal 

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

func (*HttpUri) XXX_DiscardUnknown 

func (m *HttpUri) XXX_DiscardUnknown()

func (*HttpUri) XXX_Marshal 

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

func (*HttpUri) XXX_Merge 

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

func (*HttpUri) XXX_OneofFuncs 

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

func (m *HttpUri) XXX_Size() int

func (*HttpUri) XXX_Unmarshal 

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

type HttpUri_Cluster 

type HttpUri_Cluster struct {
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3,oneof"`
}

func (*HttpUri_Cluster) Equal 

func (this *HttpUri_Cluster) Equal(that interface{}) bool

func (*HttpUri_Cluster) MarshalTo 

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

func (*HttpUri_Cluster) Size 

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

type Locality 

type Locality struct {
	// Region this :ref:`zone <envoy_api_field_core.Locality.zone>` belongs to.
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// Defines the local service zone where Envoy is running. Though optional, it
	// should be set if discovery service routing is used and the discovery
	// service exposes :ref:`zone data <envoy_api_field_endpoint.LocalityLbEndpoints.locality>`,
	// either in this message or via :option:`--service-zone`. The meaning of zone
	// is context dependent, e.g. `Availability Zone (AZ)
	// <https://docs.aws.amazon.com/AWSEC2/latest/UserGuide/using-regions-availability-zones.html>`_
	// on AWS, `Zone <https://cloud.google.com/compute/docs/regions-zones/>`_ on
	// GCP, etc.
	Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	// When used for locality of upstream hosts, this field further splits zone
	// into smaller chunks of sub-zones so they can be load balanced
	// independently.
	SubZone              string   `protobuf:"bytes,3,opt,name=sub_zone,json=subZone,proto3" json:"sub_zone,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identifies location of where either Envoy runs or where upstream hosts run.

func (*Locality) Descriptor 

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

func (*Locality) Equal 

func (this *Locality) Equal(that interface{}) bool

func (*Locality) GetRegion 

func (m *Locality) GetRegion() string

func (*Locality) GetSubZone 

func (m *Locality) GetSubZone() string

func (*Locality) GetZone 

func (m *Locality) GetZone() string

func (*Locality) Marshal 

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

func (*Locality) MarshalTo 

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

func (*Locality) ProtoMessage 

func (*Locality) ProtoMessage()

func (*Locality) Reset 

func (m *Locality) Reset()

func (*Locality) Size 

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

func (*Locality) String 

func (m *Locality) String() string

func (*Locality) Unmarshal 

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

func (*Locality) XXX_DiscardUnknown 

func (m *Locality) XXX_DiscardUnknown()

func (*Locality) XXX_Marshal 

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

func (*Locality) XXX_Merge 

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

func (*Locality) XXX_Size 

func (m *Locality) XXX_Size() int

func (*Locality) XXX_Unmarshal 

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

type Metadata 

type Metadata struct {
	// Key is the reverse DNS filter name, e.g. com.acme.widget. The envoy.*
	// namespace is reserved for Envoy's built-in filters.
	FilterMetadata       map[string]*types.Struct `` /* 191-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Metadata provides additional inputs to filters based on matched listeners, filter chains, routes and endpoints. It is structured as a map, usually from filter name (in reverse DNS format) to metadata specific to the filter. Metadata key-values for a filter are merged as connection and request handling occurs, with later values for the same key overriding earlier values.

An example use of metadata is providing additional values to http_connection_manager in the envoy.http_connection_manager.access_log namespace.

Another example use of metadata is to per service config info in cluster metadata, which may get consumed by multiple filters.

For load balancing, Metadata provides a means to subset cluster endpoints. Endpoints have a Metadata object associated and routes contain a Metadata object to match against. There are some well defined metadata used today for this purpose:

  • “{"envoy.lb": {"canary": <bool> }}“ This indicates the canary status of an endpoint and is also used during header processing (x-envoy-upstream-canary) and for stats purposes.

func (*Metadata) Descriptor 

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

func (*Metadata) Equal 

func (this *Metadata) Equal(that interface{}) bool

func (*Metadata) GetFilterMetadata 

func (m *Metadata) GetFilterMetadata() map[string]*types.Struct

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

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

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type Node 

type Node struct {
	// An opaque node identifier for the Envoy node. This also provides the local
	// service node name. It should be set if any of the following features are
	// used: :ref:`statsd <arch_overview_statistics>`, :ref:`CDS
	// <config_cluster_manager_cds>`, and :ref:`HTTP tracing
	// <arch_overview_tracing>`, either in this message or via
	// :option:`--service-node`.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Defines the local service cluster name where Envoy is running. Though
	// optional, it should be set if any of the following features are used:
	// :ref:`statsd <arch_overview_statistics>`, :ref:`health check cluster
	// verification <envoy_api_field_core.HealthCheck.HttpHealthCheck.service_name>`,
	// :ref:`runtime override directory <envoy_api_msg_config.bootstrap.v2.Runtime>`,
	// :ref:`user agent addition
	// <envoy_api_field_config.filter.network.http_connection_manager.v2.HttpConnectionManager.add_user_agent>`,
	// :ref:`HTTP global rate limiting <config_http_filters_rate_limit>`,
	// :ref:`CDS <config_cluster_manager_cds>`, and :ref:`HTTP tracing
	// <arch_overview_tracing>`, either in this message or via
	// :option:`--service-cluster`.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Opaque metadata extending the node identifier. Envoy will pass this
	// directly to the management server.
	Metadata *types.Struct `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Locality specifying where the Envoy instance is running.
	Locality *Locality `protobuf:"bytes,4,opt,name=locality,proto3" json:"locality,omitempty"`
	// This is motivated by informing a management server during canary which
	// version of Envoy is being tested in a heterogeneous fleet. This will be set
	// by Envoy in management server RPCs.
	BuildVersion         string   `protobuf:"bytes,5,opt,name=build_version,json=buildVersion,proto3" json:"build_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identifies a specific Envoy instance. The node identifier is presented to the management server, which may use this identifier to distinguish per Envoy configuration for serving.

func (*Node) Descriptor 

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

func (*Node) Equal 

func (this *Node) Equal(that interface{}) bool

func (*Node) GetBuildVersion 

func (m *Node) GetBuildVersion() string

func (*Node) GetCluster 

func (m *Node) GetCluster() string

func (*Node) GetId 

func (m *Node) GetId() string

func (*Node) GetLocality 

func (m *Node) GetLocality() *Locality

func (*Node) GetMetadata 

func (m *Node) GetMetadata() *types.Struct

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

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

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type Pipe 

type Pipe struct {
	// Unix Domain Socket path. On Linux, paths starting with '@' will use the
	// abstract namespace. The starting '@' is replaced by a null byte by Envoy.
	// Paths starting with '@' will result in an error in environments other than
	// Linux.
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pipe) Descriptor 

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

func (*Pipe) Equal 

func (this *Pipe) Equal(that interface{}) bool

func (*Pipe) GetPath 

func (m *Pipe) GetPath() string

func (*Pipe) Marshal 

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

func (*Pipe) MarshalTo 

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

func (*Pipe) ProtoMessage 

func (*Pipe) ProtoMessage()

func (*Pipe) Reset 

func (m *Pipe) Reset()

func (*Pipe) Size 

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

func (*Pipe) String 

func (m *Pipe) String() string

func (*Pipe) Unmarshal 

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

func (*Pipe) XXX_DiscardUnknown 

func (m *Pipe) XXX_DiscardUnknown()

func (*Pipe) XXX_Marshal 

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

func (*Pipe) XXX_Merge 

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

func (*Pipe) XXX_Size 

func (m *Pipe) XXX_Size() int

func (*Pipe) XXX_Unmarshal 

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

type RemoteDataSource 

type RemoteDataSource struct {
	// The HTTP URI to fetch the remote data.
	HttpUri *HttpUri `protobuf:"bytes,1,opt,name=http_uri,json=httpUri,proto3" json:"http_uri,omitempty"`
	// SHA256 string for verifying data.
	Sha256               string   `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The message specifies how to fetch data from remote and how to verify it.

func (*RemoteDataSource) Descriptor 

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

func (*RemoteDataSource) Equal 

func (this *RemoteDataSource) Equal(that interface{}) bool

func (*RemoteDataSource) GetHttpUri 

func (m *RemoteDataSource) GetHttpUri() *HttpUri

func (*RemoteDataSource) GetSha256 

func (m *RemoteDataSource) GetSha256() string

func (*RemoteDataSource) Marshal 

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

func (*RemoteDataSource) MarshalTo 

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

func (*RemoteDataSource) ProtoMessage 

func (*RemoteDataSource) ProtoMessage()

func (*RemoteDataSource) Reset 

func (m *RemoteDataSource) Reset()

func (*RemoteDataSource) Size 

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

func (*RemoteDataSource) String 

func (m *RemoteDataSource) String() string

func (*RemoteDataSource) Unmarshal 

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

func (*RemoteDataSource) XXX_DiscardUnknown 

func (m *RemoteDataSource) XXX_DiscardUnknown()

func (*RemoteDataSource) XXX_Marshal 

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

func (*RemoteDataSource) XXX_Merge 

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

func (*RemoteDataSource) XXX_Size 

func (m *RemoteDataSource) XXX_Size() int

func (*RemoteDataSource) XXX_Unmarshal 

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

type RequestMethod 

type RequestMethod int32

HTTP request method. 

const (
	METHOD_UNSPECIFIED RequestMethod = 0
	GET                RequestMethod = 1
	HEAD               RequestMethod = 2
	POST               RequestMethod = 3
	PUT                RequestMethod = 4
	DELETE             RequestMethod = 5
	CONNECT            RequestMethod = 6
	OPTIONS            RequestMethod = 7
	TRACE              RequestMethod = 8
	PATCH              RequestMethod = 9
)

func (RequestMethod) EnumDescriptor 

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

func (RequestMethod) String 

func (x RequestMethod) String() string

type RoutingPriority 

type RoutingPriority int32

Envoy supports :ref:`upstream priority routing <arch_overview_http_routing_priority>` both at the route and the virtual cluster level. The current priority implementation uses different connection pool and circuit breaking settings for each priority level. This means that even for HTTP/2 requests, two physical connections will be used to an upstream host. In the future Envoy will likely support true HTTP/2 priority over a single upstream connection. 

const (
	RoutingPriority_DEFAULT RoutingPriority = 0
	RoutingPriority_HIGH    RoutingPriority = 1
)

func (RoutingPriority) EnumDescriptor 

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

func (RoutingPriority) String 

func (x RoutingPriority) String() string

type RuntimeFractionalPercent 

type RuntimeFractionalPercent struct {
	// Default value if the runtime value's for the numerator/denominator keys are not available.
	DefaultValue *_type.FractionalPercent `protobuf:"bytes,1,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	// Runtime key for a YAML representation of a FractionalPercent.
	RuntimeKey           string   `protobuf:"bytes,2,opt,name=runtime_key,json=runtimeKey,proto3" json:"runtime_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Runtime derived FractionalPercent with defaults for when the numerator or denominator is not specified via a runtime key.

func (*RuntimeFractionalPercent) Descriptor 

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

func (*RuntimeFractionalPercent) Equal 

func (this *RuntimeFractionalPercent) Equal(that interface{}) bool

func (*RuntimeFractionalPercent) GetDefaultValue 

func (m *RuntimeFractionalPercent) GetDefaultValue() *_type.FractionalPercent

func (*RuntimeFractionalPercent) GetRuntimeKey 

func (m *RuntimeFractionalPercent) GetRuntimeKey() string

func (*RuntimeFractionalPercent) Marshal 

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

func (*RuntimeFractionalPercent) MarshalTo 

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

func (*RuntimeFractionalPercent) ProtoMessage 

func (*RuntimeFractionalPercent) ProtoMessage()

func (*RuntimeFractionalPercent) Reset 

func (m *RuntimeFractionalPercent) Reset()

func (*RuntimeFractionalPercent) Size 

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

func (*RuntimeFractionalPercent) String 

func (m *RuntimeFractionalPercent) String() string

func (*RuntimeFractionalPercent) Unmarshal 

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

func (*RuntimeFractionalPercent) XXX_DiscardUnknown 

func (m *RuntimeFractionalPercent) XXX_DiscardUnknown()

func (*RuntimeFractionalPercent) XXX_Marshal 

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

func (*RuntimeFractionalPercent) XXX_Merge 

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

func (*RuntimeFractionalPercent) XXX_Size 

func (m *RuntimeFractionalPercent) XXX_Size() int

func (*RuntimeFractionalPercent) XXX_Unmarshal 

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

type RuntimeUInt32 

type RuntimeUInt32 struct {
	// Default value if runtime value is not available.
	DefaultValue uint32 `protobuf:"varint,2,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	// Runtime key to get value for comparison. This value is used if defined.
	RuntimeKey           string   `protobuf:"bytes,3,opt,name=runtime_key,json=runtimeKey,proto3" json:"runtime_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Runtime derived uint32 with a default when not specified.

func (*RuntimeUInt32) Descriptor 

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

func (*RuntimeUInt32) Equal 

func (this *RuntimeUInt32) Equal(that interface{}) bool

func (*RuntimeUInt32) GetDefaultValue 

func (m *RuntimeUInt32) GetDefaultValue() uint32

func (*RuntimeUInt32) GetRuntimeKey 

func (m *RuntimeUInt32) GetRuntimeKey() string

func (*RuntimeUInt32) Marshal 

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

func (*RuntimeUInt32) MarshalTo 

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

func (*RuntimeUInt32) ProtoMessage 

func (*RuntimeUInt32) ProtoMessage()

func (*RuntimeUInt32) Reset 

func (m *RuntimeUInt32) Reset()

func (*RuntimeUInt32) Size 

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

func (*RuntimeUInt32) String 

func (m *RuntimeUInt32) String() string

func (*RuntimeUInt32) Unmarshal 

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

func (*RuntimeUInt32) XXX_DiscardUnknown 

func (m *RuntimeUInt32) XXX_DiscardUnknown()

func (*RuntimeUInt32) XXX_Marshal 

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

func (*RuntimeUInt32) XXX_Merge 

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

func (*RuntimeUInt32) XXX_Size 

func (m *RuntimeUInt32) XXX_Size() int

func (*RuntimeUInt32) XXX_Unmarshal 

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

type SocketAddress 

type SocketAddress struct {
	Protocol SocketAddress_Protocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=envoy.api.v2.core.SocketAddress_Protocol" json:"protocol,omitempty"`
	// The address for this socket. :ref:`Listeners <config_listeners>` will bind
	// to the address. An empty address is not allowed. Specify “0.0.0.0“ or “::“
	// to bind to any address. [#comment:TODO(zuercher) reinstate when implemented:
	// It is possible to distinguish a Listener address via the prefix/suffix matching
	// in :ref:`FilterChainMatch <envoy_api_msg_listener.FilterChainMatch>`.] When used
	// within an upstream :ref:`BindConfig <envoy_api_msg_core.BindConfig>`, the address
	// controls the source address of outbound connections. For :ref:`clusters
	// <envoy_api_msg_Cluster>`, the cluster type determines whether the
	// address must be an IP (*STATIC* or *EDS* clusters) or a hostname resolved by DNS
	// (*STRICT_DNS* or *LOGICAL_DNS* clusters). Address resolution can be customized
	// via :ref:`resolver_name <envoy_api_field_core.SocketAddress.resolver_name>`.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Types that are valid to be assigned to PortSpecifier:
	//	*SocketAddress_PortValue
	//	*SocketAddress_NamedPort
	PortSpecifier isSocketAddress_PortSpecifier `protobuf_oneof:"port_specifier"`
	// The name of the custom resolver. This must have been registered with Envoy. If
	// this is empty, a context dependent default applies. If the address is a concrete
	// IP address, no resolution will occur. If address is a hostname this
	// should be set for resolution other than DNS. Specifying a custom resolver with
	// *STRICT_DNS* or *LOGICAL_DNS* will generate an error at runtime.
	ResolverName string `protobuf:"bytes,5,opt,name=resolver_name,json=resolverName,proto3" json:"resolver_name,omitempty"`
	// When binding to an IPv6 address above, this enables `IPv4 compatibility
	// <https://tools.ietf.org/html/rfc3493#page-11>`_. Binding to “::“ will
	// allow both IPv4 and IPv6 connections, with peer IPv4 addresses mapped into
	// IPv6 space as “::FFFF:<IPv4-address>“.
	Ipv4Compat           bool     `protobuf:"varint,6,opt,name=ipv4_compat,json=ipv4Compat,proto3" json:"ipv4_compat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SocketAddress) Descriptor 

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

func (*SocketAddress) Equal 

func (this *SocketAddress) Equal(that interface{}) bool

func (*SocketAddress) GetAddress 

func (m *SocketAddress) GetAddress() string

func (*SocketAddress) GetIpv4Compat 

func (m *SocketAddress) GetIpv4Compat() bool

func (*SocketAddress) GetNamedPort 

func (m *SocketAddress) GetNamedPort() string

func (*SocketAddress) GetPortSpecifier 

func (m *SocketAddress) GetPortSpecifier() isSocketAddress_PortSpecifier

func (*SocketAddress) GetPortValue 

func (m *SocketAddress) GetPortValue() uint32

func (*SocketAddress) GetProtocol 

func (m *SocketAddress) GetProtocol() SocketAddress_Protocol

func (*SocketAddress) GetResolverName 

func (m *SocketAddress) GetResolverName() string

func (*SocketAddress) Marshal 

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

func (*SocketAddress) MarshalTo 

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

func (*SocketAddress) ProtoMessage 

func (*SocketAddress) ProtoMessage()

func (*SocketAddress) Reset 

func (m *SocketAddress) Reset()

func (*SocketAddress) Size 

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

func (*SocketAddress) String 

func (m *SocketAddress) String() string

func (*SocketAddress) Unmarshal 

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

func (*SocketAddress) XXX_DiscardUnknown 

func (m *SocketAddress) XXX_DiscardUnknown()

func (*SocketAddress) XXX_Marshal 

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

func (*SocketAddress) XXX_Merge 

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

func (*SocketAddress) XXX_OneofFuncs 

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

func (m *SocketAddress) XXX_Size() int

func (*SocketAddress) XXX_Unmarshal 

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

type SocketAddress_NamedPort 

type SocketAddress_NamedPort struct {
	NamedPort string `protobuf:"bytes,4,opt,name=named_port,json=namedPort,proto3,oneof"`
}

func (*SocketAddress_NamedPort) Equal 

func (this *SocketAddress_NamedPort) Equal(that interface{}) bool

func (*SocketAddress_NamedPort) MarshalTo 

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

func (*SocketAddress_NamedPort) Size 

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

type SocketAddress_PortValue 

type SocketAddress_PortValue struct {
	PortValue uint32 `protobuf:"varint,3,opt,name=port_value,json=portValue,proto3,oneof"`
}

func (*SocketAddress_PortValue) Equal 

func (this *SocketAddress_PortValue) Equal(that interface{}) bool

func (*SocketAddress_PortValue) MarshalTo 

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

func (*SocketAddress_PortValue) Size 

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

type SocketAddress_Protocol 

type SocketAddress_Protocol int32
const (
	TCP SocketAddress_Protocol = 0
	// [#not-implemented-hide:]
	UDP SocketAddress_Protocol = 1
)

func (SocketAddress_Protocol) EnumDescriptor 

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

func (SocketAddress_Protocol) String 

func (x SocketAddress_Protocol) String() string

type SocketOption 

type SocketOption struct {
	// An optional name to give this socket option for debugging, etc.
	// Uniqueness is not required and no special meaning is assumed.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// Corresponding to the level value passed to setsockopt, such as IPPROTO_TCP
	Level int64 `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	// The numeric name as passed to setsockopt
	Name int64 `protobuf:"varint,3,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*SocketOption_IntValue
	//	*SocketOption_BufValue
	Value isSocketOption_Value `protobuf_oneof:"value"`
	// The state in which the option will be applied. When used in BindConfig
	// STATE_PREBIND is currently the only valid value.
	State                SocketOption_SocketState `protobuf:"varint,6,opt,name=state,proto3,enum=envoy.api.v2.core.SocketOption_SocketState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Generic socket option message. This would be used to set socket options that might not exist in upstream kernels or precompiled Envoy binaries.

func (*SocketOption) Descriptor 

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

func (*SocketOption) Equal 

func (this *SocketOption) Equal(that interface{}) bool

func (*SocketOption) GetBufValue 

func (m *SocketOption) GetBufValue() []byte

func (*SocketOption) GetDescription 

func (m *SocketOption) GetDescription() string

func (*SocketOption) GetIntValue 

func (m *SocketOption) GetIntValue() int64

func (*SocketOption) GetLevel 

func (m *SocketOption) GetLevel() int64

func (*SocketOption) GetName 

func (m *SocketOption) GetName() int64

func (*SocketOption) GetState 

func (m *SocketOption) GetState() SocketOption_SocketState

func (*SocketOption) GetValue 

func (m *SocketOption) GetValue() isSocketOption_Value

func (*SocketOption) Marshal 

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

func (*SocketOption) MarshalTo 

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

func (*SocketOption) ProtoMessage 

func (*SocketOption) ProtoMessage()

func (*SocketOption) Reset 

func (m *SocketOption) Reset()

func (*SocketOption) Size 

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

func (*SocketOption) String 

func (m *SocketOption) String() string

func (*SocketOption) Unmarshal 

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

func (*SocketOption) XXX_DiscardUnknown 

func (m *SocketOption) XXX_DiscardUnknown()

func (*SocketOption) XXX_Marshal 

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

func (*SocketOption) XXX_Merge 

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

func (*SocketOption) XXX_OneofFuncs 

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

func (m *SocketOption) XXX_Size() int

func (*SocketOption) XXX_Unmarshal 

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

type SocketOption_BufValue 

type SocketOption_BufValue struct {
	BufValue []byte `protobuf:"bytes,5,opt,name=buf_value,json=bufValue,proto3,oneof"`
}

func (*SocketOption_BufValue) Equal 

func (this *SocketOption_BufValue) Equal(that interface{}) bool

func (*SocketOption_BufValue) MarshalTo 

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

func (*SocketOption_BufValue) Size 

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

type SocketOption_IntValue 

type SocketOption_IntValue struct {
	IntValue int64 `protobuf:"varint,4,opt,name=int_value,json=intValue,proto3,oneof"`
}

func (*SocketOption_IntValue) Equal 

func (this *SocketOption_IntValue) Equal(that interface{}) bool

func (*SocketOption_IntValue) MarshalTo 

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

func (*SocketOption_IntValue) Size 

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

type SocketOption_SocketState 

type SocketOption_SocketState int32
const (
	// Socket options are applied after socket creation but before binding the socket to a port
	STATE_PREBIND SocketOption_SocketState = 0
	// Socket options are applied after binding the socket to a port but before calling listen()
	STATE_BOUND SocketOption_SocketState = 1
	// Socket options are applied after calling listen()
	STATE_LISTENING SocketOption_SocketState = 2
)

func (SocketOption_SocketState) EnumDescriptor 

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

func (SocketOption_SocketState) String 

func (x SocketOption_SocketState) String() string

type TcpKeepalive 

type TcpKeepalive struct {
	// Maximum number of keepalive probes to send without response before deciding
	// the connection is dead. Default is to use the OS level configuration (unless
	// overridden, Linux defaults to 9.)
	KeepaliveProbes *types.UInt32Value `protobuf:"bytes,1,opt,name=keepalive_probes,json=keepaliveProbes,proto3" json:"keepalive_probes,omitempty"`
	// The number of seconds a connection needs to be idle before keep-alive probes
	// start being sent. Default is to use the OS level configuration (unless
	// overridden, Linux defaults to 7200s (ie 2 hours.)
	KeepaliveTime *types.UInt32Value `protobuf:"bytes,2,opt,name=keepalive_time,json=keepaliveTime,proto3" json:"keepalive_time,omitempty"`
	// The number of seconds between keep-alive probes. Default is to use the OS
	// level configuration (unless overridden, Linux defaults to 75s.)
	KeepaliveInterval    *types.UInt32Value `protobuf:"bytes,3,opt,name=keepalive_interval,json=keepaliveInterval,proto3" json:"keepalive_interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*TcpKeepalive) Descriptor 

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

func (*TcpKeepalive) Equal 

func (this *TcpKeepalive) Equal(that interface{}) bool

func (*TcpKeepalive) GetKeepaliveInterval 

func (m *TcpKeepalive) GetKeepaliveInterval() *types.UInt32Value

func (*TcpKeepalive) GetKeepaliveProbes 

func (m *TcpKeepalive) GetKeepaliveProbes() *types.UInt32Value

func (*TcpKeepalive) GetKeepaliveTime 

func (m *TcpKeepalive) GetKeepaliveTime() *types.UInt32Value

func (*TcpKeepalive) Marshal 

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

func (*TcpKeepalive) MarshalTo 

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

func (*TcpKeepalive) ProtoMessage 

func (*TcpKeepalive) ProtoMessage()

func (*TcpKeepalive) Reset 

func (m *TcpKeepalive) Reset()

func (*TcpKeepalive) Size 

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

func (*TcpKeepalive) String 

func (m *TcpKeepalive) String() string

func (*TcpKeepalive) Unmarshal 

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

func (*TcpKeepalive) XXX_DiscardUnknown 

func (m *TcpKeepalive) XXX_DiscardUnknown()

func (*TcpKeepalive) XXX_Marshal 

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

func (*TcpKeepalive) XXX_Merge 

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

func (*TcpKeepalive) XXX_Size 

func (m *TcpKeepalive) XXX_Size() int

func (*TcpKeepalive) XXX_Unmarshal 

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

type TrafficDirection 

type TrafficDirection int32

Identifies the direction of the traffic relative to the local Envoy. 

const (
	// Default option is unspecified.
	TrafficDirection_UNSPECIFIED TrafficDirection = 0
	// The transport is used for incoming traffic.
	TrafficDirection_INBOUND TrafficDirection = 1
	// The transport is used for outgoing traffic.
	TrafficDirection_OUTBOUND TrafficDirection = 2
)

func (TrafficDirection) EnumDescriptor 

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

func (TrafficDirection) String 

func (x TrafficDirection) String() string

type TransportSocket 

type TransportSocket struct {
	// The name of the transport socket to instantiate. The name must match a supported transport
	// socket implementation.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Implementation specific configuration which depends on the implementation being instantiated.
	// See the supported transport socket implementations for further documentation.
	//
	// Types that are valid to be assigned to ConfigType:
	//	*TransportSocket_Config
	//	*TransportSocket_TypedConfig
	ConfigType           isTransportSocket_ConfigType `protobuf_oneof:"config_type"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

Configuration for transport socket in :ref:`listeners <config_listeners>` and :ref:`clusters <envoy_api_msg_Cluster>`. If the configuration is empty, a default transport socket implementation and configuration will be chosen based on the platform and existence of tls_context.

func (*TransportSocket) Descriptor 

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

func (*TransportSocket) Equal 

func (this *TransportSocket) Equal(that interface{}) bool

func (*TransportSocket) GetConfig 

func (m *TransportSocket) GetConfig() *types.Struct

func (*TransportSocket) GetConfigType 

func (m *TransportSocket) GetConfigType() isTransportSocket_ConfigType

func (*TransportSocket) GetName 

func (m *TransportSocket) GetName() string

func (*TransportSocket) GetTypedConfig 

func (m *TransportSocket) GetTypedConfig() *types.Any

func (*TransportSocket) Marshal 

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

func (*TransportSocket) MarshalTo 

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

func (*TransportSocket) ProtoMessage 

func (*TransportSocket) ProtoMessage()

func (*TransportSocket) Reset 

func (m *TransportSocket) Reset()

func (*TransportSocket) Size 

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

func (*TransportSocket) String 

func (m *TransportSocket) String() string

func (*TransportSocket) Unmarshal 

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

func (*TransportSocket) XXX_DiscardUnknown 

func (m *TransportSocket) XXX_DiscardUnknown()

func (*TransportSocket) XXX_Marshal 

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

func (*TransportSocket) XXX_Merge 

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

func (*TransportSocket) XXX_OneofFuncs 

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

func (m *TransportSocket) XXX_Size() int

func (*TransportSocket) XXX_Unmarshal 

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

type TransportSocket_Config 

type TransportSocket_Config struct {
	Config *types.Struct `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

func (*TransportSocket_Config) Equal 

func (this *TransportSocket_Config) Equal(that interface{}) bool

func (*TransportSocket_Config) MarshalTo 

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

func (*TransportSocket_Config) Size 

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

type TransportSocket_TypedConfig 

type TransportSocket_TypedConfig struct {
	TypedConfig *types.Any `protobuf:"bytes,3,opt,name=typed_config,json=typedConfig,proto3,oneof"`
}

func (*TransportSocket_TypedConfig) Equal 

func (this *TransportSocket_TypedConfig) Equal(that interface{}) bool

func (*TransportSocket_TypedConfig) MarshalTo 

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

func (*TransportSocket_TypedConfig) Size 

func (m *TransportSocket_TypedConfig) 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.