feat: support opentelemry collector and Define indicators #101
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Fix api param and connection param check
Add private network param check
Bumps [fastjson](https://github.com/alibaba/fastjson) from 1.2.76 to 1.2.83. - [Release notes](https://github.com/alibaba/fastjson/releases) - [Commits](alibaba/fastjson@1.2.76...1.2.83) --- updated-dependencies: - dependency-name: com.alibaba:fastjson dependency-type: direct:production ... Signed-off-by: dependabot[bot] <[email protected]>
Bumps [spring-web](https://github.com/spring-projects/spring-framework) from 5.0.6.RELEASE to 6.0.0. - [Release notes](https://github.com/spring-projects/spring-framework/releases) - [Commits](spring-projects/spring-framework@v5.0.6.RELEASE...v6.0.0) --- updated-dependencies: - dependency-name: org.springframework:spring-web dependency-type: direct:production ... Signed-off-by: dependabot[bot] <[email protected]>
Bumps commons-net from 3.3 to 3.9.0. --- updated-dependencies: - dependency-name: commons-net:commons-net dependency-type: direct:production ... Signed-off-by: dependabot[bot] <[email protected]>
add private network param check
roll back spring content version
add quota service
add private network param check
Update api list connection name
add private network param check
add oauth http check
add publish workflows
# Conflicts: # pom.xml
# Conflicts: # adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java # adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java # adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java
Build runtimer
Update Runtimer Listener Offer Connect Record
feat: add EventSubscriber & Observer.
feat:add watch runner config.
Optimize Event Circulator Context
Optimize fileObserver formate and Support module (apache#76)
…iz (apache#102) * update subscriber and listener * init 2nd edition for Runtimer * rename few class and add propertis config * optimize concurrency biz * optimize jsonFile formate * update reflect * completed config style * completed test * update config,transfer,pusher * updateFewFileNaming * rename Pusher to Trigger, Runtimer to runtime, and optimize few architect * updateRocketMQSubscriberFile
* update subscriber and listener * init 2nd edition for Runtimer * rename few class and add propertis config * optimize concurrency biz * optimize jsonFile formate * update reflect * completed config style * completed test * update config,transfer,pusher * updateFewFileNaming * rename Pusher to Trigger, Runtimer to runtime, and optimize few architect * updateRocketMQSubscriberFile * resetDefaultConfig * resetConfig
2.add default validateFilter
2.modify ValidateFilter, add default filter
# Conflicts: # README.md # adapter/runtime/pom.xml # adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java # adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventBusListener.java # adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java # adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java # adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java # adapter/runtime/src/main/resources/runtime.properties # adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java # adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java # adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ClientConfig.java # adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java # adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java # infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java # test/demo/src/test/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationDTOControllerTest.java
|
conflict...close. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Currently rocketmq-eventbridge needs some indicators to complete the process statistics, such as the backlog of different blockingqueues during runtime execution, the tps of consumers, and some delay information in the system. We will divide it into three stages
related to issues-104
Define openTelemry and define related indicators
Test openTelemry and define whether related indicators can be collected correctly
Access the runtime layer and redefine related indicators