v2

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRoute = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRoute   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthThriftProxy = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowThriftProxy   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ProtocolType_name = map[int32]string{
	0: "AUTO_PROTOCOL",
	1: "BINARY",
	2: "LAX_BINARY",
	3: "COMPACT",
	4: "TWITTER",
}
View Source 
var ProtocolType_value = map[string]int32{
	"AUTO_PROTOCOL": 0,
	"BINARY":        1,
	"LAX_BINARY":    2,
	"COMPACT":       3,
	"TWITTER":       4,
}
View Source 
var TransportType_name = map[int32]string{
	0: "AUTO_TRANSPORT",
	1: "FRAMED",
	2: "UNFRAMED",
	3: "HEADER",
}
View Source 
var TransportType_value = map[string]int32{
	"AUTO_TRANSPORT": 0,
	"FRAMED":         1,
	"UNFRAMED":       2,
	"HEADER":         3,
}

Functions

This section is empty.

Types

type ProtocolType added in v0.6.0 

type ProtocolType int32

Thrift Protocol types supported by Envoy. 

const (
	// For downstream connections, the Thrift proxy will attempt to determine which protocol to use.
	// Note that the older, non-strict (or lax) binary protocol is not included in automatic protocol
	// detection. For upstream connections, the Thrift proxy will use the same protocol as the
	// downstream connection.
	AUTO_PROTOCOL ProtocolType = 0
	// The Thrift proxy will use the Thrift binary protocol.
	BINARY ProtocolType = 1
	// The Thrift proxy will use Thrift non-strict binary protocol.
	LAX_BINARY ProtocolType = 2
	// The Thrift proxy will use the Thrift compact protocol.
	COMPACT ProtocolType = 3
	// The Thrift proxy will use the Thrift "Twitter" protocol implemented by the finagle library.
	TWITTER ProtocolType = 4
)

func (ProtocolType) EnumDescriptor added in v0.6.0 

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

func (ProtocolType) String added in v0.6.0 

func (x ProtocolType) String() string

type Route 

