This is an automated email from the ASF dual-hosted git repository. mikexue pushed a commit to branch eventmesh-function in repository https://gitbox.apache.org/repos/asf/eventmesh.git
commit f720bc062a2fcca4fa2df763037f17d19f829969 Merge: 3215b4e13 04d0c5492 Author: xwm1992 <[email protected]> AuthorDate: Wed May 29 13:16:38 2024 +0800 fix conflicts with master .asf.yaml | 6 +- .github/dependabot.yml | 42 +- .../workflows/auto-dependabot.yml | 32 +- .github/workflows/ci.yml | 61 +- .github/workflows/code-scanning.yml | 74 + .github/workflows/codeql.yml | 69 - .github/workflows/docker.yml | 49 - .github/workflows/greetings.yml | 2 +- .../workflows/license.yml | 36 +- .github/workflows/stale.yml | 28 +- .gitignore | 4 +- .licenserc.yaml | 1 + build.gradle | 561 +++-- docker/Dockerfile_jdk11 | 27 +- docker/Dockerfile_jdk8 | 27 +- eventmesh-common/build.gradle | 9 +- .../apache/eventmesh/common/MetricsConstants.java | 65 + .../java/org/apache/eventmesh}/common/Pair.java | 31 +- .../apache/eventmesh/common/config/ConfigInfo.java | 4 +- .../apache/eventmesh/common/config/FileLoad.java | 10 +- .../eventmesh/common/enums/ProtocolType.java | 7 + .../apache/eventmesh/common/utils/JsonUtils.java | 2 +- .../build.gradle | 53 +- .../eventmesh-connector-chatgpt/gradle.properties | 2 + .../chatgpt/config/ChatGPTServerConfig.java | 14 +- .../chatgpt/server/ChatGPTConnectServer.java} | 14 +- .../chatgpt/source/config/ChatGPTSourceConfig.java | 18 +- .../config/ChatGPTSourceConnectorConfig.java | 19 +- .../chatgpt/source/config/OpenaiConfig.java | 25 +- .../chatgpt/source/config/OpenaiProxyConfig.java | 11 +- .../source/connector/ChatGPTSourceConnector.java | 252 ++ .../chatgpt/source/dto/ChatGPTRequestDTO.java | 50 +- .../chatgpt/source/enums/ChatGPTRequestType.java | 8 + .../chatgpt/source/handlers/ChatHandler.java | 69 + .../chatgpt/source/handlers/ParseHandler.java | 134 ++ .../chatgpt/source/managers/OpenaiManager.java | 131 ++ .../src/main/resources/prompt | 44 + .../src/main/resources/server-config.yml | 3 + .../src/main/resources/source-config.yml | 41 +- .../connector/ChatGPTSourceConnectorTest.java | 166 ++ .../src/test/resources/server-config.yml | 3 + .../src/test/resources/source-config.yml | 42 +- .../eventmesh-connector-http/build.gradle | 9 +- .../connector/http/server/HttpConnectServer.java | 4 +- .../connector/http/sink/HttpSinkConnector.java | 124 + .../http/sink/config/HttpRetryConfig.java | 18 +- .../connector/http/sink/config/HttpSinkConfig.java | 12 +- .../http/sink/config/HttpWebhookConfig.java | 22 +- .../http/sink/config/SinkConnectorConfig.java | 73 + .../http/sink/data/HttpConnectRecord.java | 67 + .../http/sink/data/HttpExportMetadata.java | 27 +- .../connector/http/sink/data/HttpExportRecord.java | 11 +- .../http/sink/data/HttpExportRecordPage.java | 16 +- .../http/sink/handle/CommonHttpSinkHandler.java | 181 ++ .../http/sink/handle/HttpSinkHandler.java | 74 + .../http/sink/handle/RetryHttpSinkHandler.java | 206 ++ .../http/sink/handle/WebhookHttpSinkHandler.java | 348 +++ .../eventmesh/connector/http/util/HttpUtils.java | 20 +- .../src/main/resources/sink-config.yml | 35 +- .../source/connector/HttpSinkConnectorTest.java | 170 ++ .../src/test/resources/sink-config.yml | 35 +- .../eventmesh-connector-jdbc/build.gradle | 8 +- .../eventmesh-connector-kafka/build.gradle | 6 +- .../eventmesh-connector-mongodb/build.gradle | 2 +- .../eventmesh-connector-pravega/build.gradle | 5 - .../eventmesh-connector-pulsar/build.gradle | 23 +- .../eventmesh-connector-rabbitmq/build.gradle | 7 +- .../eventmesh-connector-rocketmq/build.gradle | 11 +- .../eventmesh-connector-slack/build.gradle | 8 +- .../eventmesh-connector-spring/build.gradle | 21 +- .../eventmesh-connector-wechat/build.gradle | 6 - .../eventmesh-connector-wecom/build.gradle | 6 - eventmesh-examples/build.gradle | 10 +- .../eventmesh-meta-zookeeper/build.gradle | 10 +- .../eventmesh-metrics-api/build.gradle | 3 + .../eventmesh/metrics/api/MetricsRegistry.java | 15 + .../metrics/api/model/AbstractMetric.java | 39 +- ...cs.java => AbstractObservableDoubleMetric.java} | 33 +- ...rics.java => AbstractObservableLongMetric.java} | 32 +- .../api/model/AbstractObservableMetric.java | 64 + ...SummaryMetrics.java => AbstractSyncMetric.java} | 13 +- .../metrics/api/model/DoubleCounterMetric.java | 57 + .../metrics/api/model/DoubleHistogramMetric.java | 57 + .../api/model/DoubleUpDownCounterMetric.java | 57 + .../metrics/api/model/GrpcSummaryMetrics.java | 105 - .../metrics/api/model/HttpSummaryMetrics.java | 436 ---- ...ySummaryMetrics.java => InstrumentFurther.java} | 25 +- .../metrics/api/model/InstrumentType.java | 57 + .../metrics/api/model/LongCounterMetric.java | 57 + .../metrics/api/model/LongHistogramMetric.java | 57 + .../metrics/api/model/LongUpDownCounterMetric.java | 57 + .../apache/eventmesh/metrics/api/model/Metric.java | 27 + .../metrics/api/model/NoopDoubleCounter.java | 64 + .../metrics/api/model/NoopDoubleHistogram.java | 64 + .../metrics/api/model/NoopDoubleUpDownCounter.java | 64 + .../metrics/api/model/NoopLongCounter.java | 64 + .../metrics/api/model/NoopLongHistogram.java | 64 + .../metrics/api/model/NoopLongUpDownCounter.java | 64 + ...ics.java => ObservableDoubleCounterMetric.java} | 25 +- ...trics.java => ObservableDoubleGaugeMetric.java} | 21 +- ...va => ObservableDoubleUpDownCounterMetric.java} | 22 +- ...trics.java => ObservableLongCounterMetric.java} | 24 +- ...Metrics.java => ObservableLongGaugeMetric.java} | 25 +- ...java => ObservableLongUpDownCounterMetric.java} | 23 +- .../metrics/api/model/ObservableMetric.java | 56 + .../eventmesh/metrics/api/model/SyncMetric.java} | 11 +- .../metrics/api/model/TcpSummaryMetrics.java | 140 -- .../metrics/api/model/GrpcSummaryMetricsTest.java | 42 - .../eventmesh-metrics-prometheus/build.gradle | 11 +- .../prometheus/OpenTelemetryPrometheusManager.java | 51 + .../prometheus/PrometheusMetricsRegistry.java | 69 +- .../PrometheusMetricsRegistryManager.java | 278 +++ .../prometheus/config/PrometheusConfiguration.java | 3 + .../prometheus/metrics/PrometheusGrpcExporter.java | 60 - .../prometheus/metrics/PrometheusHttpExporter.java | 120 - .../prometheus/metrics/PrometheusTcpExporter.java | 69 - .../prometheus/utils/PrometheusExporterUtils.java | 76 - .../eventmesh-openconnect-java/build.gradle | 4 +- .../build.gradle | 6 +- .../build.gradle | 4 +- .../eventmesh-protocol-cloudevents/build.gradle | 2 +- .../eventmesh-protocol-grpc/build.gradle | 4 +- .../eventmesh-protocol-http/build.gradle | 2 +- .../eventmesh-protocol-meshmessage/build.gradle | 2 +- .../eventmesh-retry-rocketmq/build.gradle | 10 +- .../runtime/admin/handler/AbstractHttpHandler.java | 57 +- .../runtime/admin/handler/AdminHandlerManager.java | 6 +- .../runtime/admin/handler/v1/MetricsHandler.java | 111 - .../admin/handler/v2/ConfigurationHandler.java | 80 +- .../admin/response/v1/GetMetricsResponse.java | 99 +- .../response/v2/GetConfigurationResponse.java | 3 + .../eventmesh/runtime/boot/AbstractHTTPServer.java | 23 +- .../eventmesh/runtime/boot/AbstractTCPServer.java | 24 +- .../runtime/boot/EventMeshGrpcServer.java | 23 +- .../runtime/boot/EventMeshHTTPServer.java | 10 +- .../eventmesh/runtime/boot/EventMeshServer.java | 43 + .../eventmesh/runtime/boot/EventMeshTCPServer.java | 11 +- .../runtime/constants/EventMeshVersion.java | 136 +- .../protocol/grpc/consumer/EventMeshConsumer.java | 2 +- .../processor/BatchPublishCloudEventProcessor.java | 2 +- .../processor/PublishCloudEventsProcessor.java | 4 +- .../grpc/processor/ReplyMessageProcessor.java | 2 +- .../grpc/processor/RequestCloudEventProcessor.java | 6 +- .../protocol/grpc/service/ConsumerService.java | 9 +- .../protocol/grpc/service/PublisherService.java | 9 +- .../http/processor/BatchSendMessageProcessor.java | 4 +- .../processor/BatchSendMessageV2Processor.java | 4 +- .../http/processor/CreateTopicProcessor.java | 6 +- .../http/processor/DeleteTopicProcessor.java | 13 +- .../protocol/http/processor/HandlerService.java | 16 +- .../http/processor/HeartBeatProcessor.java | 10 +- .../http/processor/QuerySubscriptionProcessor.java | 6 +- .../http/processor/ReplyMessageProcessor.java | 9 +- .../http/processor/SendAsyncEventProcessor.java | 5 +- .../http/processor/SendAsyncMessageProcessor.java | 4 +- .../processor/SendAsyncRemoteEventProcessor.java | 5 +- .../http/processor/SendSyncMessageProcessor.java | 7 +- .../http/processor/SubscribeProcessor.java | 11 +- .../http/processor/UnSubscribeProcessor.java | 4 +- .../protocol/http/push/AsyncHTTPPushRequest.java | 6 +- .../protocol/tcp/client/EventMeshTcp2Client.java | 7 +- .../tcp/client/group/ClientGroupWrapper.java | 24 +- .../core/protocol/tcp/client/session/Session.java | 6 +- .../tcp/client/session/push/SessionPusher.java | 8 +- .../tcp/client/session/send/SessionSender.java | 11 +- .../runtime/metrics/EventMeshMetricsManager.java | 128 + .../eventmesh/runtime/metrics/GeneralMetrics.java | 81 + .../runtime/metrics/MetricInstrumentUnit.java | 20 +- .../eventmesh/runtime/metrics/MetricsManager.java | 33 +- .../eventmesh/runtime/metrics/MetricsUtils.java | 110 + .../runtime/metrics/MonitorMetricConstants.java | 2 + .../metrics/grpc/EventMeshGrpcMetricsManager.java | 148 ++ .../runtime/metrics/grpc/EventMeshGrpcMonitor.java | 96 - .../runtime/metrics/grpc/GrpcMetrics.java | 263 +++ .../metrics/http/EventMeshHttpMetricsManager.java | 242 ++ .../runtime/metrics/http/HTTPMetricsServer.java | 165 -- .../runtime/metrics/http/HttpMetrics.java | 827 +++++++ .../metrics/tcp/EventMeshTcpMetricsManager.java | 130 ++ .../runtime/metrics/tcp/EventMeshTcpMonitor.java | 186 -- .../eventmesh/runtime/metrics/tcp/TcpMetrics.java | 280 +++ .../runtime/metrics/tcp/TcpMetricsCalculator.java | 134 ++ .../apache/eventmesh/runtime/util/BannerUtil.java | 15 +- .../org/apache/eventmesh/runtime/util/Utils.java | 3 +- eventmesh-sdks/eventmesh-sdk-go/.golangci.yml | 25 +- eventmesh-sdks/eventmesh-sdk-java/build.gradle | 8 +- .../eventmesh/client/tcp/common/MessageUtils.java | 5 +- .../eventmesh/client/tcp/common/TcpClient.java | 9 +- .../impl/cloudevent/CloudEventTCPSubClient.java | 1 - eventmesh-sdks/eventmesh-sdk-rust/Cargo.toml | 28 +- .../eventmesh-storage-kafka/build.gradle | 8 +- .../org.apache.io.openmessaging.producer.Producer | 27 +- .../eventmesh-storage-pulsar/build.gradle | 25 +- .../eventmesh-storage-rabbitmq/build.gradle | 9 +- .../eventmesh-storage-redis/build.gradle | 4 - .../eventmesh-storage-rocketmq/build.gradle | 17 +- .../org.apache.io.openmessaging.producer.Producer | 27 +- gradle/wrapper/gradle-wrapper.properties | 2 +- settings.gradle | 3 +- style/checkStyle.xml | 26 +- style/checkstyle-header-c.txt | 14 + ...tyle-header1.txt => checkstyle-header-java.txt} | 0 ...yle-header3.txt => checkstyle-header-shell.txt} | 0 style/checkstyle-header-xml.txt | 17 + ...tyle-header2.txt => checkstyle-header-yaml.txt} | 0 tools/dependency-check/check-dependencies.sh | 56 - tools/dependency-check/known-dependencies.txt | 360 --- tools/dist-license/LICENSE | 598 +++++ tools/dist-license/NOTICE | 2467 ++++++++++++++++++++ .../go/LICENSE-github.com-cespare-xxhash-v2.txt | 0 .../go/LICENSE-github.com-cespare-xxhash.txt | 0 .../LICENSE-github.com-cloudevents-sdk-go-v2.txt | 0 .../licenses/go/LICENSE-github.com-google-uuid.txt | 0 .../go/LICENSE-github.com-json-iterator-go.txt | 0 .../go/LICENSE-github.com-panjf2000-ants.txt | 0 .../go/LICENSE-github.com-sony-sonyflake.txt | 0 .../go/LICENSE-github.com-stretchr-testify.txt | 0 .../licenses/go/LICENSE-go.uber.org-atomic.txt | 0 .../licenses/go/LICENSE-go.uber.org-zap.txt | 0 .../licenses/go/LICENSE-google.golang.org-grpc.txt | 0 .../go/LICENSE-google.golang.org-protobuf.txt | 0 .../java/AL 2.0-downloaded-LICENSE-2.0.html | 523 +++++ tools/dist-license/licenses/java/AL 2.0.txt | 1 + .../ASL, version 2-downloaded-LICENSE-2.0.txt} | 0 .../dist-license/licenses/java/ASL, version 2.txt | 1 + tools/dist-license/licenses/java/Apache-1.1.txt | 21 + tools/dist-license/licenses/java/Apache-2.0.txt | 73 + .../java/BSD licence-downloaded-license.html | 128 + tools/dist-license/licenses/java/BSD licence.txt | 1 + tools/dist-license/licenses/java/BSD-2-Clause.txt | 9 + tools/dist-license/licenses/java/BSD-3-Clause.txt | 11 + tools/dist-license/licenses/java/BSD-4-Clause.txt | 14 + .../Bouncy Castle Licence-downloaded-licence.html | 107 + .../licenses/java/Bouncy Castle Licence.txt | 1 + tools/dist-license/licenses/java/CC0-1.0.txt | 121 + tools/dist-license/licenses/java/CDDL-1.0.txt | 119 + tools/dist-license/licenses/java/CDDL-1.1.txt | 123 + tools/dist-license/licenses/java/EPL-1.0.txt | 73 + tools/dist-license/licenses/java/EPL-2.0.txt | 80 + .../GNU General Public Library-downloaded-gpl.txt} | 2 +- .../licenses/java/GNU General Public Library.txt | 1 + .../licenses/java/GPL v2-downloaded-gpl-2.0.txt | 339 +++ tools/dist-license/licenses/java/GPL v2.txt | 1 + .../java/GPL-2.0-with-classpath-exception.txt | 1 + ...re License, vesion 1.1.1-downloaded-LICENSE.txt | 2 + ...Extreme! Lab Software License, vesion 1.1.1.txt | 1 + .../LGPL, version 2.1-downloaded-licenses.html | 781 +++++++ .../licenses/java/LGPL, version 2.1.txt | 1 + tools/dist-license/licenses/java/LGPL-2.1-only.txt | 175 ++ .../licenses/java/MIT.txt} | 10 +- tools/dist-license/licenses/java/MPL-1.1.txt | 143 ++ .../licenses/java/MPL-2.0.txt} | 191 +- tools/dist-license/licenses/java/Public Domain.txt | 1 + .../licenses/java/Unicode-ICU License.txt | 1 + tools/third-party-licenses/LICENSE | 511 ---- tools/third-party-licenses/NOTICE | 1083 --------- .../licenses/java/LICENSE-ST4.txt | 28 - .../java/LICENSE-alibabacloud-gateway-spi.txt | 202 -- .../licenses/java/LICENSE-amqp-client.txt | 15 - .../java/LICENSE-animal-sniffer-annotations.txt | 21 - .../licenses/java/LICENSE-annotations.txt | 201 -- .../licenses/java/LICENSE-antlr4-runtime.txt | 28 - .../licenses/java/LICENSE-arns.txt | 202 -- .../licenses/java/LICENSE-asm-commons.txt | 28 - .../licenses/java/LICENSE-asm-tree.txt | 28 - .../licenses/java/LICENSE-asm-util.txt | 28 - .../licenses/java/LICENSE-asm.txt | 28 - .../licenses/java/LICENSE-assertj-core.txt | 202 -- .../java/LICENSE-async-http-client-netty-utils.txt | 202 -- .../licenses/java/LICENSE-async-http-client.txt | 202 -- .../licenses/java/LICENSE-auth.txt | 202 -- .../licenses/java/LICENSE-aws-core.txt | 202 -- .../licenses/java/LICENSE-aws-query-protocol.txt | 202 -- .../licenses/java/LICENSE-aws-xml-protocol.txt | 202 -- .../licenses/java/LICENSE-bcpkix-jdk15on.txt | 22 - .../licenses/java/LICENSE-bcprov-ext-jdk15on.txt | 22 - .../licenses/java/LICENSE-bcprov-jdk15on.txt | 22 - .../licenses/java/LICENSE-bcutil-jdk15on.txt | 22 - .../licenses/java/LICENSE-bolt.txt | 202 -- .../licenses/java/LICENSE-byte-buddy.txt | 201 -- .../licenses/java/LICENSE-cache-api.txt | 202 -- .../licenses/java/LICENSE-checker-qual.txt | 413 ---- .../licenses/java/LICENSE-classmate.txt | 202 -- .../licenses/java/LICENSE-cloudevents-api.txt | 203 -- .../licenses/java/LICENSE-cloudevents-core.txt | 203 -- .../java/LICENSE-cloudevents-json-jackson.txt | 203 -- .../licenses/java/LICENSE-cloudevents-kafka.txt | 203 -- .../licenses/java/LICENSE-commons-beanutils.txt | 202 -- .../licenses/java/LICENSE-commons-cli.txt | 202 -- .../licenses/java/LICENSE-commons-codec.txt | 202 -- .../licenses/java/LICENSE-commons-collections.txt | 202 -- .../licenses/java/LICENSE-commons-collections4.txt | 202 -- .../licenses/java/LICENSE-commons-digester.txt | 202 -- .../licenses/java/LICENSE-commons-io.txt | 202 -- .../licenses/java/LICENSE-commons-lang3.txt | 202 -- .../licenses/java/LICENSE-commons-logging.txt | 202 -- .../licenses/java/LICENSE-commons-text.txt | 202 -- .../licenses/java/LICENSE-commons-validator.txt | 202 -- .../licenses/java/LICENSE-consul-api.txt | 201 -- .../licenses/java/LICENSE-credentials-java.txt | 202 -- .../licenses/java/LICENSE-crt-core.txt | 202 -- .../licenses/java/LICENSE-curator-client.txt | 202 -- .../licenses/java/LICENSE-curator-framework.txt | 202 -- .../licenses/java/LICENSE-curator-recipes.txt | 202 -- .../licenses/java/LICENSE-dingtalk.txt | 202 -- .../licenses/java/LICENSE-disruptor.txt | 201 -- .../licenses/java/LICENSE-dledger.txt | 203 -- .../licenses/java/LICENSE-dom4j.txt | 39 - .../licenses/java/LICENSE-endpoint-util.txt | 202 -- .../licenses/java/LICENSE-endpoints-spi.txt | 202 -- .../java/LICENSE-error_prone_annotations.txt | 202 -- .../licenses/java/LICENSE-eventstream.txt | 202 -- .../licenses/java/LICENSE-failureaccess.txt | 202 -- .../licenses/java/LICENSE-fastjson.txt | 201 -- .../licenses/java/LICENSE-gateway-dingtalk.txt | 202 -- .../LICENSE-google-auth-library-credentials.txt | 48 - .../licenses/java/LICENSE-grpc-api.txt | 242 -- .../licenses/java/LICENSE-grpc-auth.txt | 242 -- .../licenses/java/LICENSE-grpc-context.txt | 242 -- .../licenses/java/LICENSE-grpc-core.txt | 242 -- .../licenses/java/LICENSE-grpc-grpclb.txt | 242 -- .../licenses/java/LICENSE-grpc-netty-shaded.txt | 242 -- .../licenses/java/LICENSE-grpc-netty.txt | 242 -- .../licenses/java/LICENSE-grpc-protobuf-lite.txt | 242 -- .../licenses/java/LICENSE-grpc-protobuf.txt | 242 -- .../licenses/java/LICENSE-grpc-stub.txt | 242 -- .../licenses/java/LICENSE-gson.txt | 202 -- .../licenses/java/LICENSE-guava.txt | 202 -- .../licenses/java/LICENSE-guice.txt | 202 -- .../licenses/java/LICENSE-hamcrest-core.txt | 27 - .../licenses/java/LICENSE-hibernate-validator.txt | 202 -- .../licenses/java/LICENSE-http-client-spi.txt | 202 -- .../licenses/java/LICENSE-httpasyncclient.txt | 201 -- .../licenses/java/LICENSE-httpcore-nio.txt | 202 -- .../licenses/java/LICENSE-httpcore.txt | 177 -- .../licenses/java/LICENSE-httpmime.txt | 202 -- .../licenses/java/LICENSE-icu4j.txt | 512 ---- .../licenses/java/LICENSE-ini4j.txt | 202 -- .../licenses/java/LICENSE-ipaddress.txt | 202 -- .../licenses/java/LICENSE-j2objc-annotations.txt | 232 -- .../licenses/java/LICENSE-jackson-annotations.txt | 202 -- .../licenses/java/LICENSE-jackson-core.txt | 202 -- .../licenses/java/LICENSE-jackson-databind.txt | 202 -- .../licenses/java/LICENSE-jackson-jr-objects.txt | 202 -- .../java/LICENSE-jakarta.annotation-api.txt | 277 --- .../java/LICENSE-jakarta.validation-api.txt | 277 --- .../licenses/java/LICENSE-javassist.txt | 141 -- .../licenses/java/LICENSE-javax.activation.txt | 759 ------ .../licenses/java/LICENSE-javax.annotation-api.txt | 759 ------ .../licenses/java/LICENSE-javax.inject-1.txt | 202 -- .../licenses/java/LICENSE-javax.ws.rs-api.txt | 759 ------ .../licenses/java/LICENSE-jaxb-api.txt | 274 --- .../licenses/java/LICENSE-jaxb-core.txt | 274 --- .../licenses/java/LICENSE-jaxb-impl.txt | 274 --- .../licenses/java/LICENSE-jaxen.txt | 33 - .../licenses/java/LICENSE-jboss-logging.txt | 202 -- .../java/LICENSE-jboss-marshalling-river.txt | 202 -- .../licenses/java/LICENSE-jboss-marshalling.txt | 202 -- .../licenses/java/LICENSE-jcip-annotations.txt | 202 -- .../licenses/java/LICENSE-jcommander.txt | 202 -- .../licenses/java/LICENSE-jetcd-common.txt | 202 -- .../licenses/java/LICENSE-jetcd-core.txt | 202 -- .../licenses/java/LICENSE-jetcd-resolver.txt | 202 -- .../licenses/java/LICENSE-jline.txt | 32 - .../licenses/java/LICENSE-jna.txt | 26 - .../licenses/java/LICENSE-jodd-bean.txt | 25 - .../licenses/java/LICENSE-jodd-core.txt | 24 - .../licenses/java/LICENSE-json-path.txt | 202 -- .../licenses/java/LICENSE-json-smart.txt | 202 -- .../licenses/java/LICENSE-json-utils.txt | 202 -- .../licenses/java/LICENSE-jsr305.txt | 28 - .../licenses/java/LICENSE-jul-to-slf4j.txt | 25 - .../licenses/java/LICENSE-junit.txt | 213 -- .../licenses/java/LICENSE-kafka-client.txt | 203 -- .../licenses/java/LICENSE-listenablefuture.txt | 202 -- .../licenses/java/LICENSE-log4j-api.txt | 202 -- .../licenses/java/LICENSE-log4j-core.txt | 202 -- .../licenses/java/LICENSE-log4j-slf4j-impl.txt | 202 -- .../licenses/java/LICENSE-log4j-slf4j2-impl.txt | 202 -- .../licenses/java/LICENSE-logback-core.txt | 14 - .../licenses/java/LICENSE-lz4-java.txt | 203 -- .../licenses/java/LICENSE-metrics-annotation.txt | 202 -- .../licenses/java/LICENSE-metrics-core.txt | 202 -- .../licenses/java/LICENSE-metrics-healthchecks.txt | 202 -- .../licenses/java/LICENSE-metrics-json.txt | 202 -- .../licenses/java/LICENSE-metrics-spi.txt | 202 -- .../licenses/java/LICENSE-mongodb-driver-core.txt | 202 -- .../licenses/java/LICENSE-mongodb-driver.txt | 202 -- .../java/LICENSE-mysql-binlog-connector-java.txt | 202 -- .../licenses/java/LICENSE-mysql-connector-j.txt | 1386 ----------- .../licenses/java/LICENSE-nacos-auth-plugin.txt | 201 -- .../licenses/java/LICENSE-nacos-client.txt | 201 -- .../java/LICENSE-nacos-encryption-plugin.txt | 201 -- .../licenses/java/LICENSE-netty-all.txt | 202 -- .../licenses/java/LICENSE-netty-buffer.txt | 202 -- .../licenses/java/LICENSE-netty-codec-dns.txt | 202 -- .../licenses/java/LICENSE-netty-codec-haproxy.txt | 202 -- .../licenses/java/LICENSE-netty-codec-http.txt | 202 -- .../licenses/java/LICENSE-netty-codec-http2.txt | 202 -- .../licenses/java/LICENSE-netty-codec-memcache.txt | 202 -- .../licenses/java/LICENSE-netty-codec-mqtt.txt | 202 -- .../licenses/java/LICENSE-netty-codec-redis.txt | 202 -- .../licenses/java/LICENSE-netty-codec-smtp.txt | 202 -- .../licenses/java/LICENSE-netty-codec-socks.txt | 202 -- .../licenses/java/LICENSE-netty-codec-stomp.txt | 202 -- .../licenses/java/LICENSE-netty-codec-xml.txt | 202 -- .../licenses/java/LICENSE-netty-codec.txt | 202 -- .../licenses/java/LICENSE-netty-common.txt | 202 -- .../licenses/java/LICENSE-netty-handler-proxy.txt | 202 -- .../licenses/java/LICENSE-netty-handler.txt | 202 -- .../licenses/java/LICENSE-netty-nio-client.txt | 202 -- .../java/LICENSE-netty-reactive-streams.txt | 202 -- .../LICENSE-netty-resolver-dns-classes-macos.txt | 202 -- .../LICENSE-netty-resolver-dns-native-macos.txt | 202 -- .../licenses/java/LICENSE-netty-resolver-dns.txt | 202 -- .../licenses/java/LICENSE-netty-resolver.txt | 202 -- .../LICENSE-netty-tcnative-boringssl-static.txt | 202 -- .../java/LICENSE-netty-tcnative-classes.txt | 202 -- .../java/LICENSE-netty-transport-classes-epoll.txt | 202 -- .../LICENSE-netty-transport-classes-kqueue.txt | 202 -- .../java/LICENSE-netty-transport-native-epoll.txt | 202 -- .../java/LICENSE-netty-transport-native-kqueue.txt | 202 -- .../LICENSE-netty-transport-native-unix-common.txt | 202 -- .../licenses/java/LICENSE-netty-transport-rxtx.txt | 202 -- .../licenses/java/LICENSE-netty-transport-sctp.txt | 202 -- .../licenses/java/LICENSE-netty-transport-udt.txt | 202 -- .../licenses/java/LICENSE-netty-transport.txt | 202 -- .../licenses/java/LICENSE-oapi-sdk.txt | 203 -- .../licenses/java/LICENSE-okhttp.txt | 202 -- .../licenses/java/LICENSE-okio.txt | 202 -- .../licenses/java/LICENSE-openapiutil.txt | 202 -- .../licenses/java/LICENSE-opencensus-api.txt | 202 -- .../LICENSE-opencensus-contrib-grpc-metrics.txt | 202 -- .../licenses/java/LICENSE-openmessaging-api.txt | 202 -- .../java/LICENSE-opentelemetry-api-metrics.txt | 202 -- .../licenses/java/LICENSE-opentelemetry-api.txt | 202 -- .../java/LICENSE-opentelemetry-context.txt | 202 -- .../java/LICENSE-opentelemetry-exporter-jaeger.txt | 202 -- .../LICENSE-opentelemetry-exporter-prometheus.txt | 202 -- .../java/LICENSE-opentelemetry-exporter-zipkin.txt | 202 -- .../java/LICENSE-opentelemetry-sdk-common.txt | 202 -- .../java/LICENSE-opentelemetry-sdk-metrics.txt | 202 -- .../java/LICENSE-opentelemetry-sdk-trace.txt | 202 -- .../licenses/java/LICENSE-opentelemetry-sdk.txt | 202 -- .../java/LICENSE-opentelemetry-semconv.txt | 202 -- .../java/LICENSE-org.abego.treelayout.core.txt | 28 - .../licenses/java/LICENSE-org.jacoco.agent.txt | 277 --- .../licenses/java/LICENSE-perfmark-api.txt | 202 -- .../licenses/java/LICENSE-pinpoint-annotations.txt | 202 -- .../java/LICENSE-pinpoint-bootstrap-core.txt | 202 -- .../licenses/java/LICENSE-pinpoint-bootstrap.txt | 202 -- .../java/LICENSE-pinpoint-commons-buffer.txt | 202 -- .../java/LICENSE-pinpoint-commons-profiler.txt | 202 -- .../licenses/java/LICENSE-pinpoint-commons.txt | 202 -- .../licenses/java/LICENSE-pinpoint-grpc.txt | 202 -- .../licenses/java/LICENSE-pinpoint-profiler.txt | 202 -- .../licenses/java/LICENSE-pinpoint-rpc.txt | 202 -- .../licenses/java/LICENSE-pravega-client.txt | 202 -- .../licenses/java/LICENSE-pravega-common.txt | 202 -- .../java/LICENSE-pravega-shared-authplugin.txt | 202 -- .../java/LICENSE-pravega-shared-controller-api.txt | 202 -- .../java/LICENSE-pravega-shared-protocol.txt | 202 -- .../java/LICENSE-pravega-shared-security.txt | 202 -- .../licenses/java/LICENSE-profiles.txt | 202 -- .../java/LICENSE-proto-google-common-protos.txt | 201 -- .../licenses/java/LICENSE-protobuf-java-util.txt | 48 - .../licenses/java/LICENSE-protobuf-java.txt | 48 - .../licenses/java/LICENSE-protocol-core.txt | 202 -- .../licenses/java/LICENSE-pull-parser.txt | 202 -- .../java/LICENSE-pulsar-client-admin-api.txt | 239 -- .../licenses/java/LICENSE-pulsar-client-api.txt | 239 -- .../licenses/java/LICENSE-pulsar-client.txt | 239 -- .../licenses/java/LICENSE-reactor-core.txt | 201 -- .../licenses/java/LICENSE-redisson.txt | 13 - .../licenses/java/LICENSE-reflections.txt | 202 -- .../licenses/java/LICENSE-rocketmq-acl.txt | 201 -- .../licenses/java/LICENSE-rocketmq-broker.txt | 201 -- .../licenses/java/LICENSE-rocketmq-client.txt | 201 -- .../licenses/java/LICENSE-rocketmq-common.txt | 201 -- .../licenses/java/LICENSE-rocketmq-filter.txt | 201 -- .../licenses/java/LICENSE-rocketmq-logging.txt | 201 -- .../licenses/java/LICENSE-rocketmq-namesrv.txt | 201 -- .../licenses/java/LICENSE-rocketmq-remoting.txt | 201 -- .../licenses/java/LICENSE-rocketmq-srvutil.txt | 201 -- .../licenses/java/LICENSE-rocketmq-store.txt | 201 -- .../licenses/java/LICENSE-rocketmq-test.txt | 201 -- .../licenses/java/LICENSE-rocketmq-tools.txt | 201 -- .../licenses/java/LICENSE-runtime.txt | 28 - .../licenses/java/LICENSE-rxjava.txt | 201 -- .../licenses/java/LICENSE-s3.txt | 202 -- .../licenses/java/LICENSE-sdk-core.txt | 202 -- .../licenses/java/LICENSE-simpleclient.txt | 201 -- .../licenses/java/LICENSE-simpleclient_common.txt | 201 -- .../java/LICENSE-simpleclient_httpserver.txt | 201 -- .../licenses/java/LICENSE-slack-api-client.txt | 202 -- .../licenses/java/LICENSE-slack-api-model.txt | 202 -- .../licenses/java/LICENSE-slack-app-backend.txt | 202 -- .../licenses/java/LICENSE-slf4j-api.txt | 21 - .../licenses/java/LICENSE-slf4j-simple.txt | 21 - .../licenses/java/LICENSE-snakeyaml.txt | 203 -- .../licenses/java/LICENSE-snappy-java.txt | 203 -- .../licenses/java/LICENSE-spring-aop.txt | 202 -- .../licenses/java/LICENSE-spring-beans.txt | 202 -- .../java/LICENSE-spring-boot-autoconfigure.txt | 202 -- .../java/LICENSE-spring-boot-starter-logging.txt | 202 -- .../LICENSE-spring-boot-starter-validation.txt | 202 -- .../licenses/java/LICENSE-spring-boot-starter.txt | 202 -- .../licenses/java/LICENSE-spring-boot.txt | 202 -- .../licenses/java/LICENSE-spring-context.txt | 202 -- .../licenses/java/LICENSE-spring-core.txt | 202 -- .../licenses/java/LICENSE-spring-expression.txt | 202 -- .../licenses/java/LICENSE-spring-jcl.txt | 202 -- .../licenses/java/LICENSE-spring-messaging.txt | 202 -- .../licenses/java/LICENSE-system-rules.txt | 213 -- .../licenses/java/LICENSE-tea-openapi.txt | 202 -- .../licenses/java/LICENSE-tea-util.txt | 202 -- .../licenses/java/LICENSE-tea-xml.txt | 202 -- .../licenses/java/LICENSE-tea.txt | 202 -- .../java/LICENSE-third-party-jackson-core.txt | 202 -- .../licenses/java/LICENSE-tomcat-embed-el.txt | 202 -- .../licenses/java/LICENSE-truth.txt | 202 -- .../licenses/java/LICENSE-utils.txt | 202 -- .../licenses/java/LICENSE-validation-api.txt | 201 -- .../licenses/java/LICENSE-vertx-auth-common.txt | 202 -- .../licenses/java/LICENSE-vertx-bridge-common.txt | 202 -- .../licenses/java/LICENSE-vertx-core.txt | 202 -- .../licenses/java/LICENSE-vertx-web-client.txt | 202 -- .../licenses/java/LICENSE-vertx-web-common.txt | 202 -- .../licenses/java/LICENSE-vertx-web.txt | 202 -- .../licenses/java/LICENSE-xpp3.txt | 45 - .../licenses/java/LICENSE-zipkin-reporter.txt | 201 -- .../java/LICENSE-zipkin-sender-okhttp3.txt | 201 -- .../licenses/java/LICENSE-zipkin.txt | 216 -- .../licenses/java/LICENSE-zookeeper-jute.txt | 202 -- .../licenses/java/LICENSE-zookeeper.txt | 202 -- .../licenses/java/LICENSE-zstd-jni.txt | 26 - 535 files changed, 13646 insertions(+), 60260 deletions(-) diff --cc .github/workflows/docker.yml index ab49c8204,dfb36970d..e69de29bb --- a/.github/workflows/docker.yml +++ b/.github/workflows/docker.yml @@@ -1,49 -1,50 +1,0 @@@ --# - # Licensed to the Apache Software Foundation (ASF) under one - # or more contributor license agreements. See the NOTICE file - # distributed with this work for additional information - # regarding copyright ownership. The ASF licenses this file - # to you under the Apache License, Version 2.0 (the - # "License"); you may not use this file except in compliance - # with the License. You may obtain a copy of the License at -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You under the Apache License, Version 2.0 -# (the "License"); you may not use this file except in compliance with -# the License. You may obtain a copy of the License at --# - # http://www.apache.org/licenses/LICENSE-2.0 -# http://www.apache.org/licenses/LICENSE-2.0 --# - # Unless required by applicable law or agreed to in writing, - # software distributed under the License is distributed on an - # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - # KIND, either express or implied. See the License for the - # specific language governing permissions and limitations - # under the License. -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. --# - --name: Docker --on: -- release: -- types: [released] -- --jobs: -- docker: -- runs-on: ubuntu-latest -- steps: -- - name: Checkout repository - uses: actions/checkout@v3 - uses: actions/checkout@v4 - -- - name: Login to DockerHub - uses: docker/login-action@v2 - uses: docker/login-action@v3 -- with: -- username: ${{ secrets.DOCKERHUB_USER }} -- password: ${{ secrets.DOCKERHUB_TOKEN }} - -- - name: Docker meta -- id: meta - uses: docker/metadata-action@v4 - uses: docker/metadata-action@v5 -- with: -- images: | -- apache/eventmesh -- -- - name: Build and push - uses: docker/build-push-action@v4 - uses: docker/build-push-action@v5 -- with: -- push: true -- tags: ${{ steps.meta.outputs.tags }} -- labels: ${{ steps.meta.outputs.labels }} -- file: ./docker/Dockerfile_jdk8 -- context: ./ diff --cc eventmesh-connectors/eventmesh-connector-kafka/build.gradle index 8a0b9f072,39dcbf656..b8ff17c6d --- a/eventmesh-connectors/eventmesh-connector-kafka/build.gradle +++ b/eventmesh-connectors/eventmesh-connector-kafka/build.gradle @@@ -16,10 -16,9 +16,10 @@@ */ dependencies { + implementation project(":eventmesh-common") implementation project(":eventmesh-openconnect:eventmesh-openconnect-java") - implementation 'io.cloudevents:cloudevents-kafka:2.4.2' - implementation 'org.apache.kafka:kafka-clients:3.0.0' + implementation 'io.cloudevents:cloudevents-kafka:2.5.0' + implementation 'org.apache.kafka:kafka-clients:3.6.2' compileOnly 'org.projectlombok:lombok' annotationProcessor 'org.projectlombok:lombok' - } + } diff --cc eventmesh-connectors/eventmesh-connector-pulsar/build.gradle index 904eada40,f087842ea..62ab590d8 --- a/eventmesh-connectors/eventmesh-connector-pulsar/build.gradle +++ b/eventmesh-connectors/eventmesh-connector-pulsar/build.gradle @@@ -15,13 -15,27 +15,28 @@@ * limitations under the License. */ - List pulsar = [ - "org.apache.pulsar:pulsar-client:$pulsar_version" - ] dependencies { + implementation project(":eventmesh-common") implementation project(":eventmesh-openconnect:eventmesh-openconnect-java") - implementation pulsar + + /* + * TODO: This is a shaded artifact that contains 20 MiB of external libraries. It could probably be replaced by: + * + * implementation "org.apache.pulsar:pulsar-client-api:$pulsar_version" + * runtimeOnly "org.apache.pulsar:pulsar-client-original:$pulsar_version" + * + * The exclusions can be removed after an upgrade of the transitive: + * + * "org.apache.bookkeeper:bookkeeper" + * + * dependency to 4.15.4 or higher (used by Pulsar 2.11.2 or higher). + */ + implementation("org.apache.pulsar:pulsar-client:$pulsar_version") { + // Remove logging backend implementations + exclude group: 'org.apache.logging.log4j', module: 'log4j-core' + exclude group: 'org.apache.logging.log4j', module: 'log4j-slf4j-impl' + } + compileOnly 'org.projectlombok:lombok' annotationProcessor 'org.projectlombok:lombok' } diff --cc eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/build.gradle index d40f77304,97c3b8c33..1338b0b7d --- a/eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/build.gradle +++ b/eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/build.gradle @@@ -16,12 -16,8 +16,9 @@@ */ dependencies { + implementation project(":eventmesh-common") api project(":eventmesh-spi") api "org.slf4j:slf4j-api" - implementation "org.apache.logging.log4j:log4j-api" - implementation "org.apache.logging.log4j:log4j-core" - implementation "org.apache.logging.log4j:log4j-slf4j2-impl" compileOnly 'org.projectlombok:lombok' annotationProcessor 'org.projectlombok:lombok' diff --cc eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v1/MetricsHandler.java index 2a63f8f58,a2be02aaf..000000000 deleted file mode 100644,100644 --- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v1/MetricsHandler.java +++ /dev/null @@@ -1,111 -1,113 +1,0 @@@ --/* -- * Licensed to the Apache Software Foundation (ASF) under one or more -- * contributor license agreements. See the NOTICE file distributed with -- * this work for additional information regarding copyright ownership. -- * The ASF licenses this file to You under the Apache License, Version 2.0 -- * (the "License"); you may not use this file except in compliance with -- * the License. You may obtain a copy of the License at -- * -- * http://www.apache.org/licenses/LICENSE-2.0 -- * -- * Unless required by applicable law or agreed to in writing, software -- * distributed under the License is distributed on an "AS IS" BASIS, -- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -- * See the License for the specific language governing permissions and -- * limitations under the License. -- */ -- --package org.apache.eventmesh.runtime.admin.handler.v1; -- --import org.apache.eventmesh.common.utils.JsonUtils; - import org.apache.eventmesh.metrics.api.model.HttpSummaryMetrics; - import org.apache.eventmesh.metrics.api.model.TcpSummaryMetrics; --import org.apache.eventmesh.runtime.admin.handler.AbstractHttpHandler; --import org.apache.eventmesh.runtime.admin.response.v1.GetMetricsResponse; --import org.apache.eventmesh.runtime.boot.EventMeshHTTPServer; --import org.apache.eventmesh.runtime.boot.EventMeshTCPServer; --import org.apache.eventmesh.runtime.common.EventMeshHttpHandler; -import org.apache.eventmesh.runtime.metrics.http.HttpMetrics; -import org.apache.eventmesh.runtime.metrics.tcp.TcpMetrics; -- --import java.io.IOException; -- --import io.netty.channel.ChannelHandlerContext; --import io.netty.handler.codec.http.HttpRequest; -- --import lombok.extern.slf4j.Slf4j; -- --/** -- * This class handles the {@code /metrics} endpoint, corresponding to the {@code eventmesh-dashboard} path {@code /metrics}. -- * <p> -- * This handler is responsible for retrieving summary information of metrics, including HTTP and TCP metrics. -- * -- * @see AbstractHttpHandler -- */ -- --@Slf4j --@EventMeshHttpHandler(path = "/metrics") --public class MetricsHandler extends AbstractHttpHandler { -- - private final HttpSummaryMetrics httpSummaryMetrics; - private final TcpSummaryMetrics tcpSummaryMetrics; - private final HttpMetrics httpMetrics; - private final TcpMetrics tcpMetrics; -- -- /** -- * Constructs a new instance with the provided EventMesh server instance. -- * -- * @param eventMeshHTTPServer the HTTP server instance of EventMesh -- * @param eventMeshTcpServer the TCP server instance of EventMesh -- */ -- public MetricsHandler(EventMeshHTTPServer eventMeshHTTPServer, -- EventMeshTCPServer eventMeshTcpServer) { -- super(); - this.httpSummaryMetrics = eventMeshHTTPServer.getMetrics().getSummaryMetrics(); - this.tcpSummaryMetrics = eventMeshTcpServer.getEventMeshTcpMonitor().getTcpSummaryMetrics(); - this.httpMetrics = eventMeshHTTPServer.getEventMeshHttpMetricsManager().getHttpMetrics(); - this.tcpMetrics = eventMeshTcpServer.getEventMeshTcpMetricsManager().getTcpMetrics(); -- } -- -- @Override -- protected void get(HttpRequest httpRequest, ChannelHandlerContext ctx) throws IOException { -- GetMetricsResponse getMetricsResponse = new GetMetricsResponse( - httpSummaryMetrics.maxHTTPTPS(), - httpSummaryMetrics.avgHTTPTPS(), - httpSummaryMetrics.maxHTTPCost(), - httpSummaryMetrics.avgHTTPCost(), - httpSummaryMetrics.avgHTTPBodyDecodeCost(), - httpSummaryMetrics.getHttpDiscard(), - httpSummaryMetrics.maxSendBatchMsgTPS(), - httpSummaryMetrics.avgSendBatchMsgTPS(), - httpSummaryMetrics.getSendBatchMsgNumSum(), - httpSummaryMetrics.getSendBatchMsgFailNumSum(), - httpSummaryMetrics.getSendBatchMsgFailRate(), - httpSummaryMetrics.getSendBatchMsgDiscardNumSum(), - httpSummaryMetrics.maxSendMsgTPS(), - httpSummaryMetrics.avgSendMsgTPS(), - httpSummaryMetrics.getSendMsgNumSum(), - httpSummaryMetrics.getSendMsgFailNumSum(), - httpSummaryMetrics.getSendMsgFailRate(), - httpSummaryMetrics.getReplyMsgNumSum(), - httpSummaryMetrics.getReplyMsgFailNumSum(), - httpSummaryMetrics.maxPushMsgTPS(), - httpSummaryMetrics.avgPushMsgTPS(), - httpSummaryMetrics.getHttpPushMsgNumSum(), - httpSummaryMetrics.getHttpPushFailNumSum(), - httpSummaryMetrics.getHttpPushMsgFailRate(), - httpSummaryMetrics.maxHTTPPushLatency(), - httpSummaryMetrics.avgHTTPPushLatency(), - httpSummaryMetrics.getBatchMsgQueueSize(), - httpSummaryMetrics.getSendMsgQueueSize(), - httpSummaryMetrics.getPushMsgQueueSize(), - httpSummaryMetrics.getHttpRetryQueueSize(), - httpSummaryMetrics.avgBatchSendMsgCost(), - httpSummaryMetrics.avgSendMsgCost(), - httpSummaryMetrics.avgReplyMsgCost(), - tcpSummaryMetrics.getRetrySize(), - tcpSummaryMetrics.getClient2eventMeshTPS(), - tcpSummaryMetrics.getEventMesh2mqTPS(), - tcpSummaryMetrics.getMq2eventMeshTPS(), - tcpSummaryMetrics.getEventMesh2clientTPS(), - tcpSummaryMetrics.getAllTPS(), - tcpSummaryMetrics.getAllConnections(), - tcpSummaryMetrics.getSubTopicNum()); - httpMetrics.maxHTTPTPS(), - httpMetrics.avgHTTPTPS(), - httpMetrics.maxHTTPCost(), - httpMetrics.avgHTTPCost(), - httpMetrics.avgHTTPBodyDecodeCost(), - httpMetrics.getHttpDiscard(), - httpMetrics.maxSendBatchMsgTPS(), - httpMetrics.avgSendBatchMsgTPS(), - httpMetrics.getSendBatchMsgNumSum(), - httpMetrics.getSendBatchMsgFailNumSum(), - httpMetrics.getSendBatchMsgFailRate(), - httpMetrics.getSendBatchMsgDiscardNumSum(), - httpMetrics.maxSendMsgTPS(), - httpMetrics.avgSendMsgTPS(), - httpMetrics.getSendMsgNumSum(), - httpMetrics.getSendMsgFailNumSum(), - httpMetrics.getSendMsgFailRate(), - httpMetrics.getReplyMsgNumSum(), - httpMetrics.getReplyMsgFailNumSum(), - httpMetrics.maxPushMsgTPS(), - httpMetrics.avgPushMsgTPS(), - httpMetrics.getHttpPushMsgNumSum(), - httpMetrics.getHttpPushFailNumSum(), - httpMetrics.getHttpPushMsgFailRate(), - httpMetrics.maxHTTPPushLatency(), - httpMetrics.avgHTTPPushLatency(), - httpMetrics.getBatchMsgQueueSize(), - httpMetrics.getSendMsgQueueSize(), - httpMetrics.getPushMsgQueueSize(), - httpMetrics.getHttpRetryQueueSize(), - httpMetrics.avgBatchSendMsgCost(), - httpMetrics.avgSendMsgCost(), - httpMetrics.avgReplyMsgCost(), - - tcpMetrics.getRetrySize(), - tcpMetrics.getClient2eventMeshTPS(), - tcpMetrics.getEventMesh2mqTPS(), - tcpMetrics.getMq2eventMeshTPS(), - tcpMetrics.getEventMesh2clientTPS(), - tcpMetrics.getAllTPS(), - tcpMetrics.getAllConnections(), - tcpMetrics.getSubTopicNum() - ); -- String result = JsonUtils.toJSONString(getMetricsResponse); -- writeJson(ctx, result); -- } --} diff --cc settings.gradle index 3801d9975,6a8e27bf9..63add6459 --- a/settings.gradle +++ b/settings.gradle @@@ -78,7 -77,7 +78,8 @@@ include 'eventmesh-connectors:eventmesh include 'eventmesh-connectors:eventmesh-connector-slack' include 'eventmesh-connectors:eventmesh-connector-wechat' include 'eventmesh-connectors:eventmesh-connector-http' + include 'eventmesh-connectors:eventmesh-connector-chatgpt' +include 'eventmesh-connectors:eventmesh-connector-canal' include 'eventmesh-storage-plugin:eventmesh-storage-api' include 'eventmesh-storage-plugin:eventmesh-storage-standalone' @@@ -128,11 -127,3 +129,9 @@@ include 'eventmesh-webhook:eventmesh-we include 'eventmesh-retry' include 'eventmesh-retry:eventmesh-retry-api' include 'eventmesh-retry:eventmesh-retry-rocketmq' +include 'eventmesh-runtime-v2' +include 'eventmesh-admin-server' +include 'eventmesh-registry' +include 'eventmesh-registry:eventmesh-registry-api' - findProject(':eventmesh-registry:eventmesh-registry-api')?.name = 'eventmesh-registry-api' +include 'eventmesh-registry:eventmesh-registry-nacos' - findProject(':eventmesh-registry:eventmesh-registry-nacos')?.name = 'eventmesh-registry-nacos' + --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
