fix(adasvc): do not use adaptive service filter if disabled on the cl…

…ient side (#1748)

cluster/cluster/adaptivesvc/cluster_invoker.go

@@ -66,6 +66,7 @@ func (ivk *adaptiveServiceClusterInvoker) Invoke(ctx context.Context, invocation
 	invoker := lb.Select(invokers, invocation)
 
 	// invoke
+	invocation.SetAttachment(constant.AdaptiveServiceEnabledKey, constant.AdaptiveServiceIsEnabled)
 	result := invoker.Invoke(ctx, invocation)
 
 	// if the adaptive service encounters an error, DO NOT

common/constant/key.go

@@ -380,4 +380,7 @@ const (
 	// attachment keys
 	AdaptiveServiceRemainingKey = "adaptive-service.remaining"
 	AdaptiveServiceInflightKey  = "adaptive-service.inflight"
+	AdaptiveServiceEnabledKey   = "adaptive-service.enabled"
+	// enabled value
+	AdaptiveServiceIsEnabled = "1"
 )

filter/adaptivesvc/filter.go

@@ -64,6 +64,11 @@ func newAdaptiveServiceProviderFilter() filter.Filter {
 
 func (f *adaptiveServiceProviderFilter) Invoke(ctx context.Context, invoker protocol.Invoker,
 	invocation protocol.Invocation) protocol.Result {
+	if invocation.GetAttachmentWithDefaultValue(constant.AdaptiveServiceEnabledKey, "") !=
+		constant.AdaptiveServiceIsEnabled {
+		// the adaptive service is enabled on the invocation
+		return invoker.Invoke(ctx, invocation)
+	}
 
 	l, err := limiterMapperSingleton.getMethodLimiter(invoker.GetURL(), invocation.MethodName())
 	if err != nil {
@@ -91,6 +96,10 @@ func (f *adaptiveServiceProviderFilter) Invoke(ctx context.Context, invoker prot
 
 func (f *adaptiveServiceProviderFilter) OnResponse(_ context.Context, result protocol.Result, invoker protocol.Invoker,
 	invocation protocol.Invocation) protocol.Result {
+	if result.Attachment(constant.AdaptiveServiceEnabledKey, "") != constant.AdaptiveServiceIsEnabled {
+		// the adaptive service is enabled on the invocation
+		return result
+	}
 
 	if isErrAdaptiveSvcInterrupted(result.Error()) {
 		// If the Invoke method of the adaptiveServiceProviderFilter returns an error,