This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch config-manage-improve
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from b161bff14 Merge pull request #2256 from apache/qqeasonchen-patch-6
new dcb2837b4 remote interface public
new 8ca74a166 Merge pull request #2258 from weihubeats/remove_public
new bb98afe89 update maturity docs
new b318fbcf9 Merge pull request #2261 from wqliang/updateMaturityDocs
new dd2a9e9aa [ISSUE #2255] simplify the code (#2259)
new 60b5d1cb0 [ISSUE #2245] Change to collection "StringBuilder"
new 8a94f2783 Fixed 01-store.md grammar. (#2266)
new 78ed6c682 [ISSUE #2244] Update constants (#2263)
new c6fb147ed [ISSUE #2264] remove final (#2265)
new b116d9342 [ISSUE #2250]Reliance on default encoding
[RedirectClientByPathHandlerTest]
new 164736ec3 Merge pull request #2273 from CalebZYC/issue-2250
new e06d4697b Simplify the code
new f300c208f Simplify the code
new 8b525e563 Merge pull request #2268 from weihubeats/simplify_code
new af809e1b6 update EventMeshException
new 15a357ea4 Merge pull request #2270 from weihubeats/common
new 4bb3d4d9d [ISSUE #2252]Reliance on default encoding
[WebHookProcessorTest] (#2271)
new eae65add2 [ISSUE #2251]Reliance on default encoding [IOTinyUtilsTest]
(#2272)
new b2dc5e1ab update log format in SyncRequestInstance.class (#2274)
new 3c5ea5ece add e (#2275)
new 98f6c8749 [ISSUE #2240] (Optimize) change Boolean.True to true. (#2279)
new 2643c1321 Create 05-metrics-export.md
new 2ddd0604a Merge pull request #2286 from miqdigital/translate-doc
new 183e36192 upgrade gradle to 7.6
new 7c4b70b87 upgrade gradle to 7.6
new 124b5c818 fix build error
new 71b07e8bd Merge pull request #2283 from jonyangx/upgrade_gradle
new 609ee18bc [ISSUE #2249] 'assertTrue()' can be simplified to
'assertEquals()' (#2276)
new 7599168e0 [ISSUE #2239] fix BufferedReader doesn't auto-close bug and
use UTF-8. (#2289)
new 980d08680 [ISSUE #2254] Method concatenates the result of a toString()
call [CCSubClient] (#2278)
new 3fc7ac04c add e
new 7468c3efa Merge remote-tracking branch 'upstream/master'
new f52ca38d2 update random to ThreadLocalRandom
new b967065b9 Merge pull request #2301 from weihubeats/random
new 34b732b4b [ISSUE #2253] Optimize the error log. [AsyncPubClient]
(#2302)
new de045ccda Simplify the code
new 6f2c7e49b add Licensed
new 311551b32 rename Assert to AssertUtils
new 5e4f011d1 Merge pull request #2285 from weihubeats/common
new 74457c7aa Refactoring code
new 27c2d0a23 Merge pull request #2288 from weihubeats/refactor_code
new 1cc1af9d4 [ISSUE #2297] Unified eventmesh-common dependency versioning
(#2298)
new c7ce4f14e [ISSUE #2243] Change Boolean to boolean in
NacosWebHookConfigOperation (#2290)
new 7f5915e91 Refactoring tool class NetUtils (#2316)
new a7aaac6b3 add test assert (#2292)
new c1461bbc2 Enhancement
new 3c52544cb Merge pull request #2305 from weihubeats/wh_feature
new b36761a83 Unified Dependency Management
new ad3dcbbfd Merge pull request #2313 from weihubeats/runtime_denpendes
new 8c31f73ff Delete magic variables (#2311)
new c1032874c Unified Versioning
new 3c954d838 Merge pull request #2320 from
weihubeats/eventmesh_connector_api
new 9d4bb8535 [ISSUE #2317] Refactoring tool class JsonUtils (#2318)
new 5b1a0e171 remove deprecated methods (#2328)
new 45dff0e01 fixed ISSUE #2329 in.array() cause another exception.
new ef9abb7fc Merge pull request #2330 from jackyluo-learning/bugfix-branch
new 0f7a8d8e5 Simplify spi usage
new 2734d5102 Merge pull request #2326 from weihubeats/spi
new bc6fe3c0e Simplify CloudEventUtils code (#2323)
new c4ec0690c fixed ISSUE #2331 metrics in TCP will not be reset to zero
new 4e123975a Merge pull request #2332 from
jackyluo-learning/bugfix-branch-shadow-1
new eff1ea751 fix issue 2341
new 4272157a8 Merge pull request #2352 from jonyangx/issue2341
new 513669c6b fix issue2238
new d4f6941b8 Merge pull request #2350 from jonyangx/issue2238
new a066f79e3 [ISSUE #2349] Method encodes String bytes without specifying
the character encoding (#2351)
new 4a48e1204 fix security issues
new fde740f55 Merge pull request #2355 from horoc/fix-security-issues
new 63d92946f fix issue 2346
new 6dbd73306 Merge pull request #2358 from jonyangx/issue2346
new 315b9358f fix issue2347
new 807d35c45 Merge pull request #2356 from jonyangx/issue2347
new 68aaacbff fix issue2348
new bdbdc0d37 Merge pull request #2357 from jonyangx/issue2348
new 8f5a496d7 update log output of AsyncSyncRequestInstance.java
new 8de2ca1b1 Merge pull request #2389 from MajorHe1/MajorHe1-patch-4
new c782a005e init
new facf29f71 Simplify the code
new 0fece9ed1 add listener
new c890850dc update method
new ea2fa9c03 Merge pull request #2354 from weihubeats/controller
new b2e05deda use logger to print exception in SubSerivce.java
new 76433e7e6 Merge pull request #2391 from MajorHe1/MajorHe1-patch-5
new cfe608d52 [ISSUE #2576]Enhancement the config manage for project
new 0c783a757 Merge pull request #2577 from githublaohu/laohu-master
The 2484 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
build.gradle | 4 +
docs/en/instruction/01-store.md | 2 +-
docs/zh/desing-document/05-metrics-export.md | 47 +++
.../admin/rocketmq/handler/TopicsHandler.java | 10 +-
.../eventmesh/admin/rocketmq/util/JsonUtils.java | 81 ----
.../eventmesh/admin/rocketmq/util/NetUtils.java | 48 ---
.../admin/rocketmq/util/RequestMapping.java | 2 +-
eventmesh-common/build.gradle | 11 +-
.../org/apache/eventmesh/common/Constants.java | 4 +
.../org/apache/eventmesh/common/config/Config.java | 32 +-
.../apache/eventmesh/common/config/ConfigInfo.java | 54 ++-
.../common/config/ConfigMonitorService.java | 63 +++
.../eventmesh/common/config/ConfigService.java | 123 ++++++
.../common/config/ConfigurationWrapper.java | 81 +---
.../apache/eventmesh/common/config/FileLoad.java | 88 +++++
.../apache/eventmesh/common/config/NotNull.java | 11 +-
.../apache/eventmesh/common/enums}/HttpMethod.java | 2 +-
.../common/exception/EventMeshException.java | 2 +-
.../loadbalance/RandomLoadBalanceSelector.java | 4 +-
.../WeightRandomLoadBalanceSelector.java | 6 +-
.../eventmesh/common/protocol/tcp/codec/Codec.java | 3 +-
.../eventmesh/common/utils/AssertUtils.java} | 35 +-
.../org/apache/eventmesh/common/utils/Convert.java | 440 +++++++++++++++++++++
.../apache/eventmesh/common/utils/JsonUtils.java | 66 +++-
.../apache/eventmesh/common/utils}/NetUtils.java | 48 ++-
.../apache/eventmesh/common/utils/AssertTest.java} | 21 +-
.../eventmesh-connector-api/build.gradle | 8 +-
.../api/connector/ConnectorResourceService.java | 2 +-
.../knative/consumer/KnativeConsumerImplTest.java | 12 +-
.../knative/producer/KnativeProducerImplTest.java | 30 +-
.../pravega/client/PravegaClientTest.java | 3 +-
.../cloudevent/RabbitmqCloudEventTest.java | 3 +-
.../rabbitmq/consumer/RabbitmqConsumerTest.java | 3 +-
.../rabbitmq/producer/RabbitmqProducerTest.java | 3 +-
.../connector/redis/connector/UnitTest.java | 3 +-
.../rocketmq/config/ClientConfiguration.java | 100 ++---
.../rocketmq/consumer/RocketMQConsumerImpl.java | 23 +-
.../connector/rocketmq/utils/CloudEventUtils.java | 84 ++--
.../eventmeshmessage/AsyncSyncRequestInstance.java | 8 +-
.../pub/eventmeshmessage/SyncRequestInstance.java | 6 +-
.../http/demo/sub/service/SubService.java | 6 +-
.../src/main/resources/application.properties | 2 +-
.../eventmesh/metrics/api/MetricsRegistry.java | 2 +-
.../metrics/api/model/TcpSummaryMetrics.java | 52 ++-
.../eventmesh/protocol/api/ProtocolAdaptor.java | 2 +-
.../eventmesh/api/registry/RegistryService.java | 2 +-
eventmesh-runtime/build.gradle | 6 +-
eventmesh-runtime/conf/eventmesh.properties | 6 +-
.../admin/controller/ClientManageController.java | 53 +--
.../controller/HttpHandlerManager.java} | 44 ++-
.../runtime/admin/handler/AbstractHttpHandler.java | 24 +-
.../admin/handler/DeleteWebHookConfigHandler.java | 19 +-
.../admin/handler/InsertWebHookConfigHandler.java | 20 +-
.../handler/QueryRecommendEventMeshHandler.java | 17 +-
.../handler/QueryWebHookConfigByIdHandler.java | 21 +-
.../QueryWebHookConfigByManufacturerHandler.java | 21 +-
.../handler/RedirectClientByIpPortHandler.java | 17 +-
.../admin/handler/RedirectClientByPathHandler.java | 29 +-
.../handler/RedirectClientBySubSystemHandler.java | 17 +-
.../admin/handler/RejectAllClientHandler.java | 15 +-
.../admin/handler/RejectClientByIpPortHandler.java | 19 +-
.../handler/RejectClientBySubSystemHandler.java | 19 +-
.../admin/handler/ShowClientBySystemHandler.java | 13 +-
.../runtime/admin/handler/ShowClientHandler.java | 12 +-
.../handler/ShowListenClientByTopicHandler.java | 15 +-
.../admin/handler/UpdateWebHookConfigHandler.java | 19 +-
.../{EventMeshTrace.java => EventHttpHandler.java} | 10 +-
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 12 +-
.../QueryRecommendEventMeshHandlerTest.java | 4 +-
.../handler/RedirectClientByIpPortHandlerTest.java | 4 +-
.../handler/RedirectClientByPathHandlerTest.java | 14 +-
.../runtime/client/impl/PubClientImpl.java | 27 +-
.../eventmesh/runtime/demo/AsyncPubClient.java | 2 +-
.../apache/eventmesh/runtime/demo/CCSubClient.java | 2 +-
.../protocol/processor/WebHookProcessorTest.java | 6 +-
.../eventmesh/runtime/util/IOTinyUtilsTest.java | 5 +-
.../eventmesh/runtime/util/NetUtilsTest.java | 2 +
.../examples/grpc/consumer/asyncsub/main.go | 4 +-
eventmesh-sdk-go/grpc/fake_webhookserver.go | 4 +-
eventmesh-sdk-go/grpc/producer.go | 9 -
.../client/catalog/EventMeshCatalogClient.java | 9 +-
.../grpc/config/EventMeshGrpcClientConfig.java | 44 ++-
.../client/http/AbstractProducerHttpClient.java | 97 +++++
.../eventmesh/client/http/model/RequestParam.java | 7 +-
.../client/http/producer/CloudEventProducer.java | 125 ++----
.../http/producer/EventMeshMessageProducer.java | 119 ++----
.../client/http/producer/OpenMessageProducer.java | 89 ++---
.../EventMeshMessageTCPSubClient.java | 4 +-
.../grpc/consumer/EventMeshGrpcConsumerTest.java | 6 +-
.../org/apache/eventmesh/api/acl/AclService.java | 2 +-
.../org/apache/eventmesh/api/auth/AuthService.java | 2 +-
.../eventmesh/spi/EventMeshExtensionFactory.java | 9 +-
.../org/apache/eventmesh/spi/EventMeshSPI.java | 2 +-
.../spi/example/TestSingletonExtension.java | 2 +-
.../eventmesh/trace/api/EventMeshTraceService.java | 2 +-
.../pinpoint/config/PinpointConfiguration.java | 18 +-
.../pinpoint/exporter/PinpointSpanExporter.java | 2 +-
.../admin/AdminWebHookConfigOperationManage.java | 2 +-
.../webhook/admin/FileWebHookConfigOperation.java | 2 +-
.../webhook/admin/NacosWebHookConfigOperation.java | 7 +-
.../admin/FileWebHookConfigOperationTest.java | 2 +-
.../webhook/api/WebHookConfigOperation.java | 12 +-
.../eventmesh/webhook/api/utils/StringUtils.java | 2 +-
gradle.properties | 1 +
gradle/wrapper/gradle-wrapper.properties | 2 +-
maturity.md | 124 +++---
106 files changed, 1840 insertions(+), 1006 deletions(-)
create mode 100644 docs/zh/desing-document/05-metrics-export.md
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/JsonUtils.java
delete mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/NetUtils.java
copy eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshSPI.java =>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/Config.java
(70%)
copy
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigInfo.java
(53%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigMonitorService.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/FileLoad.java
copy
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/HttpMethod.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/NotNull.java
(73%)
rename
{eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/enums}/HttpMethod.java
(95%)
copy
eventmesh-common/src/{test/java/org/apache/eventmesh/common/utils/IPUtilsTest.java
=> main/java/org/apache/eventmesh/common/utils/AssertUtils.java} (58%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/Convert.java
rename {eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util =>
eventmesh-common/src/main/java/org/apache/eventmesh/common/utils}/NetUtils.java
(59%)
copy
eventmesh-common/src/{main/java/org/apache/eventmesh/common/utils/RandomStringUtils.java
=> test/java/org/apache/eventmesh/common/utils/AssertTest.java} (70%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{common/EventMeshTrace.java
=> admin/controller/HttpHandlerManager.java} (50%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/Package.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/AbstractHttpHandler.java
(62%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/{EventMeshTrace.java
=> EventHttpHandler.java} (91%)
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/AbstractProducerHttpClient.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
