dubbo_proxyv2alpha1

package
v1.33.0-20240422202039... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProtocolType_name = map[int32]string{
		0: "Dubbo",
	}
	ProtocolType_value = map[string]int32{
		"Dubbo": 0,
	}
)

Enum value maps for ProtocolType.

View Source 
var (
	SerializationType_name = map[int32]string{
		0: "Hessian2",
	}
	SerializationType_value = map[string]int32{
		"Hessian2": 0,
	}
)

Enum value maps for SerializationType.

View Source 
var File_envoy_config_filter_network_dubbo_proxy_v2alpha1_dubbo_proxy_proto protoreflect.FileDescriptor
View Source 
var File_envoy_config_filter_network_dubbo_proxy_v2alpha1_route_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type DubboFilter 

type DubboFilter struct {

	// The name of the filter to instantiate. The name must match a supported
	// filter.
	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 *anypb.Any `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

DubboFilter configures a Dubbo filter.

func (*DubboFilter) Descriptor deprecated 

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

Deprecated: Use DubboFilter.ProtoReflect.Descriptor instead.

func (*DubboFilter) GetConfig 

func (x *DubboFilter) GetConfig() *anypb.Any

func (*DubboFilter) GetName 

func (x *DubboFilter) GetName() string

func (*DubboFilter) ProtoMessage 

func (*DubboFilter) ProtoMessage()

func (*DubboFilter) ProtoReflect 

func (x *DubboFilter) ProtoReflect() protoreflect.Message

func (*DubboFilter) Reset 

func (x *DubboFilter) Reset()

func (*DubboFilter) String 

func (x *DubboFilter) String() string

type DubboProxy 

type DubboProxy struct {

	// 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"`
	// Configure the protocol used.
	ProtocolType ProtocolType `` /* 165-byte string literal not displayed */
	// Configure the serialization protocol used.
	SerializationType SerializationType `` /* 185-byte string literal not displayed */
	// The route table for the connection manager is static and is specified in this property.
	RouteConfig []*RouteConfiguration `protobuf:"bytes,4,rep,name=route_config,json=routeConfig,proto3" json:"route_config,omitempty"`
	// A list of individual Dubbo filters that make up the filter chain for requests made to the
	// Dubbo proxy. Order matters as the filters are processed sequentially. For backwards
	// compatibility, if no dubbo_filters are specified, a default Dubbo router filter
	// (`envoy.filters.dubbo.router`) is used.
	DubboFilters []*DubboFilter `protobuf:"bytes,5,rep,name=dubbo_filters,json=dubboFilters,proto3" json:"dubbo_filters,omitempty"`
	// contains filtered or unexported fields
}

