You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2022/07/28 10:53:49 UTC
[incubator-eventmesh] 01/01: Merge pull request #1048 from apache/webhook
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit 22f436157b0c1bbe9d46dc0f847e5a9522784f76
Merge: e7ba6e2d 1adee518
Author: Eason Chen <qq...@gmail.com>
AuthorDate: Thu Jul 28 18:53:42 2022 +0800
Merge pull request #1048 from apache/webhook
.gitignore | 2 +
build.gradle | 6 +-
.../design-document/webhook/webhook-github-add.png | Bin 0 -> 82039 bytes
.../webhook/webhook-github-info.png | Bin 0 -> 49447 bytes
.../webhook/webhook-github-setting.png | Bin 0 -> 26731 bytes
.../webhook/webhook-github-webhooks.png | Bin 0 -> 49447 bytes
docs/zh/desing-document/webhook.md | 268 +++++++++++++++
.../eventmesh/admin/rocketmq/util/JsonUtils.java | 9 +
.../common/config/CommonConfiguration.java | 5 +
.../common/config/ConfigurationWrapper.java | 28 +-
.../http/WebhookProtocolTransportObject.java | 43 +++
.../protocol/http/common/EventMeshRetCode.java | 29 +-
.../demo/pub/cloudevents/AsyncPublishInstance.java | 6 +-
.../cloudevents/WebHookProtocolAdaptor.java | 62 ++++
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 3 +-
eventmesh-runtime/build.gradle | 4 +
eventmesh-runtime/conf/eventmesh.properties | 15 +-
.../admin/controller/ClientManageController.java | 24 ++
.../admin/handler/DeleteWebHookConfigHandler.java | 63 ++++
.../admin/handler/InsertWebHookConfigHandler.java | 62 ++++
.../handler/QueryWebHookConfigByIdHandler.java | 62 ++++
.../QueryWebHookConfigByManufacturerHandler.java | 67 ++++
.../admin/handler/UpdateWebHookConfigHandler.java | 62 ++++
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 68 ++--
.../runtime/boot/EventMeshHTTPServer.java | 49 ++-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 7 +
.../apache/eventmesh/runtime/boot/HTTPTrace.java | 138 ++++++++
.../eventmesh/runtime/common/EventMeshTrace.java | 36 ++
.../configuration/EventMeshHTTPConfiguration.java | 2 +
.../protocol/grpc/push/WebhookPushRequest.java | 65 ++--
.../protocol/grpc/service/ProducerService.java | 2 +-
.../http/processor/AsyncHttpProcessor.java | 35 ++
.../protocol/http/processor/HandlerService.java | 365 +++++++++++++++++++++
.../protocol/http/processor/HttpProcessor.java | 31 ++
.../processor/LocalSubscribeEventProcessor.java | 97 ++----
.../processor/LocalUnSubscribeEventProcessor.java | 83 ++---
.../processor/RemoteSubscribeEventProcessor.java | 101 ++----
.../processor/RemoteUnSubscribeEventProcessor.java | 73 ++---
.../http/processor/SendAsyncEventProcessor.java | 177 ++++------
.../http/processor/SendAsyncMessageProcessor.java | 4 +-
.../processor/SendAsyncRemoteEventProcessor.java | 179 ++++------
.../protocol/http/processor/WebHookProcessor.java | 58 ++++
.../http/processor/inf/AbstractEventProcessor.java | 2 +-
.../core/protocol/http/push/HTTPClientPool.java | 19 +-
.../eventmesh/runtime/util/EventMeshUtil.java | 1 +
.../eventmesh/runtime/util/HttpResponseUtils.java | 67 ++++
.../apache/eventmesh/runtime/util/WebhookUtil.java | 5 +-
.../grpc/producer/EventMeshGrpcProducer.java | 4 +-
eventmesh-webhook/build.gradle | 38 +++
.../eventmesh-webhook-admin/bin/.gitignore | 1 +
.../eventmesh-webhook-admin/build.gradle | 32 ++
.../eventmesh-webhook-admin/gradle.properties | 4 +-
.../admin/AdminWebHookConfigOperationManage.java | 80 +++++
.../webhook/admin/FileWebHookConfigOperation.java | 193 +++++++++++
.../webhook/admin/NacosWebHookConfigOperation.java | 205 ++++++++++++
.../eventmesh-webhook-api/bin/.gitignore | 1 +
.../eventmesh-webhook-api/build.gradle | 26 ++
.../eventmesh-webhook-api/gradle.properties | 4 +-
.../eventmesh/webhook/api/ManufacturerObject.java | 64 ++++
.../eventmesh/webhook/api/WebHookConfig.java | 95 ++++++
.../webhook/api/WebHookConfigOperation.java | 37 +++
.../webhook/api/WebHookOperationConstant.java | 51 +++
.../eventmesh-webhook-receive/bin/.gitignore | 1 +
.../eventmesh-webhook-receive/build.gradle | 39 +++
.../eventmesh-webhook-receive/gradle.properties | 4 +-
.../webhook/receive/ManufacturerProtocol.java | 42 +++
.../webhook/receive/WebHookController.java | 131 ++++++++
.../webhook/receive/WebHookMQProducer.java | 61 ++++
.../eventmesh/webhook/receive/WebHookRequest.java | 44 +++
.../webhook/receive/protocol/GithubProtocol.java | 99 ++++++
.../webhook/receive/protocol/ProtocolManage.java | 43 +++
.../storage/AbstractWebHookConfigOperation.java | 26 ++
.../receive/storage/HookConfigOperationManage.java | 120 +++++++
.../receive/storage/WebhookFileListener.java | 194 +++++++++++
.../gradle.properties | 4 +-
eventmesh-webhook/webhook.jmx | 122 +++++++
settings.gradle | 7 +
77 files changed, 3671 insertions(+), 585 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org