Versions in this module Expand all Collapse all v3 v3.1.2 Feb 5, 2024 Changes in this version + var RandInt63n = grpcrand.Int63n + func IsClusterResource(url string) bool + func IsEndpointsResource(url string) bool + func IsHTTPConnManagerResource(url string) bool + func IsListenerResource(url string) bool + func IsRouteConfigResource(url string) bool + func NewErrorf(t ErrorType, format string, args ...interface{}) error + func SetLocalityID(addr resolver.Address, l LocalityID) resolver.Address + type ClusterLBPolicyRingHash struct + MaximumRingSize uint64 + MinimumRingSize uint64 + type ClusterType int + const ClusterTypeAggregate + const ClusterTypeEDS + const ClusterTypeLogicalDNS + type ClusterUpdate struct + ClusterName string + ClusterType ClusterType + DNSHostName string + EDSServiceName string + EnableLRS bool + LBPolicy *ClusterLBPolicyRingHash + MaxRequests *uint32 + PrioritizedClusterNames []string + Raw *anypb.Any + SecurityCfg *SecurityConfig + type ClusterUpdateErrTuple struct + Err error + Update ClusterUpdate + type CompositeMatcher struct + func RouteToMatcher(r *Route) (*CompositeMatcher, error) + func (a *CompositeMatcher) Match(info iresolver.RPCInfo) bool + func (a *CompositeMatcher) String() string + type Endpoint struct + Address string + HealthStatus EndpointHealthStatus + Weight uint32 + type EndpointHealthStatus int32 + const EndpointHealthStatusDegraded + const EndpointHealthStatusDraining + const EndpointHealthStatusHealthy + const EndpointHealthStatusTimeout + const EndpointHealthStatusUnhealthy + const EndpointHealthStatusUnknown + type EndpointsUpdate struct + Drops []OverloadDropConfig + Localities []Locality + Raw *anypb.Any + type EndpointsUpdateErrTuple struct + Err error + Update EndpointsUpdate + type ErrorType int + const ErrorTypeConnection + const ErrorTypeResourceNotFound + const ErrorTypeUnknown + func ErrType(e error) ErrorType + type FilterChain struct + HTTPFilters []HTTPFilter + InlineRouteConfig *RouteConfigUpdate + RouteConfigName string + SecurityCfg *SecurityConfig + func (f *FilterChain) ConstructUsableRouteConfiguration(config RouteConfigUpdate) ([]VirtualHostWithInterceptors, error) + type FilterChainLookupParams struct + DestAddr net.IP + IsUnspecifiedListener bool + SourceAddr net.IP + SourcePort int + type FilterChainManager struct + RouteConfigNames map[string]bool + func NewFilterChainManager(lis *v3listenerpb.Listener, logger dubboLogger.Logger) (*FilterChainManager, error) + func (fci *FilterChainManager) Lookup(params FilterChainLookupParams) (*FilterChain, error) + func (fci *FilterChainManager) Validate(f func(fc *FilterChain) error) error + type HTTPFilter struct + Config httpfilter.FilterConfig + Filter httpfilter.Filter + Name string + type HashPolicy struct + HashPolicyType HashPolicyType + HeaderName string + Regex *regexp.Regexp + RegexSubstitution string + Terminal bool + type HashPolicyType int + const HashPolicyTypeChannelID + const HashPolicyTypeHeader + type HeaderMatcher struct + ExactMatch *string + InvertMatch *bool + Name string + PrefixMatch *string + PresentMatch *bool + RangeMatch *Int64Range + RegexMatch *regexp.Regexp + SuffixMatch *string + type InboundListenerConfig struct + Address string + FilterChains *FilterChainManager + Port string + type Int64Range struct + End int64 + Start int64 + type ListenerUpdate struct + HTTPFilters []HTTPFilter + InboundListenerCfg *InboundListenerConfig + InlineRouteConfig *RouteConfigUpdate + MaxStreamDuration time.Duration + Raw *anypb.Any + RouteConfigName string + type ListenerUpdateErrTuple struct + Err error + Update ListenerUpdate + type Locality struct + Endpoints []Endpoint + ID LocalityID + Priority uint32 + Weight uint32 + type LocalityID struct + Region string + SubZone string + Zone string + func GetLocalityID(addr resolver.Address) LocalityID + func LocalityIDFromString(s string) (ret LocalityID, _ error) + func (l LocalityID) Equal(o interface{}) bool + func (l LocalityID) ToString() (string, error) + type Name struct + Authority string + ContextParams map[string]string + ID string + Scheme string + Type string + func ParseName(name string) *Name + func (n *Name) String() string + type OverloadDropConfig struct + Category string + Denominator uint32 + Numerator uint32 + type ResourceType int + const ClusterResource + const EndpointsResource + const HTTPConnManagerResource + const ListenerResource + const RouteConfigResource + const UnknownResource + func (r ResourceType) String() string + type RetryBackoff struct + BaseInterval time.Duration + MaxInterval time.Duration + type RetryConfig struct + NumRetries uint32 + RetryBackoff RetryBackoff + RetryOn map[codes.Code]bool + type Route struct + ActionType RouteActionType + CaseInsensitive bool + ClusterSpecifierPlugin string + Fraction *uint32 + HTTPFilterConfigOverride map[string]httpfilter.FilterConfig + HashPolicies []*HashPolicy + Headers []*HeaderMatcher + MaxStreamDuration *time.Duration + Path *string + Prefix *string + Regex *regexp.Regexp + RetryConfig *RetryConfig + WeightedClusters map[string]WeightedCluster + type RouteActionType int + const RouteActionNonForwardingAction + const RouteActionRoute + const RouteActionUnsupported + type RouteConfigUpdate struct + ClusterSpecifierPlugins map[string]clusterspecifier.BalancerConfig + Raw *anypb.Any + VirtualHosts []*VirtualHost + type RouteConfigUpdateErrTuple struct + Err error + Update RouteConfigUpdate + type RouteWithInterceptors struct + ActionType RouteActionType + Interceptors []resolver.ServerInterceptor + M *CompositeMatcher + type SecurityConfig struct + IdentityCertName string + IdentityInstanceName string + RequireClientCert bool + RootCertName string + RootInstanceName string + SubjectAltNameMatchers []matcher.StringMatcher + func (sc *SecurityConfig) Equal(other *SecurityConfig) bool + type ServiceStatus int + const ServiceStatusACKed + const ServiceStatusNACKed + const ServiceStatusNotExist + const ServiceStatusRequested + const ServiceStatusUnknown + type SourceType int + const SourceTypeAny + const SourceTypeExternal + const SourceTypeSameOrLoopback + type UnmarshalOptions struct + Logger dubboLogger.Logger + Resources []*anypb.Any + UpdateValidator UpdateValidatorFunc + Version string + type UpdateErrorMetadata struct + Err error + Timestamp time.Time + Version string + type UpdateMetadata struct + ErrState *UpdateErrorMetadata + Status ServiceStatus + Timestamp time.Time + Version string + func UnmarshalCluster(opts *UnmarshalOptions) (map[string]ClusterUpdateErrTuple, UpdateMetadata, error) + func UnmarshalEndpoints(opts *UnmarshalOptions) (map[string]EndpointsUpdateErrTuple, UpdateMetadata, error) + func UnmarshalListener(opts *UnmarshalOptions) (map[string]ListenerUpdateErrTuple, UpdateMetadata, error) + func UnmarshalRouteConfig(opts *UnmarshalOptions) (map[string]RouteConfigUpdateErrTuple, UpdateMetadata, error) + type UpdateValidatorFunc func(interface{}) error + type UpdateWithMD struct + MD UpdateMetadata + Raw *anypb.Any + type VirtualHost struct + Domains []string + HTTPFilterConfigOverride map[string]httpfilter.FilterConfig + RetryConfig *RetryConfig + Routes []*Route + func FindBestMatchingVirtualHost(host string, vHosts []*VirtualHost) *VirtualHost + type VirtualHostWithInterceptors struct + Domains []string + Routes []RouteWithInterceptors + func FindBestMatchingVirtualHostServer(authority string, vHosts []VirtualHostWithInterceptors) *VirtualHostWithInterceptors + type WeightedCluster struct + HTTPFilterConfigOverride map[string]httpfilter.FilterConfig + Weight uint32
Go to main page