Documentation ¶
Index ¶
- Variables
- type ProtocolType
- type Route
- func (*Route) Descriptor() ([]byte, []int)
- func (m *Route) GetMatch() RouteMatch
- func (m *Route) GetRoute() RouteAction
- func (m *Route) Marshal() (dAtA []byte, err error)
- func (m *Route) MarshalTo(dAtA []byte) (int, error)
- func (*Route) ProtoMessage()
- func (m *Route) Reset()
- func (m *Route) Size() (n int)
- func (m *Route) String() string
- func (m *Route) Unmarshal(dAtA []byte) error
- func (m *Route) Validate() error
- func (m *Route) XXX_DiscardUnknown()
- func (m *Route) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Route) XXX_Merge(src proto.Message)
- func (m *Route) XXX_Size() int
- func (m *Route) XXX_Unmarshal(b []byte) error
- type RouteAction
- func (*RouteAction) Descriptor() ([]byte, []int)
- func (m *RouteAction) GetCluster() string
- func (m *RouteAction) GetClusterSpecifier() isRouteAction_ClusterSpecifier
- func (m *RouteAction) GetMetadataMatch() *core.Metadata
- func (m *RouteAction) GetWeightedClusters() *WeightedCluster
- func (m *RouteAction) Marshal() (dAtA []byte, err error)
- func (m *RouteAction) MarshalTo(dAtA []byte) (int, error)
- func (*RouteAction) ProtoMessage()
- func (m *RouteAction) Reset()
- func (m *RouteAction) Size() (n int)
- func (m *RouteAction) String() string
- func (m *RouteAction) Unmarshal(dAtA []byte) error
- func (m *RouteAction) Validate() error
- func (m *RouteAction) XXX_DiscardUnknown()
- func (m *RouteAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RouteAction) XXX_Merge(src proto.Message)
- func (*RouteAction) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *RouteAction) XXX_Size() int
- func (m *RouteAction) XXX_Unmarshal(b []byte) error
- type RouteActionValidationError
- type RouteAction_Cluster
- type RouteAction_WeightedClusters
- type RouteConfiguration
- func (*RouteConfiguration) Descriptor() ([]byte, []int)
- func (m *RouteConfiguration) GetName() string
- func (m *RouteConfiguration) GetRoutes() []Route
- func (m *RouteConfiguration) Marshal() (dAtA []byte, err error)
- func (m *RouteConfiguration) MarshalTo(dAtA []byte) (int, error)
- func (*RouteConfiguration) ProtoMessage()
- func (m *RouteConfiguration) Reset()
- func (m *RouteConfiguration) Size() (n int)
- func (m *RouteConfiguration) String() string
- func (m *RouteConfiguration) Unmarshal(dAtA []byte) error
- func (m *RouteConfiguration) Validate() error
- func (m *RouteConfiguration) XXX_DiscardUnknown()
- func (m *RouteConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RouteConfiguration) XXX_Merge(src proto.Message)
- func (m *RouteConfiguration) XXX_Size() int
- func (m *RouteConfiguration) XXX_Unmarshal(b []byte) error
- type RouteConfigurationValidationError
- type RouteMatch
- func (*RouteMatch) Descriptor() ([]byte, []int)
- func (m *RouteMatch) GetHeaders() []*route.HeaderMatcher
- func (m *RouteMatch) GetInvert() bool
- func (m *RouteMatch) GetMatchSpecifier() isRouteMatch_MatchSpecifier
- func (m *RouteMatch) GetMethodName() string
- func (m *RouteMatch) GetServiceName() string
- func (m *RouteMatch) Marshal() (dAtA []byte, err error)
- func (m *RouteMatch) MarshalTo(dAtA []byte) (int, error)
- func (*RouteMatch) ProtoMessage()
- func (m *RouteMatch) Reset()
- func (m *RouteMatch) Size() (n int)
- func (m *RouteMatch) String() string
- func (m *RouteMatch) Unmarshal(dAtA []byte) error
- func (m *RouteMatch) Validate() error
- func (m *RouteMatch) XXX_DiscardUnknown()
- func (m *RouteMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RouteMatch) XXX_Merge(src proto.Message)
- func (*RouteMatch) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *RouteMatch) XXX_Size() int
- func (m *RouteMatch) XXX_Unmarshal(b []byte) error
- type RouteMatchValidationError
- type RouteMatch_MethodName
- type RouteMatch_ServiceName
- type RouteValidationError
- type ThriftFilter
- func (*ThriftFilter) Descriptor() ([]byte, []int)
- func (m *ThriftFilter) GetConfig() *types.Struct
- func (m *ThriftFilter) GetName() string
- func (m *ThriftFilter) Marshal() (dAtA []byte, err error)
- func (m *ThriftFilter) MarshalTo(dAtA []byte) (int, error)
- func (*ThriftFilter) ProtoMessage()
- func (m *ThriftFilter) Reset()
- func (m *ThriftFilter) Size() (n int)
- func (m *ThriftFilter) String() string
- func (m *ThriftFilter) Unmarshal(dAtA []byte) error
- func (m *ThriftFilter) Validate() error
- func (m *ThriftFilter) XXX_DiscardUnknown()
- func (m *ThriftFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ThriftFilter) XXX_Merge(src proto.Message)
- func (m *ThriftFilter) XXX_Size() int
- func (m *ThriftFilter) XXX_Unmarshal(b []byte) error
- type ThriftFilterValidationError
- type ThriftProtocolOptions
- func (*ThriftProtocolOptions) Descriptor() ([]byte, []int)
- func (m *ThriftProtocolOptions) GetProtocol() ProtocolType
- func (m *ThriftProtocolOptions) GetTransport() TransportType
- func (m *ThriftProtocolOptions) Marshal() (dAtA []byte, err error)
- func (m *ThriftProtocolOptions) MarshalTo(dAtA []byte) (int, error)
- func (*ThriftProtocolOptions) ProtoMessage()
- func (m *ThriftProtocolOptions) Reset()
- func (m *ThriftProtocolOptions) Size() (n int)
- func (m *ThriftProtocolOptions) String() string
- func (m *ThriftProtocolOptions) Unmarshal(dAtA []byte) error
- func (m *ThriftProtocolOptions) Validate() error
- func (m *ThriftProtocolOptions) XXX_DiscardUnknown()
- func (m *ThriftProtocolOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ThriftProtocolOptions) XXX_Merge(src proto.Message)
- func (m *ThriftProtocolOptions) XXX_Size() int
- func (m *ThriftProtocolOptions) XXX_Unmarshal(b []byte) error
- type ThriftProtocolOptionsValidationError
- type ThriftProxy
- func (*ThriftProxy) Descriptor() ([]byte, []int)
- func (m *ThriftProxy) GetProtocol() ProtocolType
- func (m *ThriftProxy) GetRouteConfig() *RouteConfiguration
- func (m *ThriftProxy) GetStatPrefix() string
- func (m *ThriftProxy) GetThriftFilters() []*ThriftFilter
- func (m *ThriftProxy) GetTransport() TransportType
- func (m *ThriftProxy) Marshal() (dAtA []byte, err error)
- func (m *ThriftProxy) MarshalTo(dAtA []byte) (int, error)
- func (*ThriftProxy) ProtoMessage()
- func (m *ThriftProxy) Reset()
- func (m *ThriftProxy) Size() (n int)
- func (m *ThriftProxy) String() string
- func (m *ThriftProxy) Unmarshal(dAtA []byte) error
- func (m *ThriftProxy) Validate() error
- func (m *ThriftProxy) XXX_DiscardUnknown()
- func (m *ThriftProxy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ThriftProxy) XXX_Merge(src proto.Message)
- func (m *ThriftProxy) XXX_Size() int
- func (m *ThriftProxy) XXX_Unmarshal(b []byte) error
- type ThriftProxyValidationError
- type TransportType
- type WeightedCluster
- func (*WeightedCluster) Descriptor() ([]byte, []int)
- func (m *WeightedCluster) GetClusters() []*WeightedCluster_ClusterWeight
- func (m *WeightedCluster) Marshal() (dAtA []byte, err error)
- func (m *WeightedCluster) MarshalTo(dAtA []byte) (int, error)
- func (*WeightedCluster) ProtoMessage()
- func (m *WeightedCluster) Reset()
- func (m *WeightedCluster) Size() (n int)
- func (m *WeightedCluster) String() string
- func (m *WeightedCluster) Unmarshal(dAtA []byte) error
- func (m *WeightedCluster) Validate() error
- func (m *WeightedCluster) XXX_DiscardUnknown()
- func (m *WeightedCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WeightedCluster) XXX_Merge(src proto.Message)
- func (m *WeightedCluster) XXX_Size() int
- func (m *WeightedCluster) XXX_Unmarshal(b []byte) error
- type WeightedClusterValidationError
- type WeightedCluster_ClusterWeight
- func (*WeightedCluster_ClusterWeight) Descriptor() ([]byte, []int)
- func (m *WeightedCluster_ClusterWeight) GetMetadataMatch() *core.Metadata
- func (m *WeightedCluster_ClusterWeight) GetName() string
- func (m *WeightedCluster_ClusterWeight) GetWeight() *types.UInt32Value
- func (m *WeightedCluster_ClusterWeight) Marshal() (dAtA []byte, err error)
- func (m *WeightedCluster_ClusterWeight) MarshalTo(dAtA []byte) (int, error)
- func (*WeightedCluster_ClusterWeight) ProtoMessage()
- func (m *WeightedCluster_ClusterWeight) Reset()
- func (m *WeightedCluster_ClusterWeight) Size() (n int)
- func (m *WeightedCluster_ClusterWeight) String() string
- func (m *WeightedCluster_ClusterWeight) Unmarshal(dAtA []byte) error
- func (m *WeightedCluster_ClusterWeight) Validate() error
- func (m *WeightedCluster_ClusterWeight) XXX_DiscardUnknown()
- func (m *WeightedCluster_ClusterWeight) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WeightedCluster_ClusterWeight) XXX_Merge(src proto.Message)
- func (m *WeightedCluster_ClusterWeight) XXX_Size() int
- func (m *WeightedCluster_ClusterWeight) XXX_Unmarshal(b []byte) error
- type WeightedCluster_ClusterWeightValidationError
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthRoute = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRoute = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthThriftProxy = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowThriftProxy = fmt.Errorf("proto: integer overflow") )
var ProtocolType_name = map[int32]string{
0: "AUTO_PROTOCOL",
1: "BINARY",
2: "LAX_BINARY",
3: "COMPACT",
4: "TWITTER",
}
var ProtocolType_value = map[string]int32{
"AUTO_PROTOCOL": 0,
"BINARY": 1,
"LAX_BINARY": 2,
"COMPACT": 3,
"TWITTER": 4,
}
var TransportType_name = map[int32]string{
0: "AUTO_TRANSPORT",
1: "FRAMED",
2: "UNFRAMED",
3: "HEADER",
}
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 prarameters. Match RouteMatch `protobuf:"bytes,1,opt,name=match" json:"match"` // Route request to some upstream cluster. Route RouteAction `protobuf:"bytes,2,opt,name=route" json:"route"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#comment:next free field: 3]
func (*Route) Descriptor ¶
func (*Route) GetMatch ¶
func (m *Route) GetMatch() RouteMatch
func (*Route) GetRoute ¶
func (m *Route) GetRoute() RouteAction
func (*Route) ProtoMessage ¶
func (*Route) ProtoMessage()
func (*Route) Validate ¶
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 (*Route) XXX_Unmarshal ¶
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" json:"metadata_match,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#comment:next free field: 3]
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) GetWeightedClusters ¶ added in v0.6.0
func (m *RouteAction) GetWeightedClusters() *WeightedCluster
func (*RouteAction) Marshal ¶
func (m *RouteAction) Marshal() (dAtA []byte, err 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 (dst *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 ¶
RouteActionValidationError is the validation error returned by RouteAction.Validate if the designated constraints aren't met.
func (RouteActionValidationError) Error ¶
func (e RouteActionValidationError) Error() string
Error satisfies the builtin error interface
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,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" 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 (dst *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 ¶
RouteConfigurationValidationError is the validation error returned by RouteConfiguration.Validate if the designated constraints aren't met.
func (RouteConfigurationValidationError) Error ¶
func (e RouteConfigurationValidationError) Error() string
Error satisfies the builtin error interface
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" 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) 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 (dst *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 ¶
RouteMatchValidationError is the validation error returned by RouteMatch.Validate if the designated constraints aren't met.
func (RouteMatchValidationError) Error ¶
func (e RouteMatchValidationError) Error() string
Error satisfies the builtin error interface
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 ¶
RouteValidationError is the validation error returned by Route.Validate if the designated constraints aren't met.
func (RouteValidationError) Error ¶
func (e RouteValidationError) Error() string
Error satisfies the builtin error interface
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>` 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. Config *types.Struct `protobuf:"bytes,2,opt,name=config" json:"config,omitempty"` 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) GetName ¶ added in v0.6.1
func (m *ThriftFilter) GetName() string
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 (dst *ThriftFilter) XXX_Merge(src proto.Message)
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
ThriftFilterValidationError is the validation error returned by ThriftFilter.Validate if the designated constraints aren't met.
func (ThriftFilterValidationError) Error ¶ added in v0.6.1
func (e ThriftFilterValidationError) Error() string
Error satisfies the builtin error interface
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 (dst *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 { Field string Reason string Cause error Key bool }
ThriftProtocolOptionsValidationError is the validation error returned by ThriftProtocolOptions.Validate if the designated constraints aren't met.
func (ThriftProtocolOptionsValidationError) Error ¶ added in v0.6.0
func (e ThriftProtocolOptionsValidationError) Error() string
Error satisfies the builtin error interface
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" 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" 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) 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 (dst *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 ¶
ThriftProxyValidationError is the validation error returned by ThriftProxy.Validate if the designated constraints aren't met.
func (ThriftProxyValidationError) Error ¶
func (e ThriftProxyValidationError) Error() string
Error satisfies the builtin error interface
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" 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 (dst *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
WeightedClusterValidationError is the validation error returned by WeightedCluster.Validate if the designated constraints aren't met.
func (WeightedClusterValidationError) Error ¶ added in v0.6.0
func (e WeightedClusterValidationError) Error() string
Error satisfies the builtin error interface
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" 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" 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 (dst *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 { Field string Reason string Cause error Key bool }
WeightedCluster_ClusterWeightValidationError is the validation error returned by WeightedCluster_ClusterWeight.Validate if the designated constraints aren't met.
func (WeightedCluster_ClusterWeightValidationError) Error ¶ added in v0.6.0
func (e WeightedCluster_ClusterWeightValidationError) Error() string
Error satisfies the builtin error interface