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 2022/04/12 08:27:40 UTC
[incubator-eventmesh] branch develop updated (7eac0cac -> ce62aa09)
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
discard 7eac0cac Merge branch master into develop (#828)
omit 4dcd375d [ISSUE #784] Fix words misspell, optimize admin http method code (#788)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/develop (ce62aa09)
\
O -- O -- O (7eac0cac)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 4 +-
.github/ISSUE_TEMPLATE/bug_report.yml | 23 +-
.github/PULL_REQUEST_TEMPLATE.md | 4 +-
.github/workflows/ci.yml | 34 +-
NOTICE | 2 +-
README.md | 10 +-
README.zh-CN.md | 16 +-
build.gradle | 57 +-
.../{eventmesh => eventmesh-rocketmq}/Dockerfile | 2 +-
.../eventmesh-metrics-Prometheus-instruction.md | 49 -
docs/cn/instructions/eventmesh-runtime-protocol.md | 161 -
.../eventmesh-runtime-quickstart-with-docker.md | 153 -
.../instructions/eventmesh-runtime-quickstart.md | 13 +-
.../instructions/eventmesh-sdk-java-quickstart.md | 53 +-
.../eventmesh-trace-Zipkin-instruction.md | 49 -
docs/en/features/eventmesh-workflow-design.md | 287 --
.../eventmesh-metrics-Prometheus-instruction.md | 49 -
docs/en/instructions/eventmesh-runtime-protocol.md | 163 -
.../eventmesh-runtime-quickstart-with-docker.md | 160 +-
.../instructions/eventmesh-runtime-quickstart.md | 15 +-
.../instructions/eventmesh-sdk-java-quickstart.md | 58 +-
.../eventmesh-trace-Zipkin-instruction.md | 49 -
docs/en/intro.md | 17 -
docs/en/roadmap.md | 32 -
docs/images/Prometheus-download.png | Bin 57766 -> 0 bytes
docs/images/eventmesh-orchestration.png | Bin 2779741 -> 272622 bytes
docs/images/features/eventmesh-workflow-arch.jpg | Bin 166972 -> 0 bytes
docs/images/features/eventmesh-workflow-diag.png | Bin 135137 -> 0 bytes
.../images/features/eventmesh-workflow-usecase.jpg | Bin 109159 -> 0 bytes
docs/images/prometheus-yml.png | Bin 20290 -> 0 bytes
docs/images/promethus-search.png | Bin 122129 -> 0 bytes
eventmesh-admin/README.md | 12 +-
.../apache/eventmesh/admin/rocketmq/Constants.java | 23 -
.../eventmesh/admin/rocketmq/HttpMethod.java | 24 -
.../admin/rocketmq/controller/AdminController.java | 9 +-
.../admin/rocketmq/handler/TopicsHandler.java | 19 +-
.../admin/rocketmq/response/TopicResponse.java | 6 +-
.../eventmesh/admin/rocketmq/util/JsonUtils.java | 10 +-
.../eventmesh/admin/rocketmq/util/NetUtils.java | 15 +-
.../admin/rocketmq/util/RequestMapping.java | 20 +-
.../admin/rocketmq/util/UrlMappingPattern.java | 8 +-
eventmesh-common/build.gradle | 10 +-
.../org/apache/eventmesh/common/Constants.java | 4 +-
.../apache/eventmesh/common/ThreadPoolFactory.java | 2 +-
.../common/config/CommonConfiguration.java | 139 +-
.../common/config/ConfigurationWrapper.java | 32 +-
.../loadbalance/RandomLoadBalanceSelector.java | 5 +-
.../eventmesh/common/loadbalance/Weight.java | 10 +-
.../WeightRandomLoadBalanceSelector.java | 3 +-
.../WeightRoundRobinLoadBalanceSelector.java | 5 +-
.../common/protocol/SubscriptionItem.java | 33 +-
.../protocol/grpc/common/BatchMessageWrapper.java | 34 -
.../common/protocol/grpc/common/ProtocolKey.java | 42 -
.../protocol/grpc/common/SimpleMessageWrapper.java | 34 -
.../common/protocol/grpc/common/StatusCode.java | 70 -
.../common/protocol/grpc/protos/BatchMessage.java | 2574 -------------
.../grpc/protos/BatchMessageOrBuilder.java | 84 -
.../protocol/grpc/protos/ConsumerServiceGrpc.java | 445 ---
.../common/protocol/grpc/protos/EventmeshGrpc.java | 283 --
.../common/protocol/grpc/protos/Heartbeat.java | 2033 ----------
.../protocol/grpc/protos/HeartbeatOrBuilder.java | 93 -
.../protocol/grpc/protos/HeartbeatServiceGrpc.java | 290 --
.../protocol/grpc/protos/PublisherServiceGrpc.java | 476 ---
.../common/protocol/grpc/protos/RequestHeader.java | 1931 ----------
.../grpc/protos/RequestHeaderOrBuilder.java | 147 -
.../common/protocol/grpc/protos/Response.java | 788 ----
.../protocol/grpc/protos/ResponseOrBuilder.java | 57 -
.../common/protocol/grpc/protos/SimpleMessage.java | 1754 ---------
.../grpc/protos/SimpleMessageOrBuilder.java | 144 -
.../common/protocol/grpc/protos/Subscription.java | 3934 --------------------
.../grpc/protos/SubscriptionOrBuilder.java | 97 -
.../common/protocol/http/HttpCommand.java | 30 +-
.../protocol/http/body/BaseResponseBody.java | 4 +-
.../eventmesh/common/protocol/http/body/Body.java | 4 +-
.../http/body/client/HeartbeatRequestBody.java | 22 +-
.../http/body/client/HeartbeatResponseBody.java | 9 +-
.../protocol/http/body/client/RegRequestBody.java | 12 +-
.../protocol/http/body/client/RegResponseBody.java | 9 +-
.../http/body/client/SubscribeRequestBody.java | 12 +-
.../http/body/client/SubscribeResponseBody.java | 9 +-
.../http/body/client/UnRegRequestBody.java | 16 +-
.../http/body/client/UnRegResponseBody.java | 9 +-
.../http/body/client/UnSubscribeRequestBody.java | 12 +-
.../http/body/client/UnSubscribeResponseBody.java | 9 +-
.../http/body/message/PushMessageRequestBody.java | 26 +-
.../http/body/message/PushMessageResponseBody.java | 9 +-
.../http/body/message/ReplyMessageRequestBody.java | 26 +-
.../body/message/ReplyMessageResponseBody.java | 9 +-
.../body/message/SendMessageBatchRequestBody.java | 36 +-
.../body/message/SendMessageBatchResponseBody.java | 9 +-
.../message/SendMessageBatchV2RequestBody.java | 7 +-
.../message/SendMessageBatchV2ResponseBody.java | 9 +-
.../http/body/message/SendMessageRequestBody.java | 34 +-
.../http/body/message/SendMessageResponseBody.java | 10 +-
.../common/protocol/http/common/ProtocolKey.java | 2 -
.../protocol/http/header/BaseRequestHeader.java | 7 +-
.../protocol/http/header/BaseResponseHeader.java | 4 +-
.../common/protocol/http/header/Header.java | 4 +-
.../http/header/client/HeartbeatRequestHeader.java | 11 +-
.../header/client/HeartbeatResponseHeader.java | 6 +-
.../http/header/client/RegRequestHeader.java | 5 +-
.../http/header/client/RegResponseHeader.java | 6 +-
.../http/header/client/SubscribeRequestHeader.java | 5 +-
.../header/client/SubscribeResponseHeader.java | 6 +-
.../http/header/client/UnRegRequestHeader.java | 11 +-
.../http/header/client/UnRegResponseHeader.java | 6 +-
.../header/client/UnSubscribeRequestHeader.java | 5 +-
.../header/client/UnSubscribeResponseHeader.java | 6 +-
.../header/message/PushMessageRequestHeader.java | 9 +-
.../header/message/ReplyMessageRequestHeader.java | 5 +-
.../header/message/ReplyMessageResponseHeader.java | 6 +-
.../message/SendMessageBatchRequestHeader.java | 5 +-
.../message/SendMessageBatchResponseHeader.java | 6 +-
.../message/SendMessageBatchV2RequestHeader.java | 5 +-
.../message/SendMessageBatchV2ResponseHeader.java | 6 +-
.../header/message/SendMessageRequestHeader.java | 5 +-
.../header/message/SendMessageResponseHeader.java | 6 +-
.../common/protocol/tcp/EventMeshClientInfo.java | 7 +-
.../common/protocol/tcp/EventMeshMessage.java | 4 +-
.../eventmesh/common/protocol/tcp/Header.java | 12 +-
.../common/protocol/tcp/HeartBeatInfo.java | 12 +-
.../eventmesh/common/protocol/tcp/Package.java | 2 -
.../common/protocol/tcp/RedirectInfo.java | 9 +-
.../common/protocol/tcp/RegisterInfo.java | 6 +-
.../common/protocol/tcp/Subscription.java | 6 +-
.../common/protocol/tcp/UnRegisterInfo.java | 12 +-
.../eventmesh/common/protocol/tcp/UserAgent.java | 94 +-
.../eventmesh/common/protocol/tcp/codec/Codec.java | 21 +-
.../org/apache/eventmesh/common/utils/IPUtils.java | 77 +-
.../eventmesh/common/utils/RandomStringUtils.java | 2 +-
.../eventmesh/common/EventMeshMessageTest.java | 4 +-
.../loadbalance/RandomLoadBalanceSelectorTest.java | 10 +-
.../WeightRandomLoadBalanceSelectorTest.java | 12 +-
.../WeightRoundRobinLoadBalanceSelectorTest.java | 10 +-
.../protocol/http/body/BaseResponseBodyTest.java | 5 +-
.../http/header/BaseRequestHeaderTest.java | 7 +-
.../http/header/BaseResponseHeaderTest.java | 5 +-
.../header/client/AbstractRequestHeaderTest.java | 1 -
.../header/client/AbstractResponseHeaderTest.java | 5 +-
.../header/client/HeartbeatRequestHeaderTest.java | 4 +-
.../header/client/HeartbeatResponseHeaderTest.java | 4 +
.../http/header/client/RegRequestHeaderTest.java | 4 +-
.../header/client/SubscribeRequestHeaderTest.java | 4 +-
.../http/header/client/UnRegRequestHeaderTest.java | 4 +-
.../client/UnSubscribeRequestHeaderTest.java | 4 +-
.../message/PushMessageRequestHeaderTest.java | 9 +-
.../message/PushMessageResponseHeaderTest.java | 5 +-
.../message/ReplyMessageRequestHeaderTest.java | 9 +-
.../message/ReplyMessageResponseHeaderTest.java | 5 +-
.../common/protocol/tcp/codec/CodecTest.java | 17 +-
.../{IPUtilsTest.java => ThreadUtilsTest.java} | 34 +-
.../src/test/resources/configuration.properties | 4 +-
.../org/apache/eventmesh/api/AbstractContext.java | 3 -
.../apache/eventmesh/api/RequestReplyCallback.java | 3 -
.../api/connector/ConnectorResourceService.java | 6 +-
.../apache/eventmesh/api/consumer/Consumer.java | 6 +-
.../rocketmq/MessagingAccessPointImpl.java | 90 +
.../rocketmq/admin/command/CreateTopicCommand.java | 2 +-
.../cloudevent/RocketMQMessageFactory.java | 19 +-
.../impl/RocketMQBinaryMessageReader.java | 7 +-
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 4 +-
.../cloudevent/impl/RocketMQMessageWriter.java | 12 +-
.../rocketmq/config/ClientConfiguration.java | 94 +-
.../rocketmq/config/ConfigurationWrapper.java | 39 +-
.../ConnectorResourceServiceRocketmqImpl.java | 1 -
.../rocketmq/consumer/PushConsumerImpl.java | 72 +-
.../rocketmq/consumer/RocketMQConsumerImpl.java | 14 +-
.../connector/rocketmq/domain/NonStandardKeys.java | 3 -
.../rocketmq/domain/RocketMQConstants.java | 3 -
.../patch/EventMeshConsumeConcurrentlyContext.java | 1 -
.../EventMeshMessageListenerConcurrently.java | 9 +-
.../rocketmq/producer/AbstractProducer.java | 56 +-
.../connector/rocketmq/producer/ProducerImpl.java | 45 +-
.../rocketmq/producer/RocketMQProducerImpl.java | 14 +-
.../connector/rocketmq/utils/BeanUtils.java | 100 +-
.../connector/rocketmq/utils/CloudEventUtils.java | 26 +-
.../connector/rocketmq/utils/OMSUtil.java | 262 +-
.../ConsumeMessageConcurrentlyService.java | 67 +-
.../producer/DefaultProducerImplTest.java | 51 +-
.../rocketmq/consumer/PushConsumerImplTest.java | 21 +-
.../apache/rocketmq/producer/ProducerImplTest.java | 24 +-
.../org/apache/rocketmq/utils/BeanUtilsTest.java | 11 +-
.../eventmesh-connector-standalone/build.gradle | 1 +
.../connector/standalone/broker/MessageQueue.java | 3 +-
.../standalone/broker/StandaloneBroker.java | 6 +-
.../standalone/broker/model/MessageEntity.java | 4 +-
.../standalone/broker/model/TopicMetadata.java | 6 +-
.../broker/task/HistoryMessageClearTask.java | 7 +-
.../standalone/broker/task/SubScribeTask.java | 16 +-
.../standalone/consumer/StandaloneConsumer.java | 21 +-
.../consumer/StandaloneConsumerAdaptor.java | 101 +-
.../standalone/producer/StandaloneProducer.java | 22 +-
.../producer/StandaloneProducerAdaptor.java | 10 +
.../standalone/broker/StandaloneBrokerTest.java | 16 +-
eventmesh-examples/build.gradle | 7 -
.../apache/eventmesh/common/ExampleConstants.java | 45 -
.../CloudEventsBatchPublishInstance.java | 86 -
.../cloudevents/CloudEventsPublishInstance.java | 84 -
.../cloudevents/CloudEventsRequestInstance.java | 85 -
.../eventmeshmessage/AsyncPublishBroadcast.java | 77 -
.../pub/eventmeshmessage/AsyncPublishInstance.java | 77 -
.../pub/eventmeshmessage/BatchPublishInstance.java | 78 -
.../pub/eventmeshmessage/RequestReplyInstance.java | 79 -
.../grpc/sub/CloudEventsAsyncSubscribe.java | 82 -
.../grpc/sub/CloudEventsSubscribeReply.java | 86 -
.../grpc/sub/EventmeshAsyncSubscribe.java | 81 -
.../grpc/sub/EventmeshSubscribeBroadcast.java | 81 -
.../grpc/sub/EventmeshSubscribeReply.java | 85 -
.../grpc/sub/app/SpringBootDemoApplication.java | 30 -
.../grpc/sub/app/controller/SubController.java | 74 -
.../eventmesh/grpc/sub/app/service/SubService.java | 122 -
.../demo/pub/cloudevents/AsyncPublishInstance.java | 66 +-
.../pub/eventmeshmessage/AsyncPublishInstance.java | 49 +-
.../eventmeshmessage/AsyncSyncRequestInstance.java | 38 +-
.../pub/eventmeshmessage/SyncRequestInstance.java | 34 +-
.../http/demo/sub/controller/SubController.java | 20 +-
.../http/demo/sub/service/SubService.java | 41 +-
.../tcp/common/EventMeshTestCaseTopicSet.java | 2 +-
.../eventmesh/tcp/common/EventMeshTestUtils.java | 111 +-
.../tcp/demo/pub/cloudevents/AsyncPublish.java | 31 +-
.../tcp/demo/pub/cloudevents/SyncRequest.java | 33 +-
.../demo/pub/eventmeshmessage/AsyncPublish.java | 25 +-
.../eventmeshmessage/AsyncPublishBroadcast.java | 23 +-
.../tcp/demo/pub/eventmeshmessage/SyncRequest.java | 25 +-
.../tcp/demo/sub/cloudevents/AsyncSubscribe.java | 32 +-
.../tcp/demo/sub/cloudevents/SyncResponse.java | 35 +-
.../demo/sub/eventmeshmessage/AsyncSubscribe.java | 34 +-
.../eventmeshmessage/AsyncSubscribeBroadcast.java | 26 +-
.../demo/sub/eventmeshmessage/SyncResponse.java | 33 +-
.../main/java/org/apache/eventmesh/util/Utils.java | 14 +-
.../src/main/resources/application.properties | 3 +-
eventmesh-metrics-plugin/build.gradle | 16 -
.../eventmesh-metrics-api/build.gradle | 28 -
.../eventmesh-metrics-api/gradle.properties | 16 -
.../metrics/api/MetricsPluginFactory.java | 41 -
.../eventmesh/metrics/api/MetricsRegistry.java | 56 -
.../apache/eventmesh/metrics/api/model/Metric.java | 24 -
.../metrics/api/model/TcpSummaryMetrics.java | 123 -
.../eventmesh-metrics-opentelemetry/build.gradle | 38 -
.../gradle.properties | 18 -
.../OpenTelemetryMetricsRegistry.java | 87 -
.../config/OpenTelemetryConfiguration.java | 81 -
.../metrics/OpenTelemetryHttpExporter.java | 298 --
.../metrics/OpenTelemetryTcpExporter.java | 89 -
...rg.apache.eventmesh.metrics.api.MetricsRegistry | 16 -
.../src/main/resources/opentelemetry.properties | 19 -
.../config/OpenTelemetryConfigurationTest.java | 30 -
.../src/test/resources/opentelemetry.properties | 18 -
eventmesh-metrics-plugin/gradle.properties | 16 -
.../eventmesh-protocol-api/build.gradle | 1 +
.../eventmesh/protocol/api/ProtocolAdaptor.java | 4 +-
.../protocol/api/ProtocolPluginFactory.java | 8 +-
.../eventmesh-protocol-cloudevents/build.gradle | 3 +-
.../cloudevents/CloudEventsProtocolAdaptor.java | 21 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 233 --
.../http/SendMessageBatchProtocolResolver.java | 3 +-
.../http/SendMessageBatchV2ProtocolResolver.java | 84 +-
.../http/SendMessageRequestProtocolResolver.java | 22 +-
.../resolver/tcp/TcpMessageProtocolResolver.java | 18 +-
.../CloudEventsProtocolAdaptorTest.java | 4 +-
.../eventmesh-protocol-grpc/build.gradle | 54 -
.../src/main/proto/eventmesh-client.proto | 155 -
.../eventmesh-protocol-meshmessage/build.gradle | 2 +-
.../meshmessage/MeshMessageProtocolAdaptor.java | 25 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 268 --
.../http/SendMessageBatchProtocolResolver.java | 3 +-
.../http/SendMessageBatchV2ProtocolResolver.java | 10 +-
.../http/SendMessageRequestProtocolResolver.java | 89 +-
.../resolver/tcp/TcpMessageProtocolResolver.java | 10 +-
.../MeshMessageProtocolAdaptorTest.java | 4 +-
.../eventmesh-protocol-openmessage/build.gradle | 1 +
.../openmessage/OpenMessageProtocolAdaptor.java | 6 +-
.../OpenMessageProtocolAdaptorTest.java | 4 +-
.../eventmesh/api/exception/RegistryException.java | 4 -
.../eventmesh/api/registry/RegistryService.java | 7 +-
.../api/registry/dto/EventMeshDataInfo.java | 4 -
.../api/registry/dto/EventMeshRegisterInfo.java | 4 -
.../api/registry/dto/EventMeshUnRegisterInfo.java | 4 -
eventmesh-runtime/bin/start.sh | 2 +-
eventmesh-runtime/bin/stop.sh | 2 +-
eventmesh-runtime/build.gradle | 37 +-
eventmesh-runtime/conf/eventmesh.properties | 31 +-
.../conf}/prometheus.yml | 1 -
.../java/org/apache/eventmesh/runtime/acl/Acl.java | 43 +-
.../admin/controller/ClientManageController.java | 6 +-
.../handler/QueryRecommendEventMeshHandler.java | 37 +-
.../handler/RedirectClientByIpPortHandler.java | 31 +-
.../admin/handler/RedirectClientByPathHandler.java | 33 +-
.../handler/RedirectClientBySubSystemHandler.java | 28 +-
.../admin/handler/RejectAllClientHandler.java | 2 +-
.../admin/handler/RejectClientByIpPortHandler.java | 16 +-
.../handler/RejectClientBySubSystemHandler.java | 20 +-
.../admin/handler/ShowClientBySystemHandler.java | 10 +-
.../runtime/admin/handler/ShowClientHandler.java | 18 +-
.../handler/ShowListenClientByTopicHandler.java | 12 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 91 +-
.../runtime/boot/AbstractRemotingServer.java | 9 +-
.../runtime/boot/EventMeshGrpcServer.java | 228 --
.../runtime/boot/EventMeshHTTPServer.java | 99 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 37 +-
.../eventmesh/runtime/boot/EventMeshStartup.java | 10 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 150 +-
.../eventmesh/runtime/boot/SSLContextFactory.java | 10 +-
.../configuration/EventMeshGrpcConfiguration.java | 257 --
.../configuration/EventMeshHTTPConfiguration.java | 257 +-
.../configuration/EventMeshTCPConfiguration.java | 93 +-
.../runtime/connector/ConnectorResource.java | 6 +-
.../runtime/constants/EventMeshConstants.java | 3 +-
.../core/consumergroup/ConsumerGroupConf.java | 15 +-
.../core/consumergroup/ConsumerGroupTopicConf.java | 41 +-
.../core/consumergroup/ProducerGroupConf.java | 8 +-
.../runtime/core/plugin/MQConsumerWrapper.java | 22 +-
.../runtime/core/plugin/MQProducerWrapper.java | 5 +-
.../eventmesh/runtime/core/plugin/MQWrapper.java | 9 +-
.../protocol/grpc/consumer/ConsumerManager.java | 237 --
.../protocol/grpc/consumer/EventMeshConsumer.java | 298 --
.../consumergroup/ConsumerGroupClient.java | 91 -
.../consumergroup/ConsumerGroupTopicConfig.java | 73 -
.../consumer/consumergroup/StreamTopicConfig.java | 142 -
.../consumer/consumergroup/WebhookTopicConfig.java | 126 -
.../processor/BatchPublishMessageProcessor.java | 138 -
.../grpc/processor/HeartbeatProcessor.java | 113 -
.../grpc/processor/ReplyMessageProcessor.java | 139 -
.../grpc/processor/RequestMessageProcessor.java | 148 -
.../grpc/processor/SendAsyncMessageProcessor.java | 137 -
.../grpc/processor/SubscribeProcessor.java | 141 -
.../grpc/processor/SubscribeStreamProcessor.java | 141 -
.../grpc/processor/UnsubscribeProcessor.java | 111 -
.../protocol/grpc/producer/EventMeshProducer.java | 106 -
.../protocol/grpc/producer/ProducerManager.java | 92 -
.../protocol/grpc/producer/SendMessageContext.java | 127 -
.../protocol/grpc/push/AbstractPushRequest.java | 168 -
.../core/protocol/grpc/push/HandleMsgContext.java | 102 -
.../core/protocol/grpc/push/MessageHandler.java | 93 -
.../core/protocol/grpc/push/StreamPushRequest.java | 127 -
.../protocol/grpc/push/WebhookPushRequest.java | 261 --
.../core/protocol/grpc/retry/DelayRetryable.java | 26 -
.../core/protocol/grpc/retry/GrpcRetryer.java | 116 -
.../core/protocol/grpc/retry/RetryContext.java | 50 -
.../protocol/grpc/service/ConsumerService.java | 165 -
.../core/protocol/grpc/service/EventEmitter.java | 61 -
.../protocol/grpc/service/HeartbeatService.java | 66 -
.../protocol/grpc/service/ProducerService.java | 108 -
.../core/protocol/grpc/service/ServiceUtils.java | 159 -
.../core/protocol/http/async/CompleteHandler.java | 5 -
.../http/consumer/ConsumerGroupManager.java | 15 +-
.../protocol/http/consumer/ConsumerManager.java | 190 +-
.../protocol/http/consumer/EventMeshConsumer.java | 269 +-
.../protocol/http/consumer/HandleMsgContext.java | 27 +-
.../http/processor/AdminMetricsProcessor.java | 5 +-
.../http/processor/AdminShutdownProcessor.java | 8 +-
.../http/processor/BatchSendMessageProcessor.java | 125 +-
.../processor/BatchSendMessageV2Processor.java | 182 +-
.../http/processor/HeartBeatProcessor.java | 78 +-
.../http/processor/ReplyMessageProcessor.java | 213 +-
.../http/processor/SendAsyncMessageProcessor.java | 116 +-
.../http/processor/SendSyncMessageProcessor.java | 197 +-
.../http/processor/SubscribeProcessor.java | 109 +-
.../http/processor/UnSubscribeProcessor.java | 133 +-
.../core/protocol/http/processor/inf/Client.java | 21 +-
.../http/processor/inf/HttpRequestProcessor.java | 7 +-
.../protocol/http/producer/EventMeshProducer.java | 13 +-
.../protocol/http/producer/ProducerManager.java | 5 +-
.../protocol/http/producer/SendMessageContext.java | 18 +-
.../http/push/AbstractHTTPPushRequest.java | 33 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 99 +-
.../core/protocol/http/push/HTTPClientPool.java | 76 +-
.../protocol/http/push/HTTPMessageHandler.java | 21 +-
.../core/protocol/http/push/MessageHandler.java | 3 -
.../core/protocol/http/retry/DelayRetryable.java | 3 -
.../core/protocol/http/retry/HttpRetryer.java | 55 +-
.../protocol/tcp/client/EventMeshTcp2Client.java | 26 +-
.../tcp/client/EventMeshTcpConnectionHandler.java | 14 +-
.../tcp/client/EventMeshTcpExceptionHandler.java | 13 +-
.../tcp/client/EventMeshTcpMessageDispatcher.java | 35 +-
.../tcp/client/group/ClientGroupWrapper.java | 435 ++-
.../client/group/ClientSessionGroupMapping.java | 136 +-
.../group/dispatch/DownstreamDispatchStrategy.java | 7 +-
.../dispatch/FreePriorityDispatchStrategy.java | 11 +-
.../rebalance/EventMeshRebalanceService.java | 14 +-
.../rebalance/EventMeshRebalanceStrategy.java | 4 -
.../client/rebalance/EventmeshRebalanceImpl.java | 166 +-
.../client/recommend/EventMeshRecommendImpl.java | 130 +-
.../recommend/EventMeshRecommendStrategy.java | 8 +-
.../core/protocol/tcp/client/session/Session.java | 77 +-
.../tcp/client/session/SessionContext.java | 7 +-
.../tcp/client/session/push/ClientAckContext.java | 41 +-
.../client/session/push/DownStreamMsgContext.java | 87 +-
.../tcp/client/session/push/PushContext.java | 21 +-
.../tcp/client/session/push/SessionPusher.java | 40 +-
.../client/session/retry/EventMeshTcpRetryer.java | 27 +-
.../tcp/client/session/retry/RetryContext.java | 2 +-
.../tcp/client/session/send/SessionSender.java | 74 +-
.../client/session/send/UpStreamMsgContext.java | 25 +-
.../protocol/tcp/client/task/AbstractTask.java | 6 +-
.../core/protocol/tcp/client/task/GoodbyeTask.java | 8 +-
.../protocol/tcp/client/task/HeartBeatTask.java | 10 +-
.../core/protocol/tcp/client/task/HelloTask.java | 39 +-
.../core/protocol/tcp/client/task/ListenTask.java | 8 +-
.../protocol/tcp/client/task/MessageAckTask.java | 16 +-
.../tcp/client/task/MessageTransferTask.java | 75 +-
.../protocol/tcp/client/task/RecommendTask.java | 35 +-
.../protocol/tcp/client/task/SubscribeTask.java | 19 +-
.../protocol/tcp/client/task/UnSubscribeTask.java | 19 +-
.../eventmesh/runtime/domain/BytesMessageImpl.java | 113 +
.../eventmesh/runtime/domain/ConsumeRequest.java | 55 +
.../eventmesh/runtime/domain/NonStandardKeys.java | 4 -
.../runtime/domain/RocketMQConstants.java | 5 -
.../eventmesh/runtime/domain/SendResultImpl.java | 39 +
.../runtime/exporter/EventMeshExporter.java | 19 +-
.../runtime/{trace => exporter}/LogExporter.java | 2 +-
.../eventmesh/runtime/exporter/ZipkinExporter.java | 46 +
.../runtime/metrics/http/GroupMetrics.java | 23 +-
.../runtime/metrics/http/HTTPMetricsServer.java | 193 +-
.../runtime/metrics/http/HealthMetrics.java | 18 +-
.../runtime/metrics/http/SummaryMetrics.java | 157 +-
.../runtime/metrics/http/TcpSummaryMetrics.java | 208 +-
.../runtime/metrics/http/TopicMetrics.java | 22 +-
.../OpenTelemetryHTTPMetricsExporter.java | 309 ++
.../OpenTelemetryPrometheusExporter.java | 60 +
.../OpenTelemetryTCPMetricsExporter.java | 106 +
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 248 +-
.../patch/EventMeshConsumeConcurrentlyContext.java | 44 +
.../EventMeshMessageListenerConcurrently.java | 69 +
.../eventmesh/runtime/registry/Registry.java | 18 +-
.../runtime/trace/OpenTelemetryTraceFactory.java | 109 +
.../eventmesh/runtime/util/EventMeshUtil.java | 141 +-
.../eventmesh/runtime/util/HttpTinyClient.java | 27 +-
.../apache/eventmesh/runtime/util/IOTinyUtils.java | 20 +-
.../apache/eventmesh/runtime/util/NetUtils.java | 6 +-
.../eventmesh/runtime/util/RemotingHelper.java | 99 +-
.../org/apache/eventmesh/runtime/util/Utils.java | 68 +-
.../eventmesh/runtime/util/ValueComparator.java | 6 +-
.../apache/eventmesh/runtime/util/WebhookUtil.java | 109 -
.../handler/RedirectClientByIpPortHandlerTest.java | 12 +-
.../runtime/client/api/EventMeshClient.java | 6 +-
.../eventmesh/runtime/client/api/PubClient.java | 5 +-
.../eventmesh/runtime/client/api/SubClient.java | 7 +-
.../runtime/client/common/ClientConstants.java | 4 +-
.../runtime/client/common/ClientGlobal.java | 6 +-
.../eventmesh/runtime/client/common/Codec.java | 60 +-
.../runtime/client/common/MessageUtils.java | 20 +-
.../runtime/client/common/RequestContext.java | 7 +-
.../eventmesh/runtime/client/common/Server.java | 2 +-
.../eventmesh/runtime/client/common/TCPClient.java | 21 +-
.../runtime/client/common/UserAgentUtils.java | 12 +-
.../runtime/client/hook/ReceiveMsgHook.java | 4 +-
.../runtime/client/impl/EventMeshClientImpl.java | 57 +-
.../runtime/client/impl/PubClientImpl.java | 29 +-
.../runtime/client/impl/SubClientImpl.java | 64 +-
.../eventmesh/runtime/cloudevent/CSVFormat.java | 107 +
.../apache/eventmesh/runtime/cloudevent/Data.java | 197 +
.../runtime/cloudevent/OMSFactoryTest.java | 260 ++
.../runtime/cloudevent/OMSWriterTest.java | 287 ++
.../eventmesh/runtime/demo/AsyncPubClient.java | 8 +-
.../eventmesh/runtime/demo/AsyncSubClient.java | 8 +-
.../eventmesh/runtime/demo/BroadCastPubClient.java | 1 +
.../eventmesh/runtime/demo/BroadCastSubClient.java | 8 +-
.../apache/eventmesh/runtime/demo/CCSubClient.java | 8 +-
.../apache/eventmesh/runtime/demo/CClientDemo.java | 34 +-
.../eventmesh/runtime/demo/SyncPubClient.java | 4 +-
.../eventmesh/runtime/demo/SyncSubClient.java | 10 +-
.../eventmesh/runtime/util/EventMeshUtilTest.java | 4 +-
eventmesh-runtime/src/test/resources/log4j2.xml | 9 +-
eventmesh-sdk-java/build.gradle | 10 -
.../grpc/config/EventMeshGrpcClientConfig.java | 76 -
.../grpc/consumer/EventMeshGrpcConsumer.java | 264 --
.../client/grpc/consumer/ReceiveMsgHook.java | 38 -
.../client/grpc/consumer/SubStreamHandler.java | 161 -
.../client/grpc/producer/CloudEventProducer.java | 136 -
.../grpc/producer/EventMeshGrpcProducer.java | 131 -
.../client/grpc/util/EventMeshClientUtil.java | 223 --
.../eventmesh/client/http/AbstractHttpClient.java | 10 +-
.../http/consumer/EventMeshHttpConsumer.java | 59 +-
.../client/http/consumer/HandleResult.java | 9 +-
.../http/consumer/context/LiteConsumeContext.java | 79 +-
.../consumer/listener/LiteMessageListener.java | 17 +-
.../eventmesh/client/http/model/RequestParam.java | 7 +-
.../client/http/producer/CloudEventProducer.java | 76 +-
.../http/producer/EventMeshHttpProducer.java | 23 +-
.../http/producer/EventMeshMessageProducer.java | 67 +-
.../http/producer/EventMeshProtocolProducer.java | 2 +-
.../client/http/producer/OpenMessageProducer.java | 38 +-
.../producer/RRCallbackResponseHandlerAdapter.java | 29 +-
.../client/http/ssl/MyX509TrustManager.java | 11 +-
.../client/http/util/HttpLoadBalanceUtils.java | 19 +-
.../eventmesh/client/http/util/HttpUtils.java | 75 +-
.../eventmesh/client/tcp/EventMeshTCPClient.java | 2 +-
.../client/tcp/EventMeshTCPClientFactory.java | 9 +-
.../client/tcp/EventMeshTCPSubClient.java | 2 +-
.../client/tcp/common/AsyncRRCallback.java | 3 -
.../eventmesh/client/tcp/common/MessageUtils.java | 56 +-
.../client/tcp/common/RequestContext.java | 12 +-
.../eventmesh/client/tcp/common/TcpClient.java | 37 +-
.../client/tcp/conf/EventMeshTCPClientConfig.java | 4 +-
.../tcp/impl/AbstractEventMeshTCPPubHandler.java | 7 +-
.../tcp/impl/AbstractEventMeshTCPSubHandler.java | 7 +-
.../tcp/impl/cloudevent/CloudEventTCPClient.java | 2 +-
.../impl/cloudevent/CloudEventTCPPubClient.java | 18 +-
.../impl/cloudevent/CloudEventTCPSubClient.java | 17 +-
.../EventMeshMessageTCPClient.java | 4 +-
.../EventMeshMessageTCPPubClient.java | 13 +-
.../EventMeshMessageTCPSubClient.java | 9 +-
.../tcp/impl/openmessage/OpenMessageTCPClient.java | 3 +-
.../impl/openmessage/OpenMessageTCPPubClient.java | 1 -
.../impl/openmessage/OpenMessageTCPSubClient.java | 3 +-
.../client/http/demo/AsyncPublishInstance.java | 26 +-
.../client/http/demo/AsyncSyncRequestInstance.java | 28 +-
.../client/http/demo/SyncRequestInstance.java | 26 +-
.../client/http/util/HttpLoadBalanceUtilsTest.java | 5 +-
.../client/tcp/common/EventMeshTestUtils.java | 44 +-
.../tcp/impl/EventMeshTCPClientFactoryTest.java | 14 +-
.../eventmesh-security-api/build.gradle | 2 -
.../org/apache/eventmesh/api/acl/AclService.java | 4 -
.../org/apache/eventmesh/api/auth/AuthService.java | 39 -
.../eventmesh/api/common/ConfigurationWrapper.java | 58 -
.../eventmesh/api/exception/AclException.java | 4 -
.../eventmesh/api/exception/AuthException.java | 29 -
.../build.gradle | 22 -
.../gradle.properties | 18 -
.../auth/http/basic/config/AuthConfigs.java | 41 -
.../auth/http/basic/impl/AuthHttpBasicService.java | 61 -
.../org.apache.eventmesh.api.auth.AuthService | 16 -
.../src/main/resources/auth-http-basic.properties | 18 -
.../eventmesh/spi/EventMeshExtensionFactory.java | 8 +-
.../eventmesh/spi/EventMeshExtensionType.java | 2 -
.../org/apache/eventmesh/spi/EventMeshSPI.java | 1 -
.../spi/loader/EventMeshUrlClassLoader.java | 1 -
.../spi/loader/JarExtensionClassLoader.java | 26 +-
.../spi/loader/MetaInfExtensionClassLoader.java | 5 +-
.../spi/EventMeshExtensionFactoryTest.java | 1 -
.../spi/example/TestPrototypeExtension.java | 3 -
.../spi/example/TestSingletonExtension.java | 3 -
eventmesh-trace-plugin/build.gradle | 16 -
.../eventmesh-trace-api/build.gradle | 30 -
.../eventmesh-trace-api/gradle.properties | 16 -
.../eventmesh/trace/api/TracePluginFactory.java | 43 -
.../apache/eventmesh/trace/api/TraceService.java | 55 -
.../trace/api/config/ExporterConfiguration.java | 117 -
.../src/main/resources/exporter.properties | 25 -
.../eventmesh-trace-zipkin/build.gradle | 33 -
.../eventmesh-trace-zipkin/gradle.properties | 16 -
.../eventmesh/trace/zipkin/ZipkinTraceService.java | 118 -
.../trace/zipkin/config/ZipkinConfiguration.java | 96 -
.../org.apache.eventmesh.trace.api.TraceService | 16 -
.../src/main/resources/zipkin.properties | 20 -
eventmesh-trace-plugin/gradle.properties | 16 -
gradle.properties | 2 +-
gradle/wrapper/gradle-wrapper.jar | Bin 59536 -> 58910 bytes
gradle/wrapper/gradle-wrapper.properties | 3 +-
gradlew | 31 +-
gradlew.bat | 49 +-
settings.gradle | 11 -
style/checkStyle.xml | 23 +-
tool/license/allowed-licenses.txt | 0
.../third-party-dependencies/check-dependencies.sh | 25 +-
.../known-dependencies.txt | 70 +-
tools/third-party-licenses/LICENSE | 70 +-
.../licenses/LICENSE-grpc-context.txt | 242 --
.../licenses/LICENSE-grpc-core.txt | 242 --
.../licenses/LICENSE-grpc-netty-shaded.txt | 242 --
.../licenses/LICENSE-grpc-netty.txt | 242 --
.../licenses/LICENSE-grpc-protobuf-lite.txt | 242 --
.../licenses/LICENSE-grpc-protobuf.txt | 242 --
.../licenses/LICENSE-grpc-stub.txt | 242 --
.../third-party-licenses/licenses/LICENSE-gson.txt | 202 -
.../licenses/LICENSE-ipaddress.txt | 202 -
.../licenses/LICENSE-javax.annotation-api.txt | 759 ----
.../licenses/LICENSE-netty-buffer.txt | 202 -
.../licenses/LICENSE-netty-codec-dns.txt | 202 -
.../licenses/LICENSE-netty-codec-haproxy.txt | 202 -
.../licenses/LICENSE-netty-codec-http.txt | 202 -
.../licenses/LICENSE-netty-codec-http2.txt | 202 -
.../licenses/LICENSE-netty-codec-memcache.txt | 202 -
.../licenses/LICENSE-netty-codec-mqtt.txt | 202 -
.../licenses/LICENSE-netty-codec-redis.txt | 202 -
.../licenses/LICENSE-netty-codec-smtp.txt | 202 -
.../licenses/LICENSE-netty-codec-socks.txt | 202 -
.../licenses/LICENSE-netty-codec-stomp.txt | 202 -
.../licenses/LICENSE-netty-codec-xml.txt | 202 -
.../licenses/LICENSE-netty-codec.txt | 202 -
.../licenses/LICENSE-netty-common.txt | 202 -
.../licenses/LICENSE-netty-handler-proxy.txt | 202 -
.../licenses/LICENSE-netty-handler.txt | 202 -
.../LICENSE-netty-resolver-dns-classes-macos.txt | 202 -
.../LICENSE-netty-resolver-dns-native-macos.txt | 202 -
.../licenses/LICENSE-netty-resolver-dns.txt | 202 -
.../licenses/LICENSE-netty-resolver.txt | 202 -
.../licenses/LICENSE-netty-tcnative-classes.txt | 202 -
.../LICENSE-netty-transport-classes-epoll.txt | 202 -
.../LICENSE-netty-transport-classes-kqueue.txt | 202 -
.../LICENSE-netty-transport-native-epoll.txt | 202 -
.../LICENSE-netty-transport-native-kqueue.txt | 202 -
.../LICENSE-netty-transport-native-unix-common.txt | 202 -
.../licenses/LICENSE-netty-transport-rxtx.txt | 202 -
.../licenses/LICENSE-netty-transport-sctp.txt | 202 -
.../licenses/LICENSE-netty-transport-udt.txt | 202 -
.../licenses/LICENSE-netty-transport.txt | 202 -
.../licenses/LICENSE-opencensus-api.txt | 202 -
.../LICENSE-opencensus-contrib-grpc-metrics.txt | 202 -
.../LICENSE-proto-google-common-protos.txt | 201 -
.../licenses/LICENSE-protobuf-java.txt | 48 -
602 files changed, 7274 insertions(+), 41616 deletions(-)
rename docker/{eventmesh => eventmesh-rocketmq}/Dockerfile (94%)
delete mode 100644 docs/cn/instructions/eventmesh-metrics-Prometheus-instruction.md
delete mode 100644 docs/cn/instructions/eventmesh-runtime-quickstart-with-docker.md
delete mode 100644 docs/cn/instructions/eventmesh-trace-Zipkin-instruction.md
delete mode 100644 docs/en/features/eventmesh-workflow-design.md
delete mode 100644 docs/en/instructions/eventmesh-metrics-Prometheus-instruction.md
delete mode 100644 docs/en/instructions/eventmesh-trace-Zipkin-instruction.md
delete mode 100644 docs/images/Prometheus-download.png
delete mode 100644 docs/images/features/eventmesh-workflow-arch.jpg
delete mode 100644 docs/images/features/eventmesh-workflow-diag.png
delete mode 100644 docs/images/features/eventmesh-workflow-usecase.jpg
delete mode 100644 docs/images/prometheus-yml.png
delete mode 100644 docs/images/promethus-search.png
delete mode 100644 eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.java
delete mode 100644 eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/HttpMethod.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/BatchMessageWrapper.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/ProtocolKey.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/SimpleMessageWrapper.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/StatusCode.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/BatchMessage.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/BatchMessageOrBuilder.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/ConsumerServiceGrpc.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/EventmeshGrpc.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Heartbeat.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/HeartbeatOrBuilder.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/HeartbeatServiceGrpc.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/PublisherServiceGrpc.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/RequestHeader.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/RequestHeaderOrBuilder.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Response.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/ResponseOrBuilder.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SimpleMessage.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SimpleMessageOrBuilder.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Subscription.java
delete mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SubscriptionOrBuilder.java
copy eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/{IPUtilsTest.java => ThreadUtilsTest.java} (52%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/common/ExampleConstants.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsBatchPublishInstance.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsPublishInstance.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsRequestInstance.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/AsyncPublishBroadcast.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/AsyncPublishInstance.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/BatchPublishInstance.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/RequestReplyInstance.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsAsyncSubscribe.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsSubscribeReply.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventmeshAsyncSubscribe.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventmeshSubscribeBroadcast.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventmeshSubscribeReply.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/SpringBootDemoApplication.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/controller/SubController.java
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/service/SubService.java
copy {eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client => eventmesh-examples/src/main/java/org/apache/eventmesh}/tcp/common/EventMeshTestCaseTopicSet.java (96%)
delete mode 100644 eventmesh-metrics-plugin/build.gradle
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-api/build.gradle
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-api/gradle.properties
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/MetricsPluginFactory.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/MetricsRegistry.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/Metric.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/TcpSummaryMetrics.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/build.gradle
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/gradle.properties
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/java/org/apache/eventmesh/metrics/opentelemetry/OpenTelemetryMetricsRegistry.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/java/org/apache/eventmesh/metrics/opentelemetry/config/OpenTelemetryConfiguration.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/java/org/apache/eventmesh/metrics/opentelemetry/metrics/OpenTelemetryHttpExporter.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/java/org/apache/eventmesh/metrics/opentelemetry/metrics/OpenTelemetryTcpExporter.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.metrics.api.MetricsRegistry
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/resources/opentelemetry.properties
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/test/java/org/apache/eventmesh/metrics/opentelemetry/config/OpenTelemetryConfigurationTest.java
delete mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/test/resources/opentelemetry.properties
delete mode 100644 eventmesh-metrics-plugin/gradle.properties
delete mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcMessageProtocolResolver.java
delete mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-grpc/build.gradle
delete mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-grpc/src/main/proto/eventmesh-client.proto
delete mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/grpc/GrpcMessageProtocolResolver.java
rename {eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/resources => eventmesh-runtime/conf}/prometheus.yml (99%)
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcServer.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfiguration.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/EventMeshConsumer.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupClient.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupTopicConfig.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/StreamTopicConfig.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/WebhookTopicConfig.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishMessageProcessor.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/HeartbeatProcessor.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/ReplyMessageProcessor.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/RequestMessageProcessor.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SendAsyncMessageProcessor.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SubscribeProcessor.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SubscribeStreamProcessor.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/UnsubscribeProcessor.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/EventMeshProducer.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/ProducerManager.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/SendMessageContext.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/AbstractPushRequest.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/HandleMsgContext.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/MessageHandler.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/StreamPushRequest.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/WebhookPushRequest.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/DelayRetryable.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/RetryContext.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/EventEmitter.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/HeartbeatService.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ProducerService.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ServiceUtils.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/BytesMessageImpl.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/ConsumeRequest.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/SendResultImpl.java
copy eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/exception/RegistryException.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/exporter/EventMeshExporter.java (70%)
rename eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{trace => exporter}/LogExporter.java (98%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/exporter/ZipkinExporter.java
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/BaseRequestBody.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/GroupMetrics.java (62%)
copy eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/PrototypeExtension.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/HealthMetrics.java (61%)
copy eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/HttpSummaryMetrics.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/SummaryMetrics.java (76%)
rename eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/HttpSummaryMetrics.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/TcpSummaryMetrics.java (67%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/BaseRequestBody.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/TopicMetrics.java (62%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryHTTPMetricsExporter.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryPrometheusExporter.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryTCPMetricsExporter.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/patch/EventMeshConsumeConcurrentlyContext.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/patch/EventMeshMessageListenerConcurrently.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/trace/OpenTelemetryTraceFactory.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/WebhookUtil.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/CSVFormat.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/Data.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/OMSFactoryTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/OMSWriterTest.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/config/EventMeshGrpcClientConfig.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/ReceiveMsgHook.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/EventMeshGrpcProducer.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java
rename eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/GrpcType.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/HandleResult.java (86%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegResponseHeader.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/context/LiteConsumeContext.java (56%)
copy eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeaderTest.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/listener/LiteMessageListener.java (66%)
delete mode 100644 eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/auth/AuthService.java
delete mode 100644 eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/common/ConfigurationWrapper.java
delete mode 100644 eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/exception/AuthException.java
delete mode 100644 eventmesh-security-plugin/eventmesh-security-auth-http-basic/build.gradle
delete mode 100644 eventmesh-security-plugin/eventmesh-security-auth-http-basic/gradle.properties
delete mode 100644 eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/java/org/apache/eventmesh/auth/http/basic/config/AuthConfigs.java
delete mode 100644 eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/java/org/apache/eventmesh/auth/http/basic/impl/AuthHttpBasicService.java
delete mode 100644 eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.auth.AuthService
delete mode 100644 eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/resources/auth-http-basic.properties
delete mode 100644 eventmesh-trace-plugin/build.gradle
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-api/build.gradle
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-api/gradle.properties
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/TracePluginFactory.java
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/TraceService.java
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/config/ExporterConfiguration.java
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-api/src/main/resources/exporter.properties
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-zipkin/build.gradle
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-zipkin/gradle.properties
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/ZipkinTraceService.java
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/config/ZipkinConfiguration.java
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.trace.api.TraceService
delete mode 100644 eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/resources/zipkin.properties
delete mode 100644 eventmesh-trace-plugin/gradle.properties
delete mode 100644 tool/license/allowed-licenses.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-grpc-context.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-grpc-core.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-grpc-netty-shaded.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-grpc-netty.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-grpc-protobuf-lite.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-grpc-protobuf.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-grpc-stub.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-gson.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-ipaddress.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-javax.annotation-api.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-buffer.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-dns.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-haproxy.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-http.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-http2.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-memcache.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-mqtt.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-redis.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-smtp.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-socks.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-stomp.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec-xml.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-codec.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-common.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-handler-proxy.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-handler.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-resolver-dns-classes-macos.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-resolver-dns-native-macos.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-resolver-dns.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-resolver.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-tcnative-classes.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport-classes-epoll.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport-classes-kqueue.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport-native-epoll.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport-native-kqueue.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport-native-unix-common.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport-rxtx.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport-sctp.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport-udt.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-transport.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-opencensus-api.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-opencensus-contrib-grpc-metrics.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-proto-google-common-protos.txt
delete mode 100644 tools/third-party-licenses/licenses/LICENSE-protobuf-java.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org