You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2023/01/12 01:41:06 UTC
[incubator-eventmesh] branch config-manage-improve updated (e8215b82e -> bd583466a)
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 e8215b82e Merge pull request #2896 from eight-nines/MR2
new 51663802d Change CommonConfiguration and subclass to new framework
new 59a786e0f Add field notEmpty for @ConfigFiled
new b86a23b7d Change the SPI RocketMQ config to new framework
new 4d57310d0 Change the SPI kafka config to new framework
new 1aea2a539 Change the SPI Redis config to new framework
new 010ca9969 Change the SPI knative config to new framework
new b6556b431 Change the SPI pravega config to new framework
new f10330eb1 Change the SPI pulsar config to new framework
new 75ce63e0d Change the SPI rabbitmq config to new framework
new f1b024bab Change the SPI Prometheus config to new framework
new ee0712fb5 Change the SPI auth-http-basic config to new framework
new e703f6fe8 Change the SPI trace-api config to new framework
new 25b487efd Change the SPI pinpoint config to new framework
new f71c6cfbf Change the SPI zipkin config to new framework
new 90d4c52cb Use getter/setter methods to access EventMeshGrpcConfiguration
new 937e43c89 Use getter/setter methods to access EventMeshHTTPConfiguration
new bd583466a Merge pull request #2911 from eight-nines/MR2
The 2534 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:
.../common/config/CommonConfiguration.java | 12 --
.../eventmesh/common/config/ConfigFiled.java | 7 +
.../common/config/ConfigurationWrapper.java | 98 ------------
.../common/config/convert/ConvertValue.java | 12 ++
.../kafka/config/ClientConfiguration.java | 19 +--
.../kafka/config/ConfigurationWrapper.java | 83 ----------
.../knative/common/EventMeshConstants.java | 24 ---
.../knative/config/ClientConfiguration.java | 27 +---
.../knative/config/ConfigurationWrapper.java | 73 ---------
.../knative/config/ClientConfigurationTest.java | 4 +-
.../config/PravegaConnectorConfigWrapper.java | 72 ---------
.../pulsar/config/ConfigurationWrapper.java | 74 ---------
.../rabbitmq/config/ConfigurationWrapper.java | 64 --------
.../connector/redis/config/ConfigOptions.java | 51 ------
.../redis/config/ConfigurationWrapper.java | 74 ---------
.../connector/redis/config/RedisProperties.java | 43 +-----
.../connector/rocketmq/admin/command/Command.java | 8 +-
.../rocketmq/config/ClientConfiguration.java | 171 +--------------------
.../rocketmq/config/ConfigurationWrapper.java | 68 --------
.../rocketmq/consumer/RocketMQConsumerImpl.java | 1 -
.../rocketmq/producer/RocketMQProducerImpl.java | 1 -
.../command/CreateTopicCommandTest.java} | 13 +-
.../prometheus/config/PrometheusConfiguration.java | 11 +-
.../src/test/java/ConsulRegistryServiceTest.java | 2 +-
.../etcd/service/EtcdRegistryServiceTest.java | 2 +-
.../nacos/service/NacosRegistryServiceTest.java | 2 +-
.../service/ZookeeperRegistryServiceTest.java | 2 +-
.../runtime/boot/EventMeshGrpcBootstrap.java | 1 -
.../runtime/boot/EventMeshGrpcServer.java | 42 ++---
.../runtime/boot/EventMeshHTTPServer.java | 73 ++++-----
.../runtime/boot/EventMeshHttpBootstrap.java | 1 -
.../eventmesh/runtime/boot/EventMeshServer.java | 3 -
.../runtime/boot/EventMeshTcpBootstrap.java | 2 -
.../eventmesh/runtime/boot/SSLContextFactory.java | 6 +-
.../configuration/EventMeshGrpcConfiguration.java | 48 +++---
.../configuration/EventMeshHTTPConfiguration.java | 69 ++++-----
.../configuration/EventMeshTCPConfiguration.java | 6 +-
.../protocol/grpc/consumer/ConsumerManager.java | 2 +-
.../protocol/grpc/push/WebhookPushRequest.java | 2 +-
.../core/protocol/grpc/retry/GrpcRetryer.java | 33 ++--
.../protocol/grpc/service/ConsumerService.java | 8 +-
.../protocol/grpc/service/HeartbeatService.java | 2 +-
.../protocol/grpc/service/ProducerService.java | 6 +-
.../http/processor/BatchSendMessageProcessor.java | 18 +--
.../processor/BatchSendMessageV2Processor.java | 6 +-
.../processor/LocalSubscribeEventProcessor.java | 4 +-
.../processor/RemoteSubscribeEventProcessor.java | 6 +-
.../processor/RemoteUnSubscribeEventProcessor.java | 2 +-
.../http/processor/ReplyMessageProcessor.java | 6 +-
.../http/processor/SendAsyncEventProcessor.java | 4 +-
.../http/processor/SendAsyncMessageProcessor.java | 6 +-
.../processor/SendAsyncRemoteEventProcessor.java | 4 +-
.../http/processor/SendSyncMessageProcessor.java | 6 +-
.../http/processor/SubscribeProcessor.java | 4 +-
.../core/protocol/http/retry/HttpRetryer.java | 8 +-
.../controller/ClientManageControllerTest.java | 13 +-
.../runtime/boot/EventMeshServerTest.java | 157 +++----------------
.../eventmesh/runtime/client/common/Server.java | 2 -
.../EventMeshGrpcConfigurationTest.java | 93 +++++++++++
.../EventMeshHTTPConfigurationTest.java | 108 +++++++++++++
.../EventMeshTCPConfigurationTest.java | 95 ++++++++++++
.../eventmesh/api/common/ConfigurationWrapper.java | 58 -------
.../build.gradle | 2 +
.../auth/http/basic/config/AuthConfigs.java | 11 +-
.../trace/api/config/ExporterConfiguration.java | 51 +-----
.../api/config/ExporterConfigurationTest.java | 17 +-
.../{main => test}/resources/exporter.properties | 8 +-
.../eventmesh-trace-pinpoint/build.gradle | 3 +
.../pinpoint/config/PinpointConfiguration.java | 20 +--
.../trace/zipkin/config/ZipkinConfiguration.java | 21 +--
.../webhook/receive/WebHookController.java | 5 -
.../receive/storage/HookConfigOperationManage.java | 2 -
72 files changed, 583 insertions(+), 1479 deletions(-)
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigurationWrapper.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/ConfigurationWrapper.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/common/EventMeshConstants.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ConfigurationWrapper.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigWrapper.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ConfigurationWrapper.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationWrapper.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/ConfigOptions.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/ConfigurationWrapper.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ConfigurationWrapper.java
rename eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/{config/ConfigurationWrapperTest.java => admin/command/CreateTopicCommandTest.java} (66%)
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfigurationTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshHTTPConfigurationTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/configuration/EventMeshTCPConfigurationTest.java
delete mode 100644 eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/common/ConfigurationWrapper.java
copy eventmesh-webhook/eventmesh-webhook-admin/src/test/java/org/apache/eventmesh/webhook/admin/AdminWebHookConfigOperationManageTest.java => eventmesh-trace-plugin/eventmesh-trace-api/src/test/java/org/apache/eventmesh/trace/api/config/ExporterConfigurationTest.java (65%)
copy eventmesh-trace-plugin/eventmesh-trace-api/src/{main => test}/resources/exporter.properties (87%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org