[#next-free-field: 6]

func (*DubboProxy) Descriptor deprecated 

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

Deprecated: Use DubboProxy.ProtoReflect.Descriptor instead.

func (*DubboProxy) GetDubboFilters 

func (x *DubboProxy) GetDubboFilters() []*DubboFilter

func (*DubboProxy) GetProtocolType 

func (x *DubboProxy) GetProtocolType() ProtocolType

func (*DubboProxy) GetRouteConfig 

func (x *DubboProxy) GetRouteConfig() []*RouteConfiguration

func (*DubboProxy) GetSerializationType 

func (x *DubboProxy) GetSerializationType() SerializationType

func (*DubboProxy) GetStatPrefix 

func (x *DubboProxy) GetStatPrefix() string

func (*DubboProxy) ProtoMessage 

func (*DubboProxy) ProtoMessage()

func (*DubboProxy) ProtoReflect 

func (x *DubboProxy) ProtoReflect() protoreflect.Message

func (*DubboProxy) Reset 

func (x *DubboProxy) Reset()

func (*DubboProxy) String 

func (x *DubboProxy) String() string

type MethodMatch 

type MethodMatch struct {

	// The name of the method.
	Name *matcher.StringMatcher `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Method parameter definition.
	// The key is the parameter index, starting from 0.
	// The value is the parameter matching type.
	ParamsMatch map[uint32]*MethodMatch_ParameterMatchSpecifier `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MethodMatch) Descriptor deprecated 

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

Deprecated: Use MethodMatch.ProtoReflect.Descriptor instead.

func (*MethodMatch) GetName 

func (x *MethodMatch) GetName() *matcher.StringMatcher

func (*MethodMatch) GetParamsMatch 

func (x *MethodMatch) GetParamsMatch() map[uint32]*MethodMatch_ParameterMatchSpecifier

func (*MethodMatch) ProtoMessage 

func (*MethodMatch) ProtoMessage()

func (*MethodMatch) ProtoReflect 

func (x *MethodMatch) ProtoReflect() protoreflect.Message

func (*MethodMatch) Reset 

func (x *MethodMatch) Reset()

func (*MethodMatch) String 

func (x *MethodMatch) String() string

type MethodMatch_ParameterMatchSpecifier 

type MethodMatch_ParameterMatchSpecifier struct {

	// Types that are assignable to ParameterMatchSpecifier:
	//
	//	*MethodMatch_ParameterMatchSpecifier_ExactMatch
	//	*MethodMatch_ParameterMatchSpecifier_RangeMatch
	ParameterMatchSpecifier isMethodMatch_ParameterMatchSpecifier_ParameterMatchSpecifier `protobuf_oneof:"parameter_match_specifier"`
	// contains filtered or unexported fields
}

The parameter matching type.

func (*MethodMatch_ParameterMatchSpecifier) Descriptor deprecated 

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

Deprecated: Use MethodMatch_ParameterMatchSpecifier.ProtoReflect.Descriptor instead.

func (*MethodMatch_ParameterMatchSpecifier) GetExactMatch 

func (x *MethodMatch_ParameterMatchSpecifier) GetExactMatch() string

func (*MethodMatch_ParameterMatchSpecifier) GetParameterMatchSpecifier 

func (m *MethodMatch_ParameterMatchSpecifier) GetParameterMatchSpecifier() isMethodMatch_ParameterMatchSpecifier_ParameterMatchSpecifier

func (*MethodMatch_ParameterMatchSpecifier) GetRangeMatch 

func (x *MethodMatch_ParameterMatchSpecifier) GetRangeMatch() *_type.Int64Range

func (*MethodMatch_ParameterMatchSpecifier) ProtoMessage 

func (*MethodMatch_ParameterMatchSpecifier) ProtoMessage()

func (*MethodMatch_ParameterMatchSpecifier) ProtoReflect 

func (x *MethodMatch_ParameterMatchSpecifier) ProtoReflect() protoreflect.Message

func (*MethodMatch_ParameterMatchSpecifier) Reset 

func (x *MethodMatch_ParameterMatchSpecifier) Reset()

func (*MethodMatch_ParameterMatchSpecifier) String 

func (x *MethodMatch_ParameterMatchSpecifier) String() string

type MethodMatch_ParameterMatchSpecifier_ExactMatch 

type MethodMatch_ParameterMatchSpecifier_ExactMatch struct {
	// If specified, header match will be performed based on the value of the header.
	ExactMatch string `protobuf:"bytes,3,opt,name=exact_match,json=exactMatch,proto3,oneof"`
}

type MethodMatch_ParameterMatchSpecifier_RangeMatch 

type MethodMatch_ParameterMatchSpecifier_RangeMatch struct {
	// If specified, header match will be performed based on range.
	// The rule will match if the request header value is within this range.
	// The entire request header value must represent an integer in base 10 notation: consisting
	// of an optional plus or minus sign followed by a sequence of digits. The rule will not match
	// if the header value does not represent an integer. Match will fail for empty values,
	// floating point numbers or if only a subsequence of the header value is an integer.
	//
	// Examples:
	//
	//   - For range [-10,0), route will match for header value -1, but not for 0,
	//     "somestring", 10.9, "-1somestring"
	RangeMatch *_type.Int64Range `protobuf:"bytes,4,opt,name=range_match,json=rangeMatch,proto3,oneof"`
}

type ProtocolType 

type ProtocolType int32

Dubbo Protocol types supported by Envoy. 

const (
	// the default protocol.
	ProtocolType_Dubbo ProtocolType = 0
)

func (ProtocolType) Descriptor 

func (ProtocolType) Descriptor() protoreflect.EnumDescriptor

func (ProtocolType) Enum 

func (x ProtocolType) Enum() *ProtocolType

func (ProtocolType) EnumDescriptor deprecated 

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

Deprecated: Use ProtocolType.Descriptor instead.

func (ProtocolType) Number 

func (x ProtocolType) Number() protoreflect.EnumNumber

func (ProtocolType) String 

func (x ProtocolType) String() string

func (ProtocolType) Type 

func (ProtocolType) Type() protoreflect.EnumType

type Route 

type Route struct {

	// Route matching parameters.
	Match *RouteMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Route request to some upstream cluster.
	Route *RouteAction `protobuf:"bytes,2,opt,name=route,proto3" json:"route,omitempty"`
	// contains filtered or unexported fields
}

func (*Route) Descriptor deprecated 

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetMatch 

func (x *Route) GetMatch() *RouteMatch

func (*Route) GetRoute 

func (x *Route) GetRoute() *RouteAction

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect 

func (x *Route) ProtoReflect() protoreflect.Message

func (*Route) Reset 

func (x *Route) Reset()

func (*Route) String 

func (x *Route) String() string

type RouteAction 

type RouteAction struct {

	// Types that are assignable to ClusterSpecifier:
	//
	//	*RouteAction_Cluster
	//	*RouteAction_WeightedClusters
	ClusterSpecifier isRouteAction_ClusterSpecifier `protobuf_oneof:"cluster_specifier"`
	// contains filtered or unexported fields
}

func (*RouteAction) Descriptor deprecated 

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

Deprecated: Use RouteAction.ProtoReflect.Descriptor instead.

func (*RouteAction) GetCluster 

func (x *RouteAction) GetCluster() string

func (*RouteAction) GetClusterSpecifier 

func (m *RouteAction) GetClusterSpecifier() isRouteAction_ClusterSpecifier

func (*RouteAction) GetWeightedClusters 

func (x *RouteAction) GetWeightedClusters() *route.WeightedCluster

func (*RouteAction) ProtoMessage 

func (*RouteAction) ProtoMessage()

func (*RouteAction) ProtoReflect 

func (x *RouteAction) ProtoReflect() protoreflect.Message

func (*RouteAction) Reset 

func (x *RouteAction) Reset()

func (*RouteAction) String 

func (x *RouteAction) String() string

type RouteAction_Cluster 

type RouteAction_Cluster struct {
	// Indicates the upstream cluster to which the request should be routed.
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3,oneof"`
}

type RouteAction_WeightedClusters 

type RouteAction_WeightedClusters struct {
	// Multiple upstream clusters can be specified for a given route. The
	// request is routed to one of the upstream clusters based on weights
	// assigned to each cluster.
	// Currently ClusterWeight only supports the name and weight fields.
	WeightedClusters *route.WeightedCluster `protobuf:"bytes,2,opt,name=weighted_clusters,json=weightedClusters,proto3,oneof"`
}

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 interface name of the service.
	Interface string `protobuf:"bytes,2,opt,name=interface,proto3" json:"interface,omitempty"`
	// Which group does the interface belong to.
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	// The version number of the interface.
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,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,5,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

[#next-free-field: 6]

func (*RouteConfiguration) Descriptor deprecated 

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

Deprecated: Use RouteConfiguration.ProtoReflect.Descriptor instead.

func (*RouteConfiguration) GetGroup 

func (x *RouteConfiguration) GetGroup() string

func (*RouteConfiguration) GetInterface 

func (x *RouteConfiguration) GetInterface() string

func (*RouteConfiguration) GetName 

func (x *RouteConfiguration) GetName() string

func (*RouteConfiguration) GetRoutes 

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

func (*RouteConfiguration) GetVersion 

func (x *RouteConfiguration) GetVersion() string

func (*RouteConfiguration) ProtoMessage 

func (*RouteConfiguration) ProtoMessage()

func (*RouteConfiguration) ProtoReflect 

func (x *RouteConfiguration) ProtoReflect() protoreflect.Message

func (*RouteConfiguration) Reset 

func (x *RouteConfiguration) Reset()

func (*RouteConfiguration) String 

func (x *RouteConfiguration) String() string

type RouteMatch 

type RouteMatch struct {

	// Method level routing matching.
	Method *MethodMatch `protobuf:"bytes,1,opt,name=method,proto3" json:"method,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).
	Headers []*route.HeaderMatcher `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteMatch) Descriptor deprecated 

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

Deprecated: Use RouteMatch.ProtoReflect.Descriptor instead.

func (*RouteMatch) GetHeaders 

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

func (*RouteMatch) GetMethod 

func (x *RouteMatch) GetMethod() *MethodMatch

func (*RouteMatch) ProtoMessage 

func (*RouteMatch) ProtoMessage()

func (*RouteMatch) ProtoReflect 

func (x *RouteMatch) ProtoReflect() protoreflect.Message

func (*RouteMatch) Reset 

func (x *RouteMatch) Reset()

func (*RouteMatch) String 

func (x *RouteMatch) String() string

type SerializationType 

type SerializationType int32

Dubbo Serialization types supported by Envoy. 

const (
	// the default serialization protocol.
	SerializationType_Hessian2 SerializationType = 0
)

func (SerializationType) Descriptor 

func (SerializationType) Descriptor() protoreflect.EnumDescriptor

func (SerializationType) Enum 

func (x SerializationType) Enum() *SerializationType

func (SerializationType) EnumDescriptor deprecated 

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

Deprecated: Use SerializationType.Descriptor instead.

func (SerializationType) Number 

func (x SerializationType) Number() protoreflect.EnumNumber

func (SerializationType) String 

func (x SerializationType) String() string

func (SerializationType) Type 

func (SerializationType) Type() protoreflect.EnumType

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.