Documentation ¶
Index ¶
- Variables
- type RocketmqProxy
- func (*RocketmqProxy) Descriptor() ([]byte, []int)deprecated
- func (x *RocketmqProxy) GetDevelopMode() bool
- func (x *RocketmqProxy) GetRouteConfig() *RouteConfiguration
- func (x *RocketmqProxy) GetStatPrefix() string
- func (x *RocketmqProxy) GetTransientObjectLifeSpan() *durationpb.Duration
- func (*RocketmqProxy) ProtoMessage()
- func (x *RocketmqProxy) ProtoReflect() protoreflect.Message
- func (x *RocketmqProxy) Reset()
- func (x *RocketmqProxy) String() string
- type Route
- type RouteAction
- func (*RouteAction) Descriptor() ([]byte, []int)deprecated
- func (x *RouteAction) GetCluster() string
- func (x *RouteAction) GetMetadataMatch() *v32.Metadata
- func (*RouteAction) ProtoMessage()
- func (x *RouteAction) ProtoReflect() protoreflect.Message
- func (x *RouteAction) Reset()
- func (x *RouteAction) String() string
- type RouteConfiguration
- func (*RouteConfiguration) Descriptor() ([]byte, []int)deprecated
- func (x *RouteConfiguration) GetName() string
- func (x *RouteConfiguration) GetRoutes() []*Route
- func (*RouteConfiguration) ProtoMessage()
- func (x *RouteConfiguration) ProtoReflect() protoreflect.Message
- func (x *RouteConfiguration) Reset()
- func (x *RouteConfiguration) String() string
- type RouteMatch
- func (*RouteMatch) Descriptor() ([]byte, []int)deprecated
- func (x *RouteMatch) GetHeaders() []*v31.HeaderMatcher
- func (x *RouteMatch) GetTopic() *v3.StringMatcher
- func (*RouteMatch) ProtoMessage()
- func (x *RouteMatch) ProtoReflect() protoreflect.Message
- func (x *RouteMatch) Reset()
- func (x *RouteMatch) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_contrib_envoy_extensions_filters_network_rocketmq_proxy_v3_rocketmq_proxy_proto protoreflect.FileDescriptor
View Source
var File_contrib_envoy_extensions_filters_network_rocketmq_proxy_v3_route_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type RocketmqProxy ¶
type RocketmqProxy 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"` // The route table for the connection manager is specified in this property. RouteConfig *RouteConfiguration `protobuf:"bytes,2,opt,name=route_config,json=routeConfig,proto3" json:"route_config,omitempty"` // The largest duration transient object expected to live, more than 10s is recommended. TransientObjectLifeSpan *durationpb.Duration `` /* 134-byte string literal not displayed */ // If develop_mode is enabled, this proxy plugin may work without dedicated traffic intercepting // facility without considering backward compatibility of exiting RocketMQ client SDK. DevelopMode bool `protobuf:"varint,4,opt,name=develop_mode,json=developMode,proto3" json:"develop_mode,omitempty"` // contains filtered or unexported fields }
func (*RocketmqProxy) Descriptor
deprecated
func (*RocketmqProxy) Descriptor() ([]byte, []int)
Deprecated: Use RocketmqProxy.ProtoReflect.Descriptor instead.
func (*RocketmqProxy) GetDevelopMode ¶
func (x *RocketmqProxy) GetDevelopMode() bool
func (*RocketmqProxy) GetRouteConfig ¶
func (x *RocketmqProxy) GetRouteConfig() *RouteConfiguration
func (*RocketmqProxy) GetStatPrefix ¶
func (x *RocketmqProxy) GetStatPrefix() string
func (*RocketmqProxy) GetTransientObjectLifeSpan ¶
func (x *RocketmqProxy) GetTransientObjectLifeSpan() *durationpb.Duration
func (*RocketmqProxy) ProtoMessage ¶
func (*RocketmqProxy) ProtoMessage()
func (*RocketmqProxy) ProtoReflect ¶
func (x *RocketmqProxy) ProtoReflect() protoreflect.Message
func (*RocketmqProxy) Reset ¶
func (x *RocketmqProxy) Reset()
func (*RocketmqProxy) String ¶
func (x *RocketmqProxy) String() string
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) GetMatch ¶
func (x *Route) GetMatch() *RouteMatch
func (*Route) GetRoute ¶
func (x *Route) GetRoute() *RouteAction
func (*Route) ProtoReflect ¶
func (x *Route) ProtoReflect() protoreflect.Message
type RouteAction ¶
type RouteAction struct { // Indicates the upstream cluster to which the request should be routed. Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` // Optional endpoint metadata match criteria used by the subset load balancer. MetadataMatch *v32.Metadata `protobuf:"bytes,2,opt,name=metadata_match,json=metadataMatch,proto3" json:"metadata_match,omitempty"` // 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) GetMetadataMatch ¶
func (x *RouteAction) GetMetadataMatch() *v32.Metadata
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 RouteConfiguration ¶
type RouteConfiguration struct { // The name of the route configuration. 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,omitempty"` // contains filtered or unexported fields }
func (*RouteConfiguration) Descriptor
deprecated
func (*RouteConfiguration) Descriptor() ([]byte, []int)
Deprecated: Use RouteConfiguration.ProtoReflect.Descriptor instead.
func (*RouteConfiguration) GetName ¶
func (x *RouteConfiguration) GetName() string
func (*RouteConfiguration) GetRoutes ¶
func (x *RouteConfiguration) GetRoutes() []*Route
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 { // The name of the topic. Topic *v3.StringMatcher `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,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 []*v31.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() []*v31.HeaderMatcher
func (*RouteMatch) GetTopic ¶
func (x *RouteMatch) GetTopic() *v3.StringMatcher
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
Click to show internal directories.
Click to hide internal directories.