feat:support nacos-address server endpoints

cache/service/router_rule.go

@@ -117,7 +117,7 @@ func (rc *routingConfigCache) Name() string {
 }
 
 func (rc *routingConfigCache) ListRouterRule(service, namespace string) []*model.ExtendRouterConfig {
-	routerRules := rc.bucket.listEnableRules(service, namespace)
+	routerRules := rc.bucket.listEnableRules(service, namespace, true)
 	ret := make([]*model.ExtendRouterConfig, 0, len(routerRules))
 	for level := range routerRules {
 		items := routerRules[level]
@@ -132,7 +132,7 @@ func (rc *routingConfigCache) GetRouterConfigV2(id, service, namespace string) (
 		return nil, nil
 	}
 
-	routerRules := rc.bucket.listEnableRules(service, namespace)
+	routerRules := rc.bucket.listEnableRules(service, namespace, true)
 	revisions := make([]string, 0, 8)
 	rulesV2 := make([]*apitraffic.RouteRule, 0, len(routerRules))
 	for level := range routerRules {
@@ -167,7 +167,7 @@ func (rc *routingConfigCache) GetRouterConfig(id, service, namespace string) (*a
 		return nil, nil
 	}
 
-	routerRules := rc.bucket.listEnableRules(service, namespace)
+	routerRules := rc.bucket.listEnableRules(service, namespace, false)
 	inBounds, outBounds, revisions := rc.convertV2toV1(routerRules, service, namespace)
 	revision, err := types.CompositeComputeRevision(revisions)
 	if err != nil {

cache/service/router_rule_bucket.go

@@ -288,7 +288,7 @@ func (b *routeRuleBucket) size() int {
 
 // listEnableRules Inquire the routing rules of the V2 version through the service name,
 // and perform some filtering according to the Predicate
-func (b *routeRuleBucket) listEnableRules(service, namespace string) map[routingLevel][]*model.ExtendRouterConfig {
+func (b *routeRuleBucket) listEnableRules(service, namespace string, enableFullMatch bool) map[routingLevel][]*model.ExtendRouterConfig {
 	ret := make(map[routingLevel][]*model.ExtendRouterConfig)
 	tmpRecord := map[string]struct{}{}
 
@@ -338,11 +338,13 @@ func (b *routeRuleBucket) listEnableRules(service, namespace string) map[routing
 	level2 = append(level2, handler(b.level2Rules[inBound][namespace], inBound)...)
 	ret[level2RoutingV2] = level2
 
-	// Query Level3 level routing-v2 rules
-	level3 := make([]*model.ExtendRouterConfig, 0, 4)
-	level3 = append(level3, handler(b.level3Rules[outBound], outBound)...)
-	level3 = append(level3, handler(b.level3Rules[inBound], inBound)...)
-	ret[level3RoutingV2] = level3
+	if enableFullMatch {
+		// Query Level3 level routing-v2 rules
+		level3 := make([]*model.ExtendRouterConfig, 0, 4)
+		level3 = append(level3, handler(b.level3Rules[outBound], outBound)...)
+		level3 = append(level3, handler(b.level3Rules[inBound], inBound)...)
+		ret[level3RoutingV2] = level3
+	}
 	return ret
 }
 

common/utils/common.go

@@ -86,6 +86,11 @@ const (
 	MaxDbCircuitbreakerComment    = 1024
 	MaxDbCircuitbreakerOwner      = 1024
 	MaxDbCircuitbreakerVersion    = 32
+
+	MaxPlatformIDLength     = 32
+	MaxPlatformNameLength   = 128
+	MaxPlatformDomainLength = 1024
+	MaxPlatformQPS          = 65535
 )
 
 var resourceNameRE = regexp.MustCompile("^[0-9A-Za-z-./:_]+$")

service/client_v1.go

@@ -50,7 +50,6 @@ func (s *Server) DeregisterInstance(ctx context.Context, req *apiservice.Instanc
 
 // ReportServiceContract report client service interface info
 func (s *Server) ReportServiceContract(ctx context.Context, req *apiservice.ServiceContract) *apiservice.Response {
-	ctx = context.WithValue(ctx, utils.ContextIsFromClient, true)
 	cacheData := s.caches.ServiceContract().Get(ctx, &model.ServiceContract{
 		Namespace: req.GetNamespace(),
 		Service:   req.GetService(),

service/default.go

@@ -169,12 +169,6 @@ func (svr *Server) pluginInitialize() {
 		log.Warnf("Not Found History Log Plugin")
 	}
 
-	// 获取限流插件
-	svr.ratelimit = plugin.GetRatelimit()
-	if svr.ratelimit == nil {
-		log.Warnf("Not found Ratelimit Plugin")
-	}
-
 	subscriber := plugin.GetDiscoverEvent()
 	if subscriber == nil {
 		log.Warnf("Not found DiscoverEvent Plugin")