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
- func (m *RocketmqProxy) Validate() error
- func (m *RocketmqProxy) ValidateAll() error
- type RocketmqProxyMultiError
- type RocketmqProxyValidationError
- 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
- func (*Route) Descriptor() ([]byte, []int)deprecated
- func (x *Route) GetMatch() *RouteMatch
- func (x *Route) GetRoute() *RouteAction
- func (*Route) ProtoMessage()
- func (x *Route) ProtoReflect() protoreflect.Message
- func (x *Route) Reset()
- func (x *Route) String() string
- func (m *Route) Validate() error
- func (m *Route) ValidateAll() error
- 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
- func (m *RouteAction) Validate() error
- func (m *RouteAction) ValidateAll() error
- type RouteActionMultiError
- type RouteActionValidationError
- 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
- 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
- func (m *RouteConfiguration) Validate() error
- func (m *RouteConfiguration) ValidateAll() error
- type RouteConfigurationMultiError
- type RouteConfigurationValidationError
- 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
- 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
- func (m *RouteMatch) Validate() error
- func (m *RouteMatch) ValidateAll() error
- type RouteMatchMultiError
- type RouteMatchValidationError
- type RouteMultiError
- type RouteValidationError
Constants ¶
This section is empty.
Variables ¶
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
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
func (*RocketmqProxy) Validate ¶
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, the first error encountered is returned, or nil if there are no violations.
func (*RocketmqProxy) ValidateAll ¶
func (m *RocketmqProxy) ValidateAll() error
ValidateAll checks the field values on RocketmqProxy with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RocketmqProxyMultiError, or nil if none found.
type RocketmqProxyMultiError ¶
type RocketmqProxyMultiError []error
RocketmqProxyMultiError is an error wrapping multiple validation errors returned by RocketmqProxy.ValidateAll() if the designated constraints aren't met.
func (RocketmqProxyMultiError) AllErrors ¶
func (m RocketmqProxyMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RocketmqProxyMultiError) Error ¶
func (m RocketmqProxyMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RocketmqProxyValidationError ¶
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 (RocketmqProxyValidationError) Cause ¶
func (e RocketmqProxyValidationError) Cause() error
Cause function returns cause value.
func (RocketmqProxyValidationError) Error ¶
func (e RocketmqProxyValidationError) Error() string
Error satisfies the builtin error interface
func (RocketmqProxyValidationError) ErrorName ¶
func (e RocketmqProxyValidationError) ErrorName() string
ErrorName returns error name.
func (RocketmqProxyValidationError) Field ¶
func (e RocketmqProxyValidationError) Field() string
Field function returns field value.
func (RocketmqProxyValidationError) Key ¶
func (e RocketmqProxyValidationError) Key() bool
Key function returns key value.
func (RocketmqProxyValidationError) Reason ¶
func (e RocketmqProxyValidationError) Reason() string
Reason function returns reason value.
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) 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) Validate ¶
Validate checks the field values on Route with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Route) ValidateAll ¶
ValidateAll checks the field values on Route with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RouteMultiError, or nil if none found.
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
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, the first error encountered is returned, or nil if there are no violations.
func (*RouteAction) ValidateAll ¶
func (m *RouteAction) ValidateAll() error
ValidateAll checks the field values on RouteAction with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RouteActionMultiError, or nil if none found.
type RouteActionMultiError ¶
type RouteActionMultiError []error
RouteActionMultiError is an error wrapping multiple validation errors returned by RouteAction.ValidateAll() if the designated constraints aren't met.
func (RouteActionMultiError) AllErrors ¶
func (m RouteActionMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RouteActionMultiError) Error ¶
func (m RouteActionMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RouteActionValidationError ¶
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 (RouteActionValidationError) Cause ¶
func (e RouteActionValidationError) Cause() error
Cause function returns cause value.
func (RouteActionValidationError) Error ¶
func (e RouteActionValidationError) Error() string
Error satisfies the builtin error interface
func (RouteActionValidationError) ErrorName ¶
func (e RouteActionValidationError) ErrorName() string
ErrorName returns error name.
func (RouteActionValidationError) Field ¶
func (e RouteActionValidationError) Field() string
Field function returns field value.
func (RouteActionValidationError) Key ¶
func (e RouteActionValidationError) Key() bool
Key function returns key value.
func (RouteActionValidationError) Reason ¶
func (e RouteActionValidationError) Reason() string
Reason function returns reason value.
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
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, the first error encountered is returned, or nil if there are no violations.
func (*RouteConfiguration) ValidateAll ¶
func (m *RouteConfiguration) ValidateAll() error
ValidateAll checks the field values on RouteConfiguration with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RouteConfigurationMultiError, or nil if none found.
type RouteConfigurationMultiError ¶
type RouteConfigurationMultiError []error
RouteConfigurationMultiError is an error wrapping multiple validation errors returned by RouteConfiguration.ValidateAll() if the designated constraints aren't met.
func (RouteConfigurationMultiError) AllErrors ¶
func (m RouteConfigurationMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RouteConfigurationMultiError) Error ¶
func (m RouteConfigurationMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RouteConfigurationValidationError ¶
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 (RouteConfigurationValidationError) Cause ¶
func (e RouteConfigurationValidationError) Cause() error
Cause function returns cause value.
func (RouteConfigurationValidationError) Error ¶
func (e RouteConfigurationValidationError) Error() string
Error satisfies the builtin error interface
func (RouteConfigurationValidationError) ErrorName ¶
func (e RouteConfigurationValidationError) ErrorName() string
ErrorName returns error name.
func (RouteConfigurationValidationError) Field ¶
func (e RouteConfigurationValidationError) Field() string
Field function returns field value.
func (RouteConfigurationValidationError) Key ¶
func (e RouteConfigurationValidationError) Key() bool
Key function returns key value.
func (RouteConfigurationValidationError) Reason ¶
func (e RouteConfigurationValidationError) Reason() string
Reason function returns reason value.
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
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, the first error encountered is returned, or nil if there are no violations.
func (*RouteMatch) ValidateAll ¶
func (m *RouteMatch) ValidateAll() error
ValidateAll checks the field values on RouteMatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RouteMatchMultiError, or nil if none found.
type RouteMatchMultiError ¶
type RouteMatchMultiError []error
RouteMatchMultiError is an error wrapping multiple validation errors returned by RouteMatch.ValidateAll() if the designated constraints aren't met.
func (RouteMatchMultiError) AllErrors ¶
func (m RouteMatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RouteMatchMultiError) Error ¶
func (m RouteMatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RouteMatchValidationError ¶
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 (RouteMatchValidationError) Cause ¶
func (e RouteMatchValidationError) Cause() error
Cause function returns cause value.
func (RouteMatchValidationError) Error ¶
func (e RouteMatchValidationError) Error() string
Error satisfies the builtin error interface
func (RouteMatchValidationError) ErrorName ¶
func (e RouteMatchValidationError) ErrorName() string
ErrorName returns error name.
func (RouteMatchValidationError) Field ¶
func (e RouteMatchValidationError) Field() string
Field function returns field value.
func (RouteMatchValidationError) Key ¶
func (e RouteMatchValidationError) Key() bool
Key function returns key value.
func (RouteMatchValidationError) Reason ¶
func (e RouteMatchValidationError) Reason() string
Reason function returns reason value.
type RouteMultiError ¶
type RouteMultiError []error
RouteMultiError is an error wrapping multiple validation errors returned by Route.ValidateAll() if the designated constraints aren't met.
func (RouteMultiError) AllErrors ¶
func (m RouteMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RouteMultiError) Error ¶
func (m RouteMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RouteValidationError ¶
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 (RouteValidationError) Cause ¶
func (e RouteValidationError) Cause() error
Cause function returns cause value.
func (RouteValidationError) Error ¶
func (e RouteValidationError) Error() string
Error satisfies the builtin error interface
func (RouteValidationError) ErrorName ¶
func (e RouteValidationError) ErrorName() string
ErrorName returns error name.
func (RouteValidationError) Field ¶
func (e RouteValidationError) Field() string
Field function returns field value.
func (RouteValidationError) Key ¶
func (e RouteValidationError) Key() bool
Key function returns key value.
func (RouteValidationError) Reason ¶
func (e RouteValidationError) Reason() string
Reason function returns reason value.