go-control-plane: github.com/envoyproxy/go-control-plane/envoy/extensions/filters/network/rocketmq_proxy/v4alpha Index | Files

package envoy_extensions_filters_network_rocketmq_proxy_v4alpha

import "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/network/rocketmq_proxy/v4alpha"

Index

Package Files

rocketmq_proxy.pb.go rocketmq_proxy.pb.validate.go route.pb.go route.pb.validate.go

Variables

var File_envoy_extensions_filters_network_rocketmq_proxy_v4alpha_rocketmq_proxy_proto protoreflect.FileDescriptor
var File_envoy_extensions_filters_network_rocketmq_proxy_v4alpha_route_proto protoreflect.FileDescriptor

type RocketmqProxy Uses

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 Uses

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

Deprecated: Use RocketmqProxy.ProtoReflect.Descriptor instead.

func (*RocketmqProxy) GetDevelopMode Uses

func (x *RocketmqProxy) GetDevelopMode() bool

func (*RocketmqProxy) GetRouteConfig Uses

func (x *RocketmqProxy) GetRouteConfig() *RouteConfiguration

func (*RocketmqProxy) GetStatPrefix Uses

func (x *RocketmqProxy) GetStatPrefix() string

func (*RocketmqProxy) GetTransientObjectLifeSpan Uses

func (x *RocketmqProxy) GetTransientObjectLifeSpan() *duration.Duration

func (*RocketmqProxy) ProtoMessage Uses

func (*RocketmqProxy) ProtoMessage()

func (*RocketmqProxy) ProtoReflect Uses

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

func (*RocketmqProxy) Reset Uses

func (x *RocketmqProxy) Reset()

func (*RocketmqProxy) String Uses

func (x *RocketmqProxy) String() string

func (*RocketmqProxy) Validate Uses

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 Uses

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 Uses

func (e RocketmqProxyValidationError) Cause() error

Cause function returns cause value.

func (RocketmqProxyValidationError) Error Uses

func (e RocketmqProxyValidationError) Error() string

Error satisfies the builtin error interface

func (RocketmqProxyValidationError) ErrorName Uses

func (e RocketmqProxyValidationError) ErrorName() string

ErrorName returns error name.

func (RocketmqProxyValidationError) Field Uses

func (e RocketmqProxyValidationError) Field() string

Field function returns field value.

func (RocketmqProxyValidationError) Key Uses

func (e RocketmqProxyValidationError) Key() bool

Key function returns key value.

func (RocketmqProxyValidationError) Reason Uses

func (e RocketmqProxyValidationError) Reason() string

Reason function returns reason value.

type Route Uses

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 Uses

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetMatch Uses

func (x *Route) GetMatch() *RouteMatch

func (*Route) GetRoute Uses

func (x *Route) GetRoute() *RouteAction

func (*Route) ProtoMessage Uses

func (*Route) ProtoMessage()

func (*Route) ProtoReflect Uses

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

func (*Route) Reset Uses

func (x *Route) Reset()

func (*Route) String Uses

func (x *Route) String() string

func (*Route) Validate Uses

func (m *Route) Validate() error

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 Uses

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 *v4alpha2.Metadata `protobuf:"bytes,2,opt,name=metadata_match,json=metadataMatch,proto3" json:"metadata_match,omitempty"`
    // contains filtered or unexported fields
}

func (*RouteAction) Descriptor Uses

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

Deprecated: Use RouteAction.ProtoReflect.Descriptor instead.

func (*RouteAction) GetCluster Uses

func (x *RouteAction) GetCluster() string

func (*RouteAction) GetMetadataMatch Uses

func (x *RouteAction) GetMetadataMatch() *v4alpha2.Metadata

func (*RouteAction) ProtoMessage Uses

func (*RouteAction) ProtoMessage()

func (*RouteAction) ProtoReflect Uses

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

func (*RouteAction) Reset Uses

func (x *RouteAction) Reset()

func (*RouteAction) String Uses

func (x *RouteAction) String() string

func (*RouteAction) Validate Uses

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 Uses

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 Uses

func (e RouteActionValidationError) Cause() error

Cause function returns cause value.

func (RouteActionValidationError) Error Uses

func (e RouteActionValidationError) Error() string

Error satisfies the builtin error interface

func (RouteActionValidationError) ErrorName Uses

func (e RouteActionValidationError) ErrorName() string

