Versions in this module Expand all Collapse all v0 v0.10.5 Jan 12, 2023 Changes in this version + var File_contrib_envoy_extensions_filters_network_rocketmq_proxy_v3_rocketmq_proxy_proto protoreflect.FileDescriptor + var File_contrib_envoy_extensions_filters_network_rocketmq_proxy_v3_route_proto protoreflect.FileDescriptor + type RocketmqProxy struct + DevelopMode bool + RouteConfig *RouteConfiguration + StatPrefix string + TransientObjectLifeSpan *duration.Duration + func (*RocketmqProxy) Descriptor() ([]byte, []int) + func (*RocketmqProxy) ProtoMessage() + func (m *RocketmqProxy) Validate() error + func (m *RocketmqProxy) ValidateAll() error + func (x *RocketmqProxy) GetDevelopMode() bool + func (x *RocketmqProxy) GetRouteConfig() *RouteConfiguration + func (x *RocketmqProxy) GetStatPrefix() string + func (x *RocketmqProxy) GetTransientObjectLifeSpan() *duration.Duration + func (x *RocketmqProxy) ProtoReflect() protoreflect.Message + func (x *RocketmqProxy) Reset() + func (x *RocketmqProxy) String() string + type RocketmqProxyMultiError []error + func (m RocketmqProxyMultiError) AllErrors() []error + func (m RocketmqProxyMultiError) Error() string + type RocketmqProxyValidationError struct + func (e RocketmqProxyValidationError) Cause() error + func (e RocketmqProxyValidationError) Error() string + func (e RocketmqProxyValidationError) ErrorName() string + func (e RocketmqProxyValidationError) Field() string + func (e RocketmqProxyValidationError) Key() bool + func (e RocketmqProxyValidationError) Reason() string + type Route struct + Match *RouteMatch + Route *RouteAction + func (*Route) Descriptor() ([]byte, []int) + func (*Route) ProtoMessage() + func (m *Route) Validate() error + func (m *Route) ValidateAll() error + func (x *Route) GetMatch() *RouteMatch + func (x *Route) GetRoute() *RouteAction + func (x *Route) ProtoReflect() protoreflect.Message + func (x *Route) Reset() + func (x *Route) String() string + type RouteAction struct + Cluster string + MetadataMatch *v32.Metadata + func (*RouteAction) Descriptor() ([]byte, []int) + func (*RouteAction) ProtoMessage() + func (m *RouteAction) Validate() error + func (m *RouteAction) ValidateAll() error + func (x *RouteAction) GetCluster() string + func (x *RouteAction) GetMetadataMatch() *v32.Metadata + func (x *RouteAction) ProtoReflect() protoreflect.Message + func (x *RouteAction) Reset() + func (x *RouteAction) String() string + type RouteActionMultiError []error + func (m RouteActionMultiError) AllErrors() []error + func (m RouteActionMultiError) Error() string + type RouteActionValidationError struct + func (e RouteActionValidationError) Cause() error + func (e RouteActionValidationError) Error() string + func (e RouteActionValidationError) ErrorName() string + func (e RouteActionValidationError) Field() string + func (e RouteActionValidationError) Key() bool + func (e RouteActionValidationError) Reason() string + type RouteConfiguration struct + Name string + Routes []*Route + func (*RouteConfiguration) Descriptor() ([]byte, []int) + func (*RouteConfiguration) ProtoMessage() + func (m *RouteConfiguration) Validate() error + func (m *RouteConfiguration) ValidateAll() error + func (x *RouteConfiguration) GetName() string + func (x *RouteConfiguration) GetRoutes() []*Route + func (x *RouteConfiguration) ProtoReflect() protoreflect.Message + func (x *RouteConfiguration) Reset() + func (x *RouteConfiguration) String() string + type RouteConfigurationMultiError []error + func (m RouteConfigurationMultiError) AllErrors() []error + func (m RouteConfigurationMultiError) Error() string + type RouteConfigurationValidationError struct + func (e RouteConfigurationValidationError) Cause() error + func (e RouteConfigurationValidationError) Error() string + func (e RouteConfigurationValidationError) ErrorName() string + func (e RouteConfigurationValidationError) Field() string + func (e RouteConfigurationValidationError) Key() bool + func (e RouteConfigurationValidationError) Reason() string + type RouteMatch struct + Headers []*v31.HeaderMatcher + Topic *v3.StringMatcher + func (*RouteMatch) Descriptor() ([]byte, []int) + func (*RouteMatch) ProtoMessage() + func (m *RouteMatch) Validate() error + func (m *RouteMatch) ValidateAll() error + func (x *RouteMatch) GetHeaders() []*v31.HeaderMatcher + func (x *RouteMatch) GetTopic() *v3.StringMatcher + func (x *RouteMatch) ProtoReflect() protoreflect.Message + func (x *RouteMatch) Reset() + func (x *RouteMatch) String() string + type RouteMatchMultiError []error + func (m RouteMatchMultiError) AllErrors() []error + func (m RouteMatchMultiError) Error() string + type RouteMatchValidationError struct + func (e RouteMatchValidationError) Cause() error + func (e RouteMatchValidationError) Error() string + func (e RouteMatchValidationError) ErrorName() string + func (e RouteMatchValidationError) Field() string + func (e RouteMatchValidationError) Key() bool + func (e RouteMatchValidationError) Reason() string + type RouteMultiError []error + func (m RouteMultiError) AllErrors() []error + func (m RouteMultiError) Error() string + type RouteValidationError struct + func (e RouteValidationError) Cause() error + func (e RouteValidationError) Error() string + func (e RouteValidationError) ErrorName() string + func (e RouteValidationError) Field() string + func (e RouteValidationError) Key() bool + func (e RouteValidationError) Reason() string