This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch eventmesh-function
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from ae621d490 [ISSUE #4979] Canal Connector supports bidirectional data
synchronization (#5011)
add 3550ac3a7 [ISSUE #4979]Canal Connector supports bidirectional data
synchronization
add 5f1c1afb6 add bash files for admin & runtime-v2
add 8f4748f3b fix ack offset read & persist
add 50a204e8d fix checkStyle error
new fb411ba52 Merge branch 'eventmesh-function' of
https://github.com/apache/eventmesh into eventmesh-function
add f7a9517bf Merge EventMesh function branch to master (#4941)
add fdac21763 update eventmesh architecture (#4946)
add 498c35042 [ISSUE #3515] Do some code optimization[AuthTokenUtils]
(#3644)
add 6a158adf3 [ISSUE #4847] HTTPS/(m)TLSv1.3 support for HTTP Admin Server
(#4848)
add eebbde30d Bump protobufVersion from 3.21.5 to 3.25.3 (#4948)
add dd9d64aaf Bump org.antlr:antlr4 from 4.13.0 to 4.13.1 (#4952)
add 97068bc56 Bump com.baomidou:mybatis-plus-boot-starter from 3.5.5 to
3.5.6 (#4954)
add d0b61ed6a Bump io.spring.gradle:dependency-management-plugin (#4960)
add 48676ee02 Bump org.assertj:assertj-core from 2.6.0 to 2.8.0 (#4959)
add 6730bd5fc Bump com.aliyun:dingtalk from 2.0.61 to 2.1.25 (#4947)
add 027614fe7 Bump org.apache.commons:commons-lang3 from 3.6 to 3.14.0
(#4951)
add 7486a370e Bump com.mebigfatguy.fb-contrib:fb-contrib from 7.6.0 to
7.6.4 (#4950)
add 7140930ff Bump jacksonVersion from 2.0.1 to 2.17.1 (#4955)
add 1fcf5705f Bump io.cloudevents:cloudevents-http-vertx from 2.3.0 to
2.5.0 (#4956)
add b64d1e0d6 Bump com.github.seancfoley:ipaddress from 5.3.3 to 5.5.0
(#4953)
add e52084873 [ISSUE #4929] Auto approve when dependabot's branch is
changed by committers (#4930)
add 499aa7acf Bump org.redisson:redisson from 3.17.3 to 3.30.0 (#4924)
add 15fcd08c4 Bump com.alibaba.fastjson2:fastjson2 from 2.0.48 to 2.0.51
(#4975)
add 20b31c45e Bump mysql:mysql-connector-java from 8.0.32 to 8.0.33 (#4976)
add 10accdb91 Bump org.mybatis.spring.boot:mybatis-spring-boot-starter
(#4971)
add 2ef82c4c4 Bump com.h3xstream.findsecbugs:findsecbugs-plugin from
1.11.0 to 1.13.0 (#4974)
add 35e6bc445 Bump org.asynchttpclient:async-http-client from 2.12.0 to
2.12.3 (#4970)
add f0060a94c Bump commons-io:commons-io from 2.11.0 to 2.16.1 (#4968)
add 707f2614b Bump com.alibaba:druid-spring-boot-starter from 1.2.22 to
1.2.23 (#4972)
add 886bffe95 Bump software.amazon.awssdk:s3 from 2.25.55 to 2.25.64
(#4969)
add df8a973e5 Bump org.apache.commons:commons-text from 1.9 to 1.12.0
(#4967)
add e3e390b15 Bump org.junit.jupiter:junit-jupiter from 5.6.0 to 5.10.2
(#4966)
add a6014cdf7 Bump com.alibaba:druid from 1.2.6 to 1.2.23 (#4977)
add b809cea9c Bump commons-validator:commons-validator from 1.7 to 1.9.0
(#4978)
add ae238eb57 Bump org.springframework.boot:spring-boot-starter-jetty
(#4965)
add a66864a76 Bump com.google.protobuf from 0.8.17 to 0.9.4 (#4973)
add a89dbe131 Bump com.github.jk1.dependency-license-report from 2.7 to
2.8 (#4986)
add 2c39d7998 Bump software.amazon.awssdk:s3 from 2.25.64 to 2.25.69
(#4981)
add b7272e3c2 Bump com.aliyun:dingtalk from 2.1.25 to 2.1.26 (#4982)
add 342caf237 Bump org.redisson:redisson from 3.30.0 to 3.31.0 (#4980)
add 53f3a47ab Bump com.mysql:mysql-connector-j from 8.0.33 to 8.4.0 (#4983)
add 30384eac6 Bump dropwizardMetricsVersion from 4.2.25 to 4.2.26 (#4985)
add 7543ee270 Bump com.baomidou:mybatis-plus-boot-starter from 3.5.6 to
3.5.7 (#5000)
add 5bcb63b0e Bump com.baomidou:mybatis-plus from 3.5.6 to 3.5.7 (#5001)
add 2d0f0d3b1 Bump software.amazon.awssdk:s3 from 2.25.69 to 2.26.3 (#4998)
add 419d4395a Bump com.slack.api:bolt from 1.39.+ to 1.40.0 (#5004)
add 565ec1adc Bump com.gradle.common-custom-user-data-gradle-plugin (#4997)
add a7f23f881 Bump curatorVersion from 5.6.0 to 5.7.0 (#5002)
add 00ad5a5ac Bump com.aliyun:dingtalk from 2.1.26 to 2.1.27 (#4999)
add 9fd64f2a5 Bump com.gradle.develocity from 3.17.4 to 3.17.5 (#5003)
add 91f6d1e26 Bump io.netty:netty-all from 4.1.79.Final to 4.1.111.Final
(#5006)
add 7c8895246 Bump com.lmax:disruptor from 3.4.2 to 3.4.4 (#3609)
add e883175f3 Bump org.assertj:assertj-core from 2.8.0 to 3.26.0 (#3574)
add 159204834 [ISSUE #4993] Unit test for EventMeshCloudEventWriter.java
(#5007)
add 996c439e4 [ISSUE #4869] Add Webhook support for HTTP Source Connector
(#4913)
new f2d764509 solve conflicts with master branch
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/dependabot.yml | 9 +-
.github/workflows/auto-dependabot.yml | 2 +-
.github/workflows/ci.yml | 10 +-
.github/workflows/code-scanning.yml | 2 +-
build.gradle | 63 +++---
eventmesh-admin-server/build.gradle | 48 ++---
.../org/apache/eventmesh/common/Constants.java | 2 +
.../connector/http/SourceConnectorConfig.java | 28 ++-
.../common/utils/ConfigurationContextUtil.java | 3 +-
.../canal/template/AbstractSqlTemplate.java | 10 +-
.../eventmesh-connector-chatgpt/build.gradle | 4 +-
.../eventmesh-connector-dingtalk/build.gradle | 2 +-
.../eventmesh-connector-file/build.gradle | 4 +-
.../eventmesh-connector-http/build.gradle | 3 +-
.../http/common/SynchronizedCircularFifoQueue.java | 148 ++++++++++++++
.../http/sink/handle/RetryHttpSinkHandler.java | 6 +-
.../http/sink/handle/WebhookHttpSinkHandler.java | 82 ++------
.../http/source/connector/HttpSourceConnector.java | 94 ++++-----
.../http/source/data/CommonResponse.java} | 45 +++-
.../connector/http/source/data/WebhookRequest.java | 22 +-
.../connector/http/source/protocol/Protocol.java} | 38 +++-
.../http/source/protocol/ProtocolFactory.java | 80 ++++++++
.../http/source/protocol/WebhookConstants.java | 50 +++++
.../source/protocol/impl/CloudEventProtocol.java | 107 ++++++++++
.../http/source/protocol/impl/CommonProtocol.java | 111 ++++++++++
.../http/source/protocol/impl/GitHubProtocol.java | 227 +++++++++++++++++++++
.../src/main/resources/source-config.yml | 9 +-
.../source/connector/HttpSourceConnectorTest.java | 104 ++++++----
.../src/test/resources/source-config.yml | 10 +-
.../eventmesh-connector-jdbc/build.gradle | 6 +-
.../eventmesh-connector-redis/build.gradle | 2 +-
.../eventmesh-connector-slack/build.gradle | 2 +-
eventmesh-meta/eventmesh-meta-raft/build.gradle | 15 +-
.../offsetmgmt/admin/AdminOffsetService.java | 2 -
.../config/samples/eventmesh_v1_runtime.yaml | 1 -
.../eventmesh-protocol-cloudevents/build.gradle | 2 +-
.../eventmesh-protocol-grpc/build.gradle | 6 +-
.../eventmesh-protocol-http/build.gradle | 2 +-
.../eventmesh-protocol-meshmessage/build.gradle | 2 +-
eventmesh-runtime/conf/admin-server.jks | Bin 0 -> 2808 bytes
eventmesh-runtime/conf/eventmesh.properties | 24 ++-
.../admin/handler/v2/ConfigurationHandler.java | 3 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 41 ++--
.../runtime/boot/AbstractRemotingServer.java | 51 ++---
.../runtime/boot/EventMeshAdminBootstrap.java | 22 +-
.../runtime/boot/EventMeshAdminServer.java | 88 ++++++--
.../runtime/boot/EventMeshGrpcBootstrap.java | 11 +-
.../runtime/boot/EventMeshHTTPServer.java | 66 +-----
.../runtime/boot/EventMeshHttpBootstrap.java | 15 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 81 +++-----
.../runtime/boot/EventMeshTcpBootstrap.java | 12 +-
.../runtime/boot/HTTPThreadPoolGroup.java | 51 +----
.../eventmesh/runtime/boot/SSLContextFactory.java | 25 +--
.../configuration/EventMeshAdminConfiguration.java | 61 ++++++
.../configuration/EventMeshGrpcConfiguration.java | 3 -
.../configuration/EventMeshHTTPConfiguration.java | 4 -
.../configuration/EventMeshTCPConfiguration.java | 3 -
.../http/processor/AdminMetricsProcessor.java | 6 +-
.../runtime/boot/EventMeshServerTest.java | 1 -
.../EventMeshGrpcConfigurationTest.java | 1 -
.../EventMeshHTTPConfigurationTest.java | 1 -
.../EventMeshTCPConfigurationTest.java | 1 -
.../util/EventMeshCloudEventWriterTest.java | 92 +++++++++
.../src/test/resources/configuration.properties | 2 -
eventmesh-sdks/eventmesh-sdk-java/build.gradle | 2 +-
.../auth/token/impl/auth/AuthTokenUtils.java | 114 ++++-------
.../eventmesh-storage-kafka/build.gradle | 2 +-
.../eventmesh-storage-redis/build.gradle | 14 +-
.../eventmesh-storage-redis/gradle.properties | 1 +
.../storage/redis/client/RedissonClient.java | 13 +-
.../storage/redis/config/RedisProperties.java | 11 +-
.../src/main/resources/redis-client.properties | 6 +-
.../storage/redis/AbstractRedisServer.java | 22 +-
.../storage/redis/config/RedisPropertiesTest.java | 10 +-
resources/eventmesh-architecture-5.png | Bin 217382 -> 169892 bytes
settings.gradle | 4 +-
76 files changed, 1497 insertions(+), 730 deletions(-)
create mode 100644
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/common/SynchronizedCircularFifoQueue.java
copy
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/CatalogSchema.java
=>
eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/data/CommonResponse.java}
(52%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/HeartbeatItem.java
=>
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/data/WebhookRequest.java
(71%)
copy
eventmesh-connectors/{eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerListener.java
=>
eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/Protocol.java}
(50%)
create mode 100644
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/ProtocolFactory.java
create mode 100644
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/WebhookConstants.java
create mode 100644
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/impl/CloudEventProtocol.java
create mode 100644
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/impl/CommonProtocol.java
create mode 100644
eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/impl/GitHubProtocol.java
create mode 100644 eventmesh-runtime/conf/admin-server.jks
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshAdminConfiguration.java
create mode 100644
eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/EventMeshCloudEventWriterTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