ErrorName returns error name.

func (RouteActionValidationError) Field Uses

func (e RouteActionValidationError) Field() string

Field function returns field value.

func (RouteActionValidationError) Key Uses

func (e RouteActionValidationError) Key() bool

Key function returns key value.

func (RouteActionValidationError) Reason Uses

func (e RouteActionValidationError) Reason() string

Reason function returns reason value.

type RouteConfiguration Uses

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 Uses

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

Deprecated: Use RouteConfiguration.ProtoReflect.Descriptor instead.

func (*RouteConfiguration) GetName Uses

func (x *RouteConfiguration) GetName() string

func (*RouteConfiguration) GetRoutes Uses

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

func (*RouteConfiguration) ProtoMessage Uses

func (*RouteConfiguration) ProtoMessage()

func (*RouteConfiguration) ProtoReflect Uses

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

func (*RouteConfiguration) Reset Uses

func (x *RouteConfiguration) Reset()

func (*RouteConfiguration) String Uses

func (x *RouteConfiguration) String() string

func (*RouteConfiguration) Validate Uses

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 Uses

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 Uses

func (e RouteConfigurationValidationError) Cause() error

Cause function returns cause value.

func (RouteConfigurationValidationError) Error Uses

func (e RouteConfigurationValidationError) Error() string

Error satisfies the builtin error interface

func (RouteConfigurationValidationError) ErrorName Uses

func (e RouteConfigurationValidationError) ErrorName() string

ErrorName returns error name.

func (RouteConfigurationValidationError) Field Uses

func (e RouteConfigurationValidationError) Field() string

Field function returns field value.

func (RouteConfigurationValidationError) Key Uses

func (e RouteConfigurationValidationError) Key() bool

Key function returns key value.

func (RouteConfigurationValidationError) Reason Uses

func (e RouteConfigurationValidationError) Reason() string

Reason function returns reason value.

type RouteMatch Uses

type RouteMatch struct {

    // The name of the topic.
    Topic *v4alpha.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 []*v4alpha1.HeaderMatcher `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
    // contains filtered or unexported fields
}

func (*RouteMatch) Descriptor Uses

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

Deprecated: Use RouteMatch.ProtoReflect.Descriptor instead.

func (*RouteMatch) GetHeaders Uses

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

func (*RouteMatch) GetTopic Uses

func (x *RouteMatch) GetTopic() *v4alpha.StringMatcher

func (*RouteMatch) ProtoMessage Uses

func (*RouteMatch) ProtoMessage()

func (*RouteMatch) ProtoReflect Uses

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

func (*RouteMatch) Reset Uses

func (x *RouteMatch) Reset()

func (*RouteMatch) String Uses

func (x *RouteMatch) String() string

func (*RouteMatch) Validate Uses

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 Uses

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 Uses

func (e RouteMatchValidationError) Cause() error

Cause function returns cause value.

func (RouteMatchValidationError) Error Uses

func (e RouteMatchValidationError) Error() string

Error satisfies the builtin error interface

func (RouteMatchValidationError) ErrorName Uses

func (e RouteMatchValidationError) ErrorName() string

ErrorName returns error name.

func (RouteMatchValidationError) Field Uses

func (e RouteMatchValidationError) Field() string

Field function returns field value.

func (RouteMatchValidationError) Key Uses

func (e RouteMatchValidationError) Key() bool

Key function returns key value.

func (RouteMatchValidationError) Reason Uses

func (e RouteMatchValidationError) Reason() string

Reason function returns reason value.

type RouteValidationError Uses

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 Uses

func (e RouteValidationError) Cause() error

Cause function returns cause value.

func (RouteValidationError) Error Uses

func (e RouteValidationError) Error() string

Error satisfies the builtin error interface

func (RouteValidationError) ErrorName Uses

func (e RouteValidationError) ErrorName() string

ErrorName returns error name.

func (RouteValidationError) Field Uses

func (e RouteValidationError) Field() string

Field function returns field value.

func (RouteValidationError) Key Uses

func (e RouteValidationError) Key() bool

Key function returns key value.

func (RouteValidationError) Reason Uses

func (e RouteValidationError) Reason() string

Reason function returns reason value.

Package envoy_extensions_filters_network_rocketmq_proxy_v4alpha imports 23 packages (graph) and is imported by 6 packages. Updated 2021-01-08. Refresh now. Tools for package owners.