type Route struct {
	// Route matching parameters.
	Match RouteMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match"`
	// Route request to some upstream cluster.
	Route                RouteAction `protobuf:"bytes,2,opt,name=route,proto3" json:"route"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

[#comment:next free field: 3]

func (*Route) Descriptor 

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

func (*Route) GetMatch 

func (m *Route) GetMatch() RouteMatch

func (*Route) GetRoute 

func (m *Route) GetRoute() RouteAction

func (*Route) Marshal 

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

func (*Route) MarshalTo 

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

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) Reset 

func (m *Route) Reset()

func (*Route) Size 

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

func (*Route) String 

func (m *Route) String() string

func (*Route) Unmarshal 

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

func (*Route) Validate 

func (m *Route) Validate() error

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

func (*Route) XXX_DiscardUnknown 

func (m *Route) XXX_DiscardUnknown()

func (*Route) XXX_Marshal 

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

func (*Route) XXX_Merge 

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

func (*Route) XXX_Size 

func (m *Route) XXX_Size() int

func (*Route) XXX_Unmarshal 

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

type RouteAction 

type RouteAction struct {
	// Types that are valid to be assigned to ClusterSpecifier:
	//	*RouteAction_Cluster
	//	*RouteAction_WeightedClusters
	ClusterSpecifier isRouteAction_ClusterSpecifier `protobuf_oneof:"cluster_specifier"`
	// Optional endpoint metadata match criteria used by the subset load balancer. Only endpoints in
	// the upstream cluster with metadata matching what is set in this field will be considered.
	// Note that this will be merged with what's provided in :ref: `WeightedCluster.MetadataMatch
	// <envoy_api_field_config.filter.network.thrift_proxy.v2alpha1.WeightedCluster.ClusterWeight.metadata_match>`,
	// with values there taking precedence. Keys and values should be provided under the "envoy.lb"
	// metadata key.
	MetadataMatch *core.Metadata `protobuf:"bytes,3,opt,name=metadata_match,json=metadataMatch,proto3" json:"metadata_match,omitempty"`
	// Specifies a set of rate limit configurations that could be applied to the route.
	// N.B. Thrift service or method name matching can be achieved by specifying a RequestHeaders
	// action with the header name ":method-name".
	RateLimits           []*route.RateLimit `protobuf:"bytes,4,rep,name=rate_limits,json=rateLimits,proto3" json:"rate_limits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

[#comment:next free field: 5]

func (*RouteAction) Descriptor 

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

func (*RouteAction) GetCluster 

func (m *RouteAction) GetCluster() string

func (*RouteAction) GetClusterSpecifier added in v0.6.0 

func (m *RouteAction) GetClusterSpecifier() isRouteAction_ClusterSpecifier

func (*RouteAction) GetMetadataMatch added in v0.6.0 

func (m *RouteAction) GetMetadataMatch() *core.Metadata

func (*RouteAction) GetRateLimits added in v0.6.2 

func (m *RouteAction) GetRateLimits() []*route.RateLimit

func (*RouteAction) GetWeightedClusters added in v0.6.0 

func (m *RouteAction) GetWeightedClusters() *WeightedCluster

func (*RouteAction) Marshal 

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

func (*RouteAction) MarshalTo 

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

func (*RouteAction) ProtoMessage 

func (*RouteAction) ProtoMessage()

func (*RouteAction) Reset 

func (m *RouteAction) Reset()

func (*RouteAction) Size 

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

func (*RouteAction) String 

func (m *RouteAction) String() string

func (*RouteAction) Unmarshal 

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

func (*RouteAction) Validate 

func (m *RouteAction) Validate() error

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

func (*RouteAction) XXX_DiscardUnknown 

func (m *RouteAction) XXX_DiscardUnknown()

func (*RouteAction) XXX_Marshal 

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

func (*RouteAction) XXX_Merge 

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

func (*RouteAction) XXX_OneofFuncs added in v0.6.0 

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

func (m *RouteAction) XXX_Size() int

func (*RouteAction) XXX_Unmarshal 

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

type RouteActionValidationError 

type RouteActionValidationError struct {
	// contains filtered or unexported fields
}

RouteActionValidationError is the validation error returned by RouteAction.Validate if the designated constraints aren't met.

func (RouteActionValidationError) Cause 

func (e RouteActionValidationError) Cause() error

Cause function returns cause value.

func (RouteActionValidationError) Error 

func (e RouteActionValidationError) Error() string

Error satisfies the builtin error interface

func (RouteActionValidationError) ErrorName added in v0.7.0 

func (e RouteActionValidationError) ErrorName() string

ErrorName returns error name.

func (RouteActionValidationError) Field 

func (e RouteActionValidationError) Field() string

Field function returns field value.

func (RouteActionValidationError) Key 

func (e RouteActionValidationError) Key() bool

Key function returns key value.

func (RouteActionValidationError) Reason 

func (e RouteActionValidationError) Reason() string

Reason function returns reason value.

type RouteAction_Cluster added in v0.6.0 

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

func (*RouteAction_Cluster) MarshalTo added in v0.6.0 

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

func (*RouteAction_Cluster) Size added in v0.6.0 

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

type RouteAction_WeightedClusters added in v0.6.0 

type RouteAction_WeightedClusters struct {
	WeightedClusters *WeightedCluster `protobuf:"bytes,2,opt,name=weighted_clusters,json=weightedClusters,proto3,oneof"`
}

func (*RouteAction_WeightedClusters) MarshalTo added in v0.6.0 

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

func (*RouteAction_WeightedClusters) Size added in v0.6.0 

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

type RouteConfiguration 

type RouteConfiguration struct {
	// The name of the route configuration. Reserved for future use in asynchronous route discovery.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The list of routes that will be matched, in order, against incoming requests. The first route
	// that matches will be used.
	Routes               []Route  `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

[#comment:next free field: 3]

func (*RouteConfiguration) Descriptor 

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

func (*RouteConfiguration) GetName 

func (m *RouteConfiguration) GetName() string

func (*RouteConfiguration) GetRoutes 

func (m *RouteConfiguration) GetRoutes() []Route

func (*RouteConfiguration) Marshal 

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

func (*RouteConfiguration) MarshalTo 

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

func (*RouteConfiguration) ProtoMessage 

func (*RouteConfiguration) ProtoMessage()

func (*RouteConfiguration) Reset 

func (m *RouteConfiguration) Reset()

func (*RouteConfiguration) Size 

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

func (*RouteConfiguration) String 

func (m *RouteConfiguration) String() string

func (*RouteConfiguration) Unmarshal 

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

func (*RouteConfiguration) Validate 

func (m *RouteConfiguration) Validate() error

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

func (*RouteConfiguration) XXX_DiscardUnknown 

func (m *RouteConfiguration) XXX_DiscardUnknown()

func (*RouteConfiguration) XXX_Marshal 

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

func (*RouteConfiguration) XXX_Merge 

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

func (*RouteConfiguration) XXX_Size 

func (m *RouteConfiguration) XXX_Size() int

func (*RouteConfiguration) XXX_Unmarshal 

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

type RouteConfigurationValidationError 

type RouteConfigurationValidationError struct {
	// contains filtered or unexported fields
}

RouteConfigurationValidationError is the validation error returned by RouteConfiguration.Validate if the designated constraints aren't met.

func (RouteConfigurationValidationError) Cause 

func (e RouteConfigurationValidationError) Cause() error

Cause function returns cause value.

func (RouteConfigurationValidationError) Error 

func (e RouteConfigurationValidationError) Error() string

Error satisfies the builtin error interface

func (RouteConfigurationValidationError) ErrorName added in v0.7.0 

func (e RouteConfigurationValidationError) ErrorName() string

ErrorName returns error name.

func (RouteConfigurationValidationError) Field 

func (e RouteConfigurationValidationError) Field() string

Field function returns field value.

func (RouteConfigurationValidationError) Key 

func (e RouteConfigurationValidationError) Key() bool

Key function returns key value.

func (RouteConfigurationValidationError) Reason 

func (e RouteConfigurationValidationError) Reason() string

Reason function returns reason value.

type RouteMatch 

type RouteMatch struct {
	// Types that are valid to be assigned to MatchSpecifier:
	//	*RouteMatch_MethodName
	//	*RouteMatch_ServiceName
	MatchSpecifier isRouteMatch_MatchSpecifier `protobuf_oneof:"match_specifier"`
	// Inverts whatever matching is done in the :ref:`method_name
	// <envoy_api_field_config.filter.network.thrift_proxy.v2alpha1.RouteMatch.method_name>` or
	// :ref:`service_name
	// <envoy_api_field_config.filter.network.thrift_proxy.v2alpha1.RouteMatch.service_name>` fields.
	// Cannot be combined with wildcard matching as that would result in routes never being matched.
	//
	// .. note::
	//
	//   This does not invert matching done as part of the :ref:`headers field
	//   <envoy_api_field_config.filter.network.thrift_proxy.v2alpha1.RouteMatch.headers>` field. To
	//   invert header matching, see :ref:`invert_match
	//   <envoy_api_field_route.HeaderMatcher.invert_match>`.
	Invert bool `protobuf:"varint,3,opt,name=invert,proto3" json:"invert,omitempty"`
	// Specifies a set of headers that the route should match on. The router will check the request’s
	// headers against all the specified headers in the route config. A match will happen if all the
	// headers in the route are present in the request with the same values (or based on presence if
	// the value field is not in the config). Note that this only applies for Thrift transports and/or
	// protocols that support headers.
	Headers              []*route.HeaderMatcher `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

[#comment:next free field: 5]

func (*RouteMatch) Descriptor 

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

func (*RouteMatch) GetHeaders added in v0.6.0 

func (m *RouteMatch) GetHeaders() []*route.HeaderMatcher

func (*RouteMatch) GetInvert added in v0.6.0 

func (m *RouteMatch) GetInvert() bool

func (*RouteMatch) GetMatchSpecifier added in v0.6.0 

func (m *RouteMatch) GetMatchSpecifier() isRouteMatch_MatchSpecifier

func (*RouteMatch) GetMethodName added in v0.6.0 

func (m *RouteMatch) GetMethodName() string

func (*RouteMatch) GetServiceName added in v0.6.0 

func (m *RouteMatch) GetServiceName() string

func (*RouteMatch) Marshal 

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

func (*RouteMatch) MarshalTo 

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

func (*RouteMatch) ProtoMessage 

func (*RouteMatch) ProtoMessage()

func (*RouteMatch) Reset 

func (m *RouteMatch) Reset()

func (*RouteMatch) Size 

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

func (*RouteMatch) String 

func (m *RouteMatch) String() string

func (*RouteMatch) Unmarshal 

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

func (*RouteMatch) Validate 

func (m *RouteMatch) Validate() error

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

func (*RouteMatch) XXX_DiscardUnknown 

func (m *RouteMatch) XXX_DiscardUnknown()

func (*RouteMatch) XXX_Marshal 

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

func (*RouteMatch) XXX_Merge 

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

func (*RouteMatch) XXX_OneofFuncs added in v0.6.0 

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

func (m *RouteMatch) XXX_Size() int

func (*RouteMatch) XXX_Unmarshal 

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

type RouteMatchValidationError 

type RouteMatchValidationError struct {
	// contains filtered or unexported fields
}

RouteMatchValidationError is the validation error returned by RouteMatch.Validate if the designated constraints aren't met.

func (RouteMatchValidationError) Cause 

func (e RouteMatchValidationError) Cause() error

Cause function returns cause value.

func (RouteMatchValidationError) Error 

func (e RouteMatchValidationError) Error() string

Error satisfies the builtin error interface

func (RouteMatchValidationError) ErrorName added in v0.7.0 

func (e RouteMatchValidationError) ErrorName() string

ErrorName returns error name.

func (RouteMatchValidationError) Field 

func (e RouteMatchValidationError) Field() string

Field function returns field value.

func (RouteMatchValidationError) Key 

func (e RouteMatchValidationError) Key() bool

Key function returns key value.

func (RouteMatchValidationError) Reason 

func (e RouteMatchValidationError) Reason() string

Reason function returns reason value.

type RouteMatch_MethodName added in v0.6.0 

type RouteMatch_MethodName struct {
	MethodName string `protobuf:"bytes,1,opt,name=method_name,json=methodName,proto3,oneof"`
}

func (*RouteMatch_MethodName) MarshalTo added in v0.6.0 

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

func (*RouteMatch_MethodName) Size added in v0.6.0 

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

type RouteMatch_ServiceName added in v0.6.0 

type RouteMatch_ServiceName struct {
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3,oneof"`
}

func (*RouteMatch_ServiceName) MarshalTo added in v0.6.0 

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

func (*RouteMatch_ServiceName) Size added in v0.6.0 

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

type RouteValidationError 

type RouteValidationError struct {
	// contains filtered or unexported fields
}

RouteValidationError is the validation error returned by Route.Validate if the designated constraints aren't met.

func (RouteValidationError) Cause 

func (e RouteValidationError) Cause() error

Cause function returns cause value.

func (RouteValidationError) Error 

func (e RouteValidationError) Error() string

Error satisfies the builtin error interface

func (RouteValidationError) ErrorName added in v0.7.0 

func (e RouteValidationError) ErrorName() string

ErrorName returns error name.

func (RouteValidationError) Field 

func (e RouteValidationError) Field() string

Field function returns field value.

func (RouteValidationError) Key 

func (e RouteValidationError) Key() bool

Key function returns key value.

func (RouteValidationError) Reason 

func (e RouteValidationError) Reason() string

Reason function returns reason value.

type ThriftFilter added in v0.6.1 

type ThriftFilter struct {
	// The name of the filter to instantiate. The name must match a supported
	// filter. The built-in filters are:
	//
	// [#comment:TODO(zuercher): Auto generate the following list]
	// * :ref:`envoy.filters.thrift.router <config_thrift_filters_router>`
	// * :ref:`envoy.filters.thrift.rate_limit <config_thrift_filters_rate_limit>`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Filter specific configuration which depends on the filter being instantiated. See the supported
	// filters for further documentation.
	//
	// Types that are valid to be assigned to ConfigType:
	//	*ThriftFilter_Config
	//	*ThriftFilter_TypedConfig
	ConfigType           isThriftFilter_ConfigType `protobuf_oneof:"config_type"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

ThriftFilter configures a Thrift filter. [#comment:next free field: 3]

func (*ThriftFilter) Descriptor added in v0.6.1 

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

func (*ThriftFilter) GetConfig added in v0.6.1 

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

func (*ThriftFilter) GetConfigType added in v0.6.3 

func (m *ThriftFilter) GetConfigType() isThriftFilter_ConfigType

func (*ThriftFilter) GetName added in v0.6.1 

func (m *ThriftFilter) GetName() string

func (*ThriftFilter) GetTypedConfig added in v0.6.3 

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

func (*ThriftFilter) Marshal added in v0.6.1 

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

func (*ThriftFilter) MarshalTo added in v0.6.1 

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

func (*ThriftFilter) ProtoMessage added in v0.6.1 

func (*ThriftFilter) ProtoMessage()

func (*ThriftFilter) Reset added in v0.6.1 

func (m *ThriftFilter) Reset()

func (*ThriftFilter) Size added in v0.6.1 

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

func (*ThriftFilter) String added in v0.6.1 

func (m *ThriftFilter) String() string

func (*ThriftFilter) Unmarshal added in v0.6.1 

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

func (*ThriftFilter) Validate added in v0.6.1 

func (m *ThriftFilter) Validate() error

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

func (*ThriftFilter) XXX_DiscardUnknown added in v0.6.1 

func (m *ThriftFilter) XXX_DiscardUnknown()

func (*ThriftFilter) XXX_Marshal added in v0.6.1 

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

func (*ThriftFilter) XXX_Merge added in v0.6.1 

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

func (*ThriftFilter) XXX_OneofFuncs added in v0.6.3 

func (*ThriftFilter) 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 (*ThriftFilter) XXX_Size added in v0.6.1 

func (m *ThriftFilter) XXX_Size() int

func (*ThriftFilter) XXX_Unmarshal added in v0.6.1 

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

type ThriftFilterValidationError added in v0.6.1 

type ThriftFilterValidationError struct {
	// contains filtered or unexported fields
}

ThriftFilterValidationError is the validation error returned by ThriftFilter.Validate if the designated constraints aren't met.

func (ThriftFilterValidationError) Cause added in v0.6.1 

func (e ThriftFilterValidationError) Cause() error

Cause function returns cause value.

func (ThriftFilterValidationError) Error added in v0.6.1 

func (e ThriftFilterValidationError) Error() string

Error satisfies the builtin error interface

func (ThriftFilterValidationError) ErrorName added in v0.7.0 

func (e ThriftFilterValidationError) ErrorName() string

ErrorName returns error name.

func (ThriftFilterValidationError) Field added in v0.6.1 

func (e ThriftFilterValidationError) Field() string

Field function returns field value.

func (ThriftFilterValidationError) Key added in v0.6.1 

func (e ThriftFilterValidationError) Key() bool

Key function returns key value.

func (ThriftFilterValidationError) Reason added in v0.6.1 

func (e ThriftFilterValidationError) Reason() string

Reason function returns reason value.

type ThriftFilter_Config added in v0.6.3 

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

func (*ThriftFilter_Config) MarshalTo added in v0.6.3 

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

func (*ThriftFilter_Config) Size added in v0.6.3 

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

type ThriftFilter_TypedConfig added in v0.6.3 

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

func (*ThriftFilter_TypedConfig) MarshalTo added in v0.6.3 

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

func (*ThriftFilter_TypedConfig) Size added in v0.6.3 

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

type ThriftProtocolOptions added in v0.6.0 

type ThriftProtocolOptions struct {
	// Supplies the type of transport that the Thrift proxy should use for upstream connections.
	// Selecting
	// :ref:`AUTO_TRANSPORT<envoy_api_enum_value_config.filter.network.thrift_proxy.v2alpha1.TransportType.AUTO_TRANSPORT>`,
	// which is the default, causes the proxy to use the same transport as the downstream connection.
	Transport TransportType `` /* 141-byte string literal not displayed */
	// Supplies the type of protocol that the Thrift proxy should use for upstream connections.
	// Selecting
	// :ref:`AUTO_PROTOCOL<envoy_api_enum_value_config.filter.network.thrift_proxy.v2alpha1.ProtocolType.AUTO_PROTOCOL>`,
	// which is the default, causes the proxy to use the same protocol as the downstream connection.
	Protocol             ProtocolType `` /* 138-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ThriftProtocolOptions specifies Thrift upstream protocol options. This object is used in in :ref:`extension_protocol_options<envoy_api_field_Cluster.extension_protocol_options>`, keyed by the name `envoy.filters.network.thrift_proxy`. [#comment:next free field: 3]

func (*ThriftProtocolOptions) Descriptor added in v0.6.0 

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

func (*ThriftProtocolOptions) GetProtocol added in v0.6.0 

func (m *ThriftProtocolOptions) GetProtocol() ProtocolType

func (*ThriftProtocolOptions) GetTransport added in v0.6.0 

func (m *ThriftProtocolOptions) GetTransport() TransportType

func (*ThriftProtocolOptions) Marshal added in v0.6.0 

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

func (*ThriftProtocolOptions) MarshalTo added in v0.6.0 

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

func (*ThriftProtocolOptions) ProtoMessage added in v0.6.0 

func (*ThriftProtocolOptions) ProtoMessage()

func (*ThriftProtocolOptions) Reset added in v0.6.0 

func (m *ThriftProtocolOptions) Reset()

func (*ThriftProtocolOptions) Size added in v0.6.0 

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

func (*ThriftProtocolOptions) String added in v0.6.0 

func (m *ThriftProtocolOptions) String() string

func (*ThriftProtocolOptions) Unmarshal added in v0.6.0 

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

func (*ThriftProtocolOptions) Validate added in v0.6.0 

func (m *ThriftProtocolOptions) Validate() error

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

func (*ThriftProtocolOptions) XXX_DiscardUnknown added in v0.6.0 

func (m *ThriftProtocolOptions) XXX_DiscardUnknown()

func (*ThriftProtocolOptions) XXX_Marshal added in v0.6.0 

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

func (*ThriftProtocolOptions) XXX_Merge added in v0.6.0 

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

func (*ThriftProtocolOptions) XXX_Size added in v0.6.0 

func (m *ThriftProtocolOptions) XXX_Size() int

func (*ThriftProtocolOptions) XXX_Unmarshal added in v0.6.0 

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

type ThriftProtocolOptionsValidationError added in v0.6.0 

type ThriftProtocolOptionsValidationError struct {
	// contains filtered or unexported fields
}

ThriftProtocolOptionsValidationError is the validation error returned by ThriftProtocolOptions.Validate if the designated constraints aren't met.

func (ThriftProtocolOptionsValidationError) Cause added in v0.6.0 

func (e ThriftProtocolOptionsValidationError) Cause() error

Cause function returns cause value.

func (ThriftProtocolOptionsValidationError) Error added in v0.6.0 

func (e ThriftProtocolOptionsValidationError) Error() string

Error satisfies the builtin error interface

func (ThriftProtocolOptionsValidationError) ErrorName added in v0.7.0 

func (e ThriftProtocolOptionsValidationError) ErrorName() string

ErrorName returns error name.

func (ThriftProtocolOptionsValidationError) Field added in v0.6.0 

func (e ThriftProtocolOptionsValidationError) Field() string

Field function returns field value.

func (ThriftProtocolOptionsValidationError) Key added in v0.6.0 

func (e ThriftProtocolOptionsValidationError) Key() bool

Key function returns key value.

func (ThriftProtocolOptionsValidationError) Reason added in v0.6.0 

func (e ThriftProtocolOptionsValidationError) Reason() string

Reason function returns reason value.

type ThriftProxy 

type ThriftProxy struct {
	// Supplies the type of transport that the Thrift proxy should use. Defaults to
	// :ref:`AUTO_TRANSPORT<envoy_api_enum_value_config.filter.network.thrift_proxy.v2alpha1.TransportType.AUTO_TRANSPORT>`.
	Transport TransportType `` /* 141-byte string literal not displayed */
	// Supplies the type of protocol that the Thrift proxy should use. Defaults to
	// :ref:`AUTO_PROTOCOL<envoy_api_enum_value_config.filter.network.thrift_proxy.v2alpha1.ProtocolType.AUTO_PROTOCOL>`.
	Protocol ProtocolType `` /* 138-byte string literal not displayed */
	// The human readable prefix to use when emitting statistics.
	StatPrefix string `protobuf:"bytes,1,opt,name=stat_prefix,json=statPrefix,proto3" json:"stat_prefix,omitempty"`
	// The route table for the connection manager is static and is specified in this property.
	RouteConfig *RouteConfiguration `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3" json:"route_config,omitempty"`
	// A list of individual Thrift filters that make up the filter chain for requests made to the
	// Thrift proxy. Order matters as the filters are processed sequentially. For backwards
	// compatibility, if no thrift_filters are specified, a default Thrift router filter
	// (`envoy.filters.thrift.router`) is used.
	ThriftFilters        []*ThriftFilter `protobuf:"bytes,5,rep,name=thrift_filters,json=thriftFilters,proto3" json:"thrift_filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

[#comment:next free field: 6]

func (*ThriftProxy) Descriptor 

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

func (*ThriftProxy) GetProtocol 

func (m *ThriftProxy) GetProtocol() ProtocolType

func (*ThriftProxy) GetRouteConfig 

func (m *ThriftProxy) GetRouteConfig() *RouteConfiguration

func (*ThriftProxy) GetStatPrefix 

func (m *ThriftProxy) GetStatPrefix() string

func (*ThriftProxy) GetThriftFilters added in v0.6.1 

func (m *ThriftProxy) GetThriftFilters() []*ThriftFilter

func (*ThriftProxy) GetTransport 

func (m *ThriftProxy) GetTransport() TransportType

func (*ThriftProxy) Marshal 

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

func (*ThriftProxy) MarshalTo 

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

func (*ThriftProxy) ProtoMessage 

func (*ThriftProxy) ProtoMessage()

func (*ThriftProxy) Reset 

func (m *ThriftProxy) Reset()

func (*ThriftProxy) Size 

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

func (*ThriftProxy) String 

func (m *ThriftProxy) String() string

func (*ThriftProxy) Unmarshal 

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

func (*ThriftProxy) Validate 

func (m *ThriftProxy) Validate() error

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

func (*ThriftProxy) XXX_DiscardUnknown 

func (m *ThriftProxy) XXX_DiscardUnknown()

func (*ThriftProxy) XXX_Marshal 

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

func (*ThriftProxy) XXX_Merge 

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

func (*ThriftProxy) XXX_Size 

func (m *ThriftProxy) XXX_Size() int

func (*ThriftProxy) XXX_Unmarshal 

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

type ThriftProxyValidationError 

type ThriftProxyValidationError struct {
	// contains filtered or unexported fields
}

ThriftProxyValidationError is the validation error returned by ThriftProxy.Validate if the designated constraints aren't met.

func (ThriftProxyValidationError) Cause 

func (e ThriftProxyValidationError) Cause() error

Cause function returns cause value.

func (ThriftProxyValidationError) Error 

func (e ThriftProxyValidationError) Error() string

Error satisfies the builtin error interface

func (ThriftProxyValidationError) ErrorName added in v0.7.0 

func (e ThriftProxyValidationError) ErrorName() string

ErrorName returns error name.

func (ThriftProxyValidationError) Field 

func (e ThriftProxyValidationError) Field() string

Field function returns field value.

func (ThriftProxyValidationError) Key 

func (e ThriftProxyValidationError) Key() bool

Key function returns key value.

func (ThriftProxyValidationError) Reason 

func (e ThriftProxyValidationError) Reason() string

Reason function returns reason value.

type TransportType added in v0.6.0 

type TransportType int32

Thrift transport types supported by Envoy. 

const (
	// For downstream connections, the Thrift proxy will attempt to determine which transport to use.
	// For upstream connections, the Thrift proxy will use same transport as the downstream
	// connection.
	AUTO_TRANSPORT TransportType = 0
	// The Thrift proxy will use the Thrift framed transport.
	FRAMED TransportType = 1
	// The Thrift proxy will use the Thrift unframed transport.
	UNFRAMED TransportType = 2
	// The Thrift proxy will assume the client is using the Thrift header transport.
	HEADER TransportType = 3
)

func (TransportType) EnumDescriptor added in v0.6.0 

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

func (TransportType) String added in v0.6.0 

func (x TransportType) String() string

type WeightedCluster added in v0.6.0 

type WeightedCluster struct {
	// Specifies one or more upstream clusters associated with the route.
	Clusters             []*WeightedCluster_ClusterWeight `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

Allows for specification of multiple upstream clusters along with weights that indicate the percentage of traffic to be forwarded to each cluster. The router selects an upstream cluster based on these weights.

func (*WeightedCluster) Descriptor added in v0.6.0 

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

func (*WeightedCluster) GetClusters added in v0.6.0 

func (m *WeightedCluster) GetClusters() []*WeightedCluster_ClusterWeight

func (*WeightedCluster) Marshal added in v0.6.0 

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

func (*WeightedCluster) MarshalTo added in v0.6.0 

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

func (*WeightedCluster) ProtoMessage added in v0.6.0 

func (*WeightedCluster) ProtoMessage()

func (*WeightedCluster) Reset added in v0.6.0 

func (m *WeightedCluster) Reset()

func (*WeightedCluster) Size added in v0.6.0 

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

func (*WeightedCluster) String added in v0.6.0 

func (m *WeightedCluster) String() string

func (*WeightedCluster) Unmarshal added in v0.6.0 

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

func (*WeightedCluster) Validate added in v0.6.0 

func (m *WeightedCluster) Validate() error

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

func (*WeightedCluster) XXX_DiscardUnknown added in v0.6.0 

func (m *WeightedCluster) XXX_DiscardUnknown()

func (*WeightedCluster) XXX_Marshal added in v0.6.0 

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

func (*WeightedCluster) XXX_Merge added in v0.6.0 

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

func (*WeightedCluster) XXX_Size added in v0.6.0 

func (m *WeightedCluster) XXX_Size() int

func (*WeightedCluster) XXX_Unmarshal added in v0.6.0 

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

type WeightedClusterValidationError added in v0.6.0 

type WeightedClusterValidationError struct {
	// contains filtered or unexported fields
}

WeightedClusterValidationError is the validation error returned by WeightedCluster.Validate if the designated constraints aren't met.

func (WeightedClusterValidationError) Cause added in v0.6.0 

func (e WeightedClusterValidationError) Cause() error

Cause function returns cause value.

func (WeightedClusterValidationError) Error added in v0.6.0 

func (e WeightedClusterValidationError) Error() string

Error satisfies the builtin error interface

func (WeightedClusterValidationError) ErrorName added in v0.7.0 

func (e WeightedClusterValidationError) ErrorName() string

ErrorName returns error name.

func (WeightedClusterValidationError) Field added in v0.6.0 

func (e WeightedClusterValidationError) Field() string

Field function returns field value.

func (WeightedClusterValidationError) Key added in v0.6.0 

func (e WeightedClusterValidationError) Key() bool

Key function returns key value.

func (WeightedClusterValidationError) Reason added in v0.6.0 

func (e WeightedClusterValidationError) Reason() string

Reason function returns reason value.

type WeightedCluster_ClusterWeight added in v0.6.0 

type WeightedCluster_ClusterWeight struct {
	// Name of the upstream cluster.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// When a request matches the route, the choice of an upstream cluster is determined by its
	// weight. The sum of weights across all entries in the clusters array determines the total
	// weight.
	Weight *types.UInt32Value `protobuf:"bytes,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// Optional endpoint metadata match criteria used by the subset load balancer. Only endpoints in
	// the upstream cluster with metadata matching what is set in this field, combined with what's
	// provided in :ref: `RouteAction's metadata_match
	// <envoy_api_field_config.filter.network.thrift_proxy.v2alpha1.RouteAction.metadata_match>`,
	// will be considered. Values here will take precedence. Keys and values should be provided
	// under the "envoy.lb" metadata key.
	MetadataMatch        *core.Metadata `protobuf:"bytes,3,opt,name=metadata_match,json=metadataMatch,proto3" json:"metadata_match,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*WeightedCluster_ClusterWeight) Descriptor added in v0.6.0 

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

func (*WeightedCluster_ClusterWeight) GetMetadataMatch added in v0.6.0 

func (m *WeightedCluster_ClusterWeight) GetMetadataMatch() *core.Metadata

func (*WeightedCluster_ClusterWeight) GetName added in v0.6.0 

func (m *WeightedCluster_ClusterWeight) GetName() string

func (*WeightedCluster_ClusterWeight) GetWeight added in v0.6.0 

func (m *WeightedCluster_ClusterWeight) GetWeight() *types.UInt32Value

func (*WeightedCluster_ClusterWeight) Marshal added in v0.6.0 

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

func (*WeightedCluster_ClusterWeight) MarshalTo added in v0.6.0 

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

func (*WeightedCluster_ClusterWeight) ProtoMessage added in v0.6.0 

func (*WeightedCluster_ClusterWeight) ProtoMessage()

func (*WeightedCluster_ClusterWeight) Reset added in v0.6.0 

func (m *WeightedCluster_ClusterWeight) Reset()

func (*WeightedCluster_ClusterWeight) Size added in v0.6.0 

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

func (*WeightedCluster_ClusterWeight) String added in v0.6.0 

func (m *WeightedCluster_ClusterWeight) String() string

func (*WeightedCluster_ClusterWeight) Unmarshal added in v0.6.0 

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

func (*WeightedCluster_ClusterWeight) Validate added in v0.6.0 

func (m *WeightedCluster_ClusterWeight) Validate() error

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

func (*WeightedCluster_ClusterWeight) XXX_DiscardUnknown added in v0.6.0 

func (m *WeightedCluster_ClusterWeight) XXX_DiscardUnknown()

func (*WeightedCluster_ClusterWeight) XXX_Marshal added in v0.6.0 

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

func (*WeightedCluster_ClusterWeight) XXX_Merge added in v0.6.0 

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

func (*WeightedCluster_ClusterWeight) XXX_Size added in v0.6.0 

func (m *WeightedCluster_ClusterWeight) XXX_Size() int

func (*WeightedCluster_ClusterWeight) XXX_Unmarshal added in v0.6.0 

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

type WeightedCluster_ClusterWeightValidationError added in v0.6.0 

type WeightedCluster_ClusterWeightValidationError struct {
	// contains filtered or unexported fields
}

WeightedCluster_ClusterWeightValidationError is the validation error returned by WeightedCluster_ClusterWeight.Validate if the designated constraints aren't met.

func (WeightedCluster_ClusterWeightValidationError) Cause added in v0.6.0 

func (e WeightedCluster_ClusterWeightValidationError) Cause() error

Cause function returns cause value.

func (WeightedCluster_ClusterWeightValidationError) Error added in v0.6.0 

func (e WeightedCluster_ClusterWeightValidationError) Error() string

Error satisfies the builtin error interface

func (WeightedCluster_ClusterWeightValidationError) ErrorName added in v0.7.0 

func (e WeightedCluster_ClusterWeightValidationError) ErrorName() string

ErrorName returns error name.

func (WeightedCluster_ClusterWeightValidationError) Field added in v0.6.0 

func (e WeightedCluster_ClusterWeightValidationError) Field() string

Field function returns field value.

func (WeightedCluster_ClusterWeightValidationError) Key added in v0.6.0 

func (e WeightedCluster_ClusterWeightValidationError) Key() bool

Key function returns key value.

func (WeightedCluster_ClusterWeightValidationError) Reason added in v0.6.0 

func (e WeightedCluster_ClusterWeightValidationError) Reason() string

Reason function returns reason value.

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.