import "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/network/rocketmq_proxy/v3"
rocketmq_proxy.pb.go rocketmq_proxy.pb.validate.go route.pb.go route.pb.validate.go
var File_envoy_extensions_filters_network_rocketmq_proxy_v3_rocketmq_proxy_proto protoreflect.FileDescriptor
var File_envoy_extensions_filters_network_rocketmq_proxy_v3_route_proto protoreflect.FileDescriptor
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 *duration.Duration `protobuf:"bytes,3,opt,name=transient_object_life_span,json=transientObjectLifeSpan,proto3" json:"transient_object_life_span,omitempty"`
// 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() ([]byte, []int)
Deprecated: Use RocketmqProxy.ProtoReflect.Descriptor instead.
func (x *RocketmqProxy) GetDevelopMode() bool
func (x *RocketmqProxy) GetRouteConfig() *RouteConfiguration
func (x *RocketmqProxy) GetStatPrefix() string
func (x *RocketmqProxy) GetTransientObjectLifeSpan() *duration.Duration
func (*RocketmqProxy) ProtoMessage()
func (x *RocketmqProxy) ProtoReflect() protoreflect.Message
func (x *RocketmqProxy) Reset()
func (x *RocketmqProxy) String() string
func (m *RocketmqProxy) Validate() error
Validate checks the field values on RocketmqProxy with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type RocketmqProxyValidationError struct {
// contains filtered or unexported fields
}RocketmqProxyValidationError is the validation error returned by RocketmqProxy.Validate if the designated constraints aren't met.
func (e RocketmqProxyValidationError) Cause() error
Cause function returns cause value.
func (e RocketmqProxyValidationError) Error() string
Error satisfies the builtin error interface
func (e RocketmqProxyValidationError) ErrorName() string
ErrorName returns error name.
func (e RocketmqProxyValidationError) Field() string
Field function returns field value.
func (e RocketmqProxyValidationError) Key() bool
Key function returns key value.
func (e RocketmqProxyValidationError) Reason() string
Reason function returns reason value.
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
}Deprecated: Use Route.ProtoReflect.Descriptor instead.
func (x *Route) GetMatch() *RouteMatch
func (x *Route) GetRoute() *RouteAction
func (x *Route) ProtoReflect() protoreflect.Message
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.
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() ([]byte, []int)
Deprecated: Use RouteAction.ProtoReflect.Descriptor instead.
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
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.
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 (e RouteActionValidationError) Cause() error
Cause function returns cause value.
func (e RouteActionValidationError) Error() string
Error satisfies the builtin error interface
func (e RouteActionValidationError) ErrorName() string
ErrorName returns error name.
func (e RouteActionValidationError) Field() string
Field function returns field value.
func (e RouteActionValidationError) Key() bool
Key function returns key value.
func (e RouteActionValidationError) Reason() string
Reason function returns reason value.
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() ([]byte, []int)
Deprecated: Use RouteConfiguration.ProtoReflect.Descriptor instead.
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
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.
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 (e RouteConfigurationValidationError) Cause() error
Cause function returns cause value.
func (e RouteConfigurationValidationError) Error() string
Error satisfies the builtin error interface
func (e RouteConfigurationValidationError) ErrorName() string
ErrorName returns error name.
func (e RouteConfigurationValidationError) Field() string
Field function returns field value.
func (e RouteConfigurationValidationError) Key() bool
Key function returns key value.
func (e RouteConfigurationValidationError) Reason() string
Reason function returns reason value.
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() ([]byte, []int)
Deprecated: Use RouteMatch.ProtoReflect.Descriptor instead.
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
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.
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 (e RouteMatchValidationError) Cause() error
Cause function returns cause value.
func (e RouteMatchValidationError) Error() string
Error satisfies the builtin error interface
func (e RouteMatchValidationError) ErrorName() string
ErrorName returns error name.
func (e RouteMatchValidationError) Field() string
Field function returns field value.
func (e RouteMatchValidationError) Key() bool
Key function returns key value.
func (e RouteMatchValidationError) Reason() string
Reason function returns reason value.
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 (e RouteValidationError) Cause() error
Cause function returns cause value.
func (e RouteValidationError) Error() string
Error satisfies the builtin error interface
func (e RouteValidationError) ErrorName() string
ErrorName returns error name.
func (e RouteValidationError) Field() string
Field function returns field value.
func (e RouteValidationError) Key() bool
Key function returns key value.
func (e RouteValidationError) Reason() string
Reason function returns reason value.
Package envoy_extensions_filters_network_rocketmq_proxy_v3 imports 23 packages (graph) and is imported by 6 packages. Updated 2021-01-08. Refresh now. Tools for package owners.