消息队列禁消费插件初始提交

Signed-off-by: lilai <lilai23@foxmail.com>
sermant-io · Dec 6, 2023 · 599ceef · 599ceef
1 parent 198029d
commit 599ceef
Show file tree

Hide file tree

Showing 30 changed files with 510 additions and 773 deletions.
diff --git a/.github/actions/common/plugin-change-check/action.yml b/.github/actions/common/plugin-change-check/action.yml
@@ -76,13 +76,14 @@ runs:
       run: |
         echo "sermantSpringbootRegistryChanged=${{ steps.changed-sermant-springboot-registry.outputs.changed }}" >> $GITHUB_ENV
     - uses: marceloprado/has-changed-path@v1.0.1
-      id: changed-sermant-mq-consumer-deny
+      id: changed-sermant-mq-consume-prohibition
       with:
-        paths: sermant-plugins/sermant-mq-consumer-deny
-    - name: env sermant-sermant-mq-consumer-deny
+        paths: sermant-plugins/sermant-mq-consume-prohibition
+    - name: env sermant-sermant-mq-consume-prohibition
       shell: bash
       run: |
-        echo "sermantMqConsumerDenyChanged=${{ steps.changed-sermant-mq-consumer-deny.outputs.changed }}" >> $GITHUB_ENV
+        echo "sermantMqConsumeProhibitionChanged=${{ steps.changed-sermant-mq-consume-prohibition.outputs.changed
+        }}" >> $GITHUB_ENV
     - uses: marceloprado/has-changed-path@v1.0.1
       id: changed-sermant-removal
       with:
@@ -172,7 +173,7 @@ runs:
             ${{ env.sermantSpringbootRegistryChanged }} == 'true' -o ${{ env.sermantServiceRegistryChanged }} == 'true' ];then
           echo "enableSpringLane=true" >> $GITHUB_ENV
         fi
-        
+
         # ==========removal is needed to test?==========
         if [ ${{ env.sermantAgentCoreChanged }} == 'true' -o ${{ env.sermantServiceRemovalChanged }} == 'true' -o \
             ${{ env.sermantSpringbootRegistryChanged }} == 'true' -o ${{ env.sermantServiceRegistryChanged }} == 'true' ];then

diff --git a/sermant-agentcore/sermant-agentcore-config/config/plugins.yaml b/sermant-agentcore/sermant-agentcore-config/config/plugins.yaml
@@ -13,7 +13,7 @@ plugins:
   - dynamic-config
   - monitor
   - springboot-registry
-  - mq-consume-deny
+  - mq-consume-prohibition
   - service-removal
   - service-visibility
   - tag-transmission

diff --git a/sermant-agentcore/sermant-agentcore-config/config/test/plugins.yaml b/sermant-agentcore/sermant-agentcore-config/config/test/plugins.yaml
@@ -13,7 +13,7 @@ plugins:
   - dynamic-config
   - monitor
   - springboot-registry
-  - mq-consume-deny
+  - mq-consume-prohibition
   - service-removal
   - service-visibility
   - tag-transmission

diff --git a/sermant-plugins/pom.xml b/sermant-plugins/pom.xml
@@ -36,7 +36,7 @@
                 <module>sermant-router</module>
                 <module>sermant-loadbalancer</module>
                 <module>sermant-springboot-registry</module>
-                <module>sermant-mq-consume-deny</module>
+                <module>sermant-mq-consume-prohibition</module>
                 <module>sermant-monitor</module>
                 <module>sermant-service-visibility</module>
                 <module>sermant-service-removal</module>
@@ -69,7 +69,7 @@
                 <module>sermant-dynamic-config</module>
                 <module>sermant-monitor</module>
                 <module>sermant-springboot-registry</module>
-                <module>sermant-mq-consume-deny</module>
+                <module>sermant-mq-consume-prohibition</module>
                 <module>sermant-service-visibility</module>
                 <module>sermant-service-removal</module>
                 <module>sermant-spring-beans-deal</module>
@@ -101,7 +101,7 @@
                 <module>sermant-loadbalancer</module>
                 <module>sermant-monitor</module>
                 <module>sermant-springboot-registry</module>
-                <module>sermant-mq-consume-deny</module>
+                <module>sermant-mq-consume-prohibition</module>
                 <module>sermant-service-visibility</module>
                 <module>sermant-service-removal</module>
                 <module>sermant-spring-beans-deal</module>

diff --git a/sermant-plugins/sermant-mq-consume-deny/config/config.yaml b/sermant-plugins/sermant-mq-consume-deny/config/config.yaml
diff --git a/...c/main/java/com/huaweicloud/sermant/kafka/interceptor/KafkaConsumerMethodInterceptor.java b/...c/main/java/com/huaweicloud/sermant/kafka/interceptor/KafkaConsumerMethodInterceptor.java
diff --git a/...lugin/src/main/java/com/huaweicloud/sermant/kafka/matcher/KafkaConsumerMethodMatcher.java b/...lugin/src/main/java/com/huaweicloud/sermant/kafka/matcher/KafkaConsumerMethodMatcher.java