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/09/25 09:29:14 UTC
[incubator-eventmesh] branch kafka-connector updated (2768d047 -> e0cdb2c1)
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch kafka-connector
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 2768d047 Merge pull request #1264 from Markliniubility/kafka
add e5df488f Modify the value of protocolType
add 8ef36ef5 Merge pull request #1003 from kirinzhu/fix-zlx-2
add d430ed90 [ISSUE #980]Made some fileds are final
add 229ad5e3 Merge pull request #1015 from liuzwei/fix_bug#980
add 371a24ec add runtime unit tests
add bc136483 1. revert non-unit-test changes 2. modify the check-style code problem
add e0e06bad fix ci problem
add 0707ea47 Merge pull request #966 from walterlife/walterlife/add-unit-test-for-runtime
add 9d56389a Update README.md
add 4aad846c Update README.md
add 50a27fe4 Merge pull request #1024 from kirinzhu/fix-patch-readme
add 6cc9295e When trace enable, then get trace plugin.
add ecb9cfe6 Two NPE problems fixes for Tcp Protocol Resolver.
add afab36b8 Merge pull request #1023 from mytang0/fix_patch_npe
add c9c84e4f update: update grpc version from 1.15.0 to 1.17.1
add 6b21158f update: update Generated grpc version from 1.15.0 to 1.17.1
add c1e63790 add: support Etcd Registry
add bb819593 feat: change EtcdClientFactory to singleton
add c7f3d6ea add: jetcd-core-0.3.0.jar to known-dependencies.txt
add ed97121c feat: throw exception when createClient failed
add 2adf8085 fix: move EtcdClientWrapper into factory package
add edb29535 add: new known-dependencies
add fa53c827 fix: checkStyle formatted
add 548c93c5 fix: EtcdRegistryServiceTest param
add 8a1125e9 fix: add EtcdRegistryMonitorExecutorService & fix logger format
add d5acaa9b fix: add comment
add 5b23bfc4 fix: the unit test code
add 889d5420 fix: unit test code add RegistryException expected
add 1e43deef fix: EtcdRegistryService add shutdown executor
add 3dd4237a remove: EtcdRegistryServiceTest nnecessary stubbings
add 76729598 fix: EtcdRegistryServiceTest checkStyle
add 09fc238b Merge pull request #1029 from JellyBo/registry-etcd-jelly
add 1d50d1ec [Bug]Fix the case that span is null
add ee5a4e5e Merge pull request #1020 from liuzwei/fix_bug_span_npe
add 08c97090 SPI plugin path config can move to constant config
add fa7884de plugin dir config move to variable
add e1940849 Merge pull request #955 from mroccyen/issue-950
add 48072721 Update SubService.java
add d47b0ee3 Update SubService.java
add be4b8465 Merge pull request #1026 from pkyriakou23/fixing_issue988
add c73dc8d8 Update quick-start
add 441e8223 Merge pull request #1032 from kirinzhu/fix-patch-quickstart
add 81ffb3b7 [ISSUE #1059] Fix NullPointException of Http Request
add 2cfc0686 Update bug_report.yml
add 76b39f63 Merge pull request #1041 from apache/xwm1992-patch-1
add 3f50544a Update ProducerGroupConf.java
add ed5ff6f3 Update eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java
add 5d7d8f66 Fix code style
add ab193380 Merge pull request #1025 from pkyriakou23/fixing_issue997
add 79d33773 fix valid url bug
add 30bc2cb7 Merge pull request #1039 from zmt-Eason/dev_zmt
add d9708c46 Update docs
add 3d3639a4 Update docs
add e720cb2c Update docs
add 87c0caa5 Update docs
add 8faecde0 Update docs
add 98669ea3 Merge pull request #1034 from kirinzhu/fix-patch-docs
add ee027561 fix(.git):1. 排除bin目录
add 9050f68f WebHookController 实现
add 4a172f21 webhook receive module
add 612b1501 [ISSUE #865] support webhook
add 37b51bd9 fix: 参数名修正
add 8cbbf727 fix: webhook依赖引入修正
add 399af859 fix: webhook配置写入nacos、file方式实现
add aa426a6e Merge pull request #886 from JellyBo/webhook
add 17afd9ca Merge remote-tracking branch 'apache/webhook' into webhook
add 9f61806b conflict resolution and improve the code
add f9041178 Merge pull request #897 from eight-nines/webhook
add e9b83089 Convert comments to English and improve the code
add fc832a0a Merge pull request #903 from eight-nines/webhook
add dfe45499 fix(runtime):1. 基本完成handlerService设计与开发
add 0fd45dea Merge pull request #1 from apache/webhook
add db181288 feat: optimize webHookConfig CURD logic
add 5bf070c0 feat: FileWebHookConfigOperation writeToFile method add lock, getWebhookConfigFilePath method use MD5
add d8fd4410 feat: add License
add e7d2c465 feat: optimize the code
add 82166ee9 feat: WebHookConfigOperation add License
add de257d67 Repair exception Handling
add 8dce3084 Send webhook CloudEvents
add 38cdc31d add license header
add c74d6452 fix gradle
add 571344c9 fix gradle again
add 360b8a0d fix gradle again
add 6c55ae46 fix code style
add 0f47364c fix gradle
add 2b68a6d6 fix license
add 9249f2c6 Improve the functionality of the code
add fb922c7f fix the code
add d7f5b97e fix the gradle
add 7fa6d5ca Modify the parameter passing when WebHookController creates HookConfigOperationManage
add c5fdea0e Integrate AdminWebHookConfigOperationManage into HttpServer of eventmesh-runtime
add 5a80073d Merge pull request #914 from eight-nines/webhook
add 044dbf28 add HTTPTrace for the branch webhook
add 2bc74e9a 将errorTrace与exceptionTrace合并 & 修改HttpReqTrace方法名为requestInfoTrace
add 2880edea Merge pull request #929 from yiyuquan/webhook
add a02cd271 Add HttpProcessor & WebHookProcessor
add 5c5bd450 Update HttpProcessor & WebHookProcessor
add f594c04d Merge pull request #934 from 111-dep/webhook
add 5cc85a64 Merge branch 'webhook_remote' into webhook_jelly_fix
add b30c7b41 feat: add comments
add c4f0e777 feat: add License Header
add 358a2e6a Merge pull request #921 from JellyBo/webhook_jelly_fix
add f49928ff fix(webhook and httpservice):1. 完成webhook与httpservice联调
add 3e3aaf2c fix(webhook): 1. 添加使用说明 2. eventcloud适配器
add 31a5aeb2 fix(*):1.处理代码样式
add ade843d1 1. 格式化代码
add 665f2b96 1. 删除.checkstyle 2. 在.gitignore 添加排除.checkstyle
add be7de8e6 fix(webhook):1. review 修正,2. 打包修正 3. 文档补齐
add e295099d fix(*):1. 修正review问题
add a025a8d5 fix(*):1. 修正review问题
add ef2390db fix(*):1.修正review问题
add a8791fe2 Merge remote-tracking branch 'apache/master' into webhook
add e5d14690 update HandlerService
add 8492c706 update HandlerService
add bf28cd7d update AsyncHttpProcessor.java update EventMeshRetCode.java update HandlerService.java update SendAsyncEventProcessorV2.java
add 5f65d21c update SendAsyncEventProcessorV2 update SendAsyncMessageProcessor
add c05bdca4 update AsyncHttpProcessor.java update EventMeshHTTPServer.java update HandlerService.java
add 8896ed41 delete SendAsyncEventProcessorV2 update SendAsyncEventProcessor update EventMeshHttpServer update HTTPTrace
add b0e82153 fix checkstyle
add 88f60704 update http processors supported trace annotation
add 1a811d02 fix checkStyle
add 18a62334 Merge pull request #937 from githublaohu/webhook
add ff274aaa Merge pull request #1042 from xwm1992/webhook
add 53af0a01 Merge pull request #1045 from xwm1992/webhook
add c8eebee3 Merge branch 'webhook' of https://github.com/apache/incubator-eventmesh into webhook
add cf6df56d add apache header
add d00fbabe Merge pull request #1048 from apache/webhook
add 6d914be1 Merge remote-tracking branch 'apache/master' into trace-bug-fix
add 4597f076 Merge pull request #1060 from xwm1992/trace-bug-fix
add 194f1452 Fix NullPointException Of ClientManageControllerTest
add e38ab71d fix FileWebHookConfigOperation checkstyle problem
add 54208737 Merge pull request #1067 from walterlife/bugfix/walterlife/1064
add a92fae50 Fix the problem of shared registry singleton.
add 6e16bab1 Review fixes.
add 0294c996 Merge pull request #1044 from mytang0/fix_patch_registry
add 0d0b44b1 [ISSUE #1074]Fix PrometheusConfigurationTest running test fail
add a8322a57 Merge pull request #1075 from xwm1992/Prometheus-test-bugfix
add e5243107 Tcp UpStreamMsgContext retry infinite loop bug fix.
add f15645d4 Fixed bugs caused by partial logical sequence of closeSession.
add dc0b52bb Merge branch 'master' into fix_patch_tcp
add d43a9bfb TCP session adds isRunning() method.
add 0e276a07 Rollback TCP closeSession logical order modification.
add 93c6d9fb Merge pull request #1037 from mytang0/fix_patch_tcp
add 48a77684 add consul registry implement
add 9d031b93 add consul registry implement
add 30a06e79 add consul licence
add 210eb787 add consul
add a7ea6213 style fix lint
add 3b996e3e style fix lint
add c5977f9a style fix lint
add 454d59d3 style fix lint
add 9a2db88f style fix lint
add 78c8f461 create spi file
add a0fbfef7 remove unused file
add 4bf59e8c resolve conversation
add eafb72a2 add token support
add 9ef662e2 feat: add new impl
add cce9fdc9 feat: add licence header
add 0a531626 refactor: move to java
add 62c5b496 style: replace Chinese to English
add a1a574c1 Merge pull request #901 from huyuanxin/consul-regisrty
add c8009d5d Merge pull request #1104 from apache/registry-consul
add e0b7439f Merge remote-tracking branch 'apache/master' into registry-etcd
add a07f098e Merge pull request #1103 from apache/registry-etcd
add 9f37387a Extract constants of protocol-http module
add 0809605d Merge pull request #1100 from Karen-W-2002/extraction_protocol_http
add c527349f [ISSUE #1068] translate desing-document/cloudevents to zh
add d3c859d0 Merge pull request #1096 from HeZean/docs-zh-cloudevents
add 696f122e [MINOR] fix gradle build fail exception
add 0a1069bb Merge pull request #1110 from xwm1992/fixBuildException
add 772c10e8 replace with Constants
add d8e5f43f Merge pull request #1109 from KevinClair/#1085
add b2cca149 fix: Remove unnecessary whitespace #1117
add 0f8f5ee2 Merge pull request #1118 from Frank-liuyang/master
add 4179fe2e Update roadmap docs
add ea4998a0 Modify some typo
add 1474c187 Modify some typo
add ca4b0039 Merge pull request #1106 from kirinzhu/fix-patch-01
add 64f40dc2 extract constants of Zipkin trace module
add 96770639 Merge pull request #1099 from LIU-WEI-git/extract_contants
add c113af78 [ISSUE #1062]translate document (workflow.md)
add 6396ea8e [ISSUE #1062]translate document (workflow.md)
add 09f69cb3 Merge pull request #1097 from wuyiliang1/doc_zh_workflow
add 0dcd710b [ISSUE #1102] PR auto link to issue
add 4ac3ae4f Merge pull request #1112 from HeZean/pr-template
add 132af3b3 [MINOR] fix license check exception
add 51519e05 fix prometheus ut test exception
add a07f922a unit dependencies jar version
add 676f91b4 Merge pull request #1119 from xwm1992/fixLicenseCheck
add c02e2be0 [MINOR] update project licenses
add 8b2f3fd3 Merge pull request #1138 from xwm1992/license-update
add 338193cc http
add 150cf7b9 feat: http eventmesh producer
add 5cdb2347 feat: grpc producer eventmesh
add 3426d753 hearbeat
add abde2b36 heartbeat
add cdb011f8 feat: grpc subscribe
add 89425c0b feat: grpc subscribe
add 3c5dc4e9 stream
add c9702823 feat: stream
add e6575e2d feat: rr
add e9ab057c feat: batch publish
add 6db4722a When trace enable, then get trace plugin.
add 9896e9d1 Implement the redis connector plugin.
add eb77f3a7 Remove invalid import.
add 2d5701ed Introduce redis-mock tool and test case optimization.
add fc74b31f Check style problem fix.
add 9a86f291 Check style problem fix & License Check problem fix
add dbfad847 Add known dependencies & Add LICENSE
add a7012829 Add known dependencies problem fix
add 28befe6e Code optimize.
add dcb28417 Build (macOS-latest, 8) testSendOneway FAILED fix.
add a8be7978 Partial modification recovery and code optimization.
add a560e612 Review suggestion: remove the unified configuration function.
add 4f2c1376 Merge pull request #990 from mytang0/feature/redis-connector
add cb9d12da Update greetings.yml
add 9142d05c Merge pull request #1172 from apache/qqeasonchen-patch-1
add 6c660b50 test: add test code for runtime module
add d39b0b78 fix: fix ci code style check error
add c6e982c5 Merge pull request #1143 from KRCheung/test/runtime
add ea0039a6 Extract constants of ExporterConfiguration
add 7cc62dfc Merge pull request #1164 from seriouszyx/extract_constants
add e1624684 [Issue #1076] Extraction of constants
add cb03b4c0 Merge pull request #1089 from Karen-W-2002/NacosWebHookConfigOperations_Constants
add 73ba9564 Update greetings.yml
add 6796ee95 Merge pull request #1180 from apache/qqeasonchen-patch-3
add 0fa1b96b Update README.md
add 97b10b74 Merge pull request #1178 from apache/qqeasonchen-patch-2
add 256563b5 [ISSUE #1080]Extraction of constants [AuthConfigs]
add a88306f4 Merge remote-tracking branch 'origin/master' into issue_1080
add 020b2a63 Merge pull request #1179 from wuyiliang1/issue_1080
add 8b9ed9e2 Remove the invalid code.
add 71d5c146 open log.
add edbfd093 Merge pull request #1134 from KevinClair/#1017
add 02148711 [Doc #1144] Add design document of Bridge
add 77b25476 Merge pull request #1163 from xwm1992/support-eventbridge-docs
add 18e9af58 remove unused local variables
add 8a64e46f Merge pull request #1171 from horoc/remove-unused-local-variables
add 102c7e09 [ISSUE #999] Implement serializable interface for ValueComparator
add e7df8150 Merge branch 'apache:master' into serializable-interface
add 1ecc60cf Merge pull request #1136 from HeZean/serializable-interface
add a72dc8ea Update LICENSE
add 264b0392 Update LICENSE
add 89c91aa7 Update LICENSE
add 01b77264 Add files via upload
add bea380ac Add files via upload
add dcb94e4b Revert "add init rocketmq home path"
add 6df1fcad delete deploy pa
add 69e8fa16 Set theme jekyll-theme-cayman
add b3e64d4c Set theme jekyll-theme-cayman
add 9a3c0928 update eventmesh-panels.png (#363)
add def3f1d6 Initial Implementation of Apache Pulsar Connector
add 47db0db4 Merge pull request #1137 from apache/pulsar-connector
add 87fdad2d [ISSUE #986] Remove unused replyMsgThreadPoolQueue
add bf33f8df Merge pull request #1101 from HeZean/issue986
add 2533b876 [Issue-1152] Extraction of constants [ClientGroupWrapper EventMeshProducer]
add 1b94e38f Merge pull request #1190 from indhuvisu/issue-1152
add 6ae7ffd3 Update README.md
add d8b8d74f Merge pull request #1183 from apache/qqeasonchen-patch-4
add 98c29168 Update greetings.yml
add 0d41ff33 Merge pull request #1191 from apache/qqeasonchen-patch-5
add 45a1384d [ISSUE #982] Explicit usage of byte encoding in common and admin
add 23f40978 Merge branch 'apache:master' into byte-encoding
add 3fe88bd3 Merge branch 'apache:master' into byte-encoding
add 912a0d24 feat: add encoding for string-bytes convertions
add eff88836 Update TopicsHandler.java
add 80105641 Merge pull request #1105 from HeZean/byte-encoding
add 08734539 upgrade grpc version to 1.42.2, protobuf version to 3.21.5
add 86b3678c add out dir to .gitignore
add ddeb9a48 Merge pull request #1192 from LIU-WEI-git/grpc_upgrade
add 0febb204 feat: [Doc] Translate the design document (stream.md) #1063
add 205ed8e8 Merge pull request #1196 from BigXin0109/master
add 31b652ab fix: [Doc] Image link not working [03-stream.md] #1174
add e89245a8 Merge pull request #1197 from BigXin0109/fix/stream_image_not_working
add a1b36481 fix FileWebHookConfigOperation insert error
add 952ffd9e update known dependecies
add 54662988 fix file path concat in WebhookFileListener
add 8b1b6447 fix ci error
add d9a9a6d6 update Constants
add 766fffde Merge pull request #1201 from weihubeats/feature_constants
add bc8d62ef Update README.md
add 5825ae86 Merge pull request #1199 from apache/qqeasonchen-patch-6
add 14b206e3 feat: Remove alarm
add fda0a9af Merge pull request #1200 from BigXin0109/fix/warning_code
add b0f4361a Merge branch 'master' into fix-filewebHookconfig-insert-error
add 261f35a6 fix code style
add ce514fd8 Merge pull request #1198 from horoc/fix-filewebHookconfig-insert-error
add 1bbfb5da Set theme jekyll-theme-cayman
add 053ff4ee Add files via upload
add 53219e3a Add files via upload
add 19d8c323 [Issue #533] Adding design doc for EventMesh Workflow
add ebe57dbb Add remote processors
add da896bcc Uploaded implementation of Knative producer.
add 261e8b8e Uploaded implementation of Knative producer.
add 720ca94a Amended Knative producer implementation according to comments.
add 0f05d107 Amended Knative producer implementation according to comments.
add 1269da7d Amended Knative producer implementation according to comments.
add 6a0588f9 Fixed checkstyle and license check issues.
add 7090c9fe Amended according to discussion.
add 2832d5e7 Fixed issues in PR check. 1. Fixed issue in Continuous Integration / Build (ubuntu-latest, 8) (pull_request). 2. Fixed issue in Continuous Integration / Build (ubuntu-latest, 11) (pull_request). 3. Fixed issue in Continuous Integration / Build (macOS-latest, 8) (pull_request). 4. Fixed issue in Continuous Integration / Build (macOS-latest, 11) (pull_request). 5. Fixed issue in Continuous Integration / License Check (pull_request).
add 139ea9ed Passed producer test for the whole pub/sub procedure.
add 4781b7e0 Minor fixed for checkstyle issue.
add fe755b73 Added start and shutdown methods.
add 434096c6 Added license in KnativeConnectorTest.
add 2c33ff53 Uploaded implementation of Knative consumer.
add 40905c8c Fixed missing license header problem.
add 44a484a8 Fixed CI problems.
add da9e120b Merge pull request #1214 from pchengma/master
add 146be390 fix code style bug
add e68538fc Merge pull request #1212 from LIU-WEI-git/fix_code_style
add ecb63682 fix: fix NullPointerException
add 07989af2 Merge branch 'upstream_master' into fix/fix_zipkin_trace_npe
add 0a7a79d9 Merge pull request #1209 from BigXin0109/fix/fix_zipkin_trace_npe
add e0bc53ce add eventmesh-workflow-go module
add c206b810 Refer eventmesh-server-go mod to use plugin/log
add 3056310d add license header
add 0f94c6de add ignore license file
add 552e4b21 add eventmesh catalog module
add e8d96071 add valid license header
add c7590ccf add eventmesh-workflow-go module
add f24c03bd Refer eventmesh-server-go mod to use plugin/log
add cfa01146 add license header
add 2af0cfb1 add ignore license file
add 5ae52c8f Merge pull request #1160 from walterlife/walterlife/workflow
add 18fc5684 add eventmesh catalog module
add a6037f82 add valid license header
add ad69f864 Merge pull request #1189 from walterlife/eventmesh-catalog
add 6edee019 Merge branch 'eventmesh-workflow-go' of https://github.com/walterlife/incubator-eventmesh into eventmesh-workflow-go
add 3e6c5805 Merge pull request #1210 from walterlife/eventmesh-workflow-go
add ab1b5592 fix webhook request type convert error
add 703ff366 Merge pull request #1215 from horoc/fix-webhook-request-type-convert-error
add 96220299 init
add e44f4ccf init
add e1b7a5d8 add config with test
add 85a007da add exception class
add c0085d16 edit gitignore
add c1a3cabb [bug] grpc version conflict
add d6a73b98 producer
add f8dfd89b Merge remote-tracking branch 'upstream/master' into pravega_connector
add c3d6946b Merge remote-tracking branch 'upstream/master' into pravega_connector
add 0293f4a4 update scope name
add b2f6b331 add config item
add 25051aec update PravegaClient
add aea53e1a SubscribeTask
add 1ae4d668 fix PravegaClient bug
add 079df0b7 update config and format code
add ab8181c6 add test
add cc5a235e add UT
add 9e31517e Merge remote-tracking branch 'upstream/master' into pravega_connector
add 27c4dabf reuse writer
add b92b7b65 remove .gitignore duplicate items
add aed744a8 move SubscribeTask.java
add 92de6434 fix pub/sub bug
add b9709086 format
add e04f3ffc Merge remote-tracking branch 'upstream/master' into pravega_connector
add d0df831e Merge remote-tracking branch 'upstream/master' into pravega_connector
add 898537fd add license
add d0aad1bd add test properties
add 11e52b6f ignore docker test, add known-dependencies.txt
add c48b692e Merge pull request #1203 from LIU-WEI-git/pravega_connector
add 7f9ad8f6 Update README.md
add 9717af16 Merge pull request #1218 from apache/qqeasonchen-patch-5
add ece75867 Update roadmap.md
add 358711ea Merge pull request #1217 from apache/qqeasonchen-patch-4
add 29a40af8 Merge remote-tracking branch 'apache/master' into redis-connector
add 2ecc73cb Merge pull request #1219 from apache/redis-connector
add 4925c56c Merge branch 'master' into rust-sdk
add 67ee6661 Merge pull request #1156 from RiESAEX/rust-sdk
add ba38bba1 Extraction of constants grpc、JAVA and application/cloudevents+json.
add 65514793 Logger's modification "ConfigurationWrapper" to ConfigurationWrapper.class here.
add 6d6e18af add rust sdk lisence header
add aaa7b427 Merge pull request #1222 from horoc/add-rust-sdk-lisence-header
add 8557c829 fix document invalid image urls
add 7baeb181 Merge pull request #1221 from horoc/fix-doc-invalid-picture-url
add 4f3492a2 Uploaded documentation (Knative).
add 95f6f767 Fixed CI problems.
add 863cf568 Fixed CI problem by deleting unnecessary unit test.
add b7a395bd Merge pull request #1225 from pchengma/master
add 7ce2c459 Merge pull request #1226 from RiemannChow/master
add a43d9353 Revert "Extraction of constants grpc、JAVA and application/cloudevents+json."
add 3aae1828 Merge pull request #1228 from apache/revert-1226-master
add c168cfd1 Merge branch 'apache:master' into master
add afca9835 Extraction of constants grpc、JAVA and application/cloudevents+json.
add fdda67ae Extraction of constants grpc、JAVA and application/cloudevents+json.
add d06066b8 Merge pull request #1233 from RiemannChow/extraction_constants
add 950788c9 modify webhook protocol plugin dir
add 9c606a78 fix WebHookProcessor request content read error
add 4e7c8c53 add WebHookProcessor unit test and bug fix
add f56c23d6 Merge pull request #1227 from horoc/modify-webhook-protocol-plugin-dir
add ec8399b5 add README.md
add 8b7f9470 fix style check
add f16d2e81 Merge pull request #1240 from LIU-WEI-git/0908_fix_style
add ceae83da Merge remote-tracking branch 'upstream/master' into pravega_connector_doc
add 73ff23e3 Merge pull request #1242 from LIU-WEI-git/pravega_connector_doc
add bf736a2f Remove invalid code [ runtime module core and util directory ]
add 9abcc3c8 Merge pull request #1252 from KeeProMise/ISSUE#1161
add 679de465 add catalog protocol
add a4255ae5 Merge pull request #1249 from walterlife/catalog-protocol
add 87665bc2 add workflow protocol
add f6aefd75 Merge pull request #1250 from walterlife/workflow-protocol
add d6b58c6a [ISSUE #1273] update known-dependencies
add 88f50319 Merge pull request #1275 from githublaohu/webhook-repair5
add 12e7d24f Extraction of constants #1083
add c2e7adb7 rm author.
add 7edc74f7 [ISSUE #1276] update github protocol under the webhook module
add c23efeca Merge pull request #1278 from githublaohu/webhook-repair5
add b5bf5a02 Merge branch 'master' of https://github.com/apache/incubator-eventmesh
add 6acd7637 rm apache license
add 5292c223 [ISSUE #1279] gradle.properties incorrect under the eventmesh-connector-pulsar
add aad26e35 Merge pull request #1282 from githublaohu/webhook-repair5
add 4d0b8165 Merge branch 'master' of https://github.com/apache/incubator-eventmesh
add 1c8782a6 Merge pull request #1281 from heihei180/master
add a3eeea5c add selector interface
add 76e1cec0 Merge pull request #1290 from walterlife/selector
add 07b4805e add workflow java client
add 72a3e780 Enhancement 1280
add 5051f7f3 Fixed code style
add c816e11e Merge branch 'apache:master' into fix_patch_1280
add 4965bea9 Merge pull request #1292 from zdb11/fix_patch_1280
add c718777a Remove invalid code.
add 7bc3546a Merge branch 'master' of https://github.com/RiemannChow/incubator-eventmesh
add 85acff31 Merge pull request #1236 from RiemannChow/master
add 30bf0584 [ISSUE #1321] update WebHookMQProducer constructor
add eb859e69 Merge pull request #1322 from githublaohu/webhook-repair5
add 810849d2 [ISSUE #1330] Update WebHookController for using WebHookMQProducer
add c7ce2b61 Merge pull request #1332 from githublaohu/webhook-repair5
add 84e9d5af [Issuse #1316] Pulsar Connector: Repair started error with ClassNotFoundException(PulsarProducerImpl)
add 7ea82754 Merge pull request #1317 from fengyongshe/pulsar-connector
add a9dad165 [ISSUE #1333] Add utils for webhook get the file config
add 12ed1ac3 Merge pull request #1343 from githublaohu/webhook-repair5
add 45102930 [ISSUE #1344] update HookConfigOperationManage for webhook
add 0cdfc515 Merge pull request #1349 from githublaohu/webhook-repair5
add 13567a05 [ISSUE #1350] Fix WebHookProcessorTest test error
add c6148856 Merge pull request #1351 from githublaohu/webhook-repair5
add a26427c5 add key javadoc for publish method
add 244974af move SubscribeTask.java to client package
add 49afbf23 fix unclose bug and serialize bug
add 1cc58163 Merge pull request #1348 from LIU-WEI-git/fix_1347
add 0023a0d7 add license files
add 088a1c59 Merge pull request #1346 from LIU-WEI-git/license_files
add aadc086f [ISSUE #1231] use StringUtils.defaultIfEmpty replace non-null check
add 2ca2b159 Merge remote-tracking branch 'origin/master' into issue_1231
add 76b5517d Merge pull request #1234 from wuyiliang1/issue_1231
add a796f4bc [ISSUE #1356] update WebhookFileListener for operating the webhook config
add 49a32d71 Merge pull request #1357 from githublaohu/webhook-repair5
add 5e7cdd16 [ISSUE #1358] Update FileWebHookConfigOperation for webhook config
add 410c2e51 Merge pull request #1359 from githublaohu/webhook-repair5
add b622e932 [ISSUE #1361] Update WebHookProtocolAdaptor for pub/sub
add 8365f07f Merge pull request #1362 from githublaohu/webhook-repair5
add 97bfa067 [ISSUE #1364] Fix WebHook module code checkstyle
add 874d0f39 Merge pull request #1366 from githublaohu/webhook-repair5
add b17f3f5d Moved knative connector doc to design-document dir.
add 4e67dbb0 Merge pull request #1369 from pchengma/master
add df47f061 fixed webHook protocol adaptor
add e379be68 Merge pull request #1370 from cocodroid/fixed-webhook
add 93426af2 upgrade SubscribeTask and PravegaClient in pravega connector
add 0c1fcb70 support sendOneway method
add cb09085d support Broadcast and Clustering message model
add 22326481 Merge pull request #1237 from LIU-WEI-git/pravega_connector_upgrade
add ae7b2159 feat : [Doc] Delete duplicate documents [eventmesh-unit-test-rule.md] #1272
add 61ad522a Merge pull request #1380 from luodanqing/master
add c1cf00da Revert "feat : [Doc] Delete duplicate documents [eventmesh-unit-test-rule.md] #1272"
add 8a36fe0b feat : [Doc] Delete duplicate documents [eventmesh-unit-test-rule.md] #1272
add 7537d823 Revert "feat : [Doc] Delete duplicate documents [eventmesh-unit-test-rule.md] #1272"
add 33666b35 feat : [Doc] Delete duplicate documents [eventmesh-unit-test-rule.md] #1272
add 86455c58 Merge pull request #1389 from luodanqing/master
add c5c74e93 Merge branch 'master' into workflow-client-java
add b560c2a3 Merge pull request #1340 from walterlife/workflow-client-java
new e0cdb2c1 Merge remote-tracking branch 'apache/master' into kafka-connector
The 1 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/ISSUE_TEMPLATE/bug_report.yml | 1 +
.github/PULL_REQUEST_TEMPLATE.md | 4 +-
.github/workflows/greetings.yml | 4 +-
.gitignore | 3 +-
.licenserc.yaml | 1 +
README.md | 52 +-
README.zh-CN.md | 38 +-
build.gradle | 26 +-
docs/en/design-document/03-stream.md | 2 +-
docs/en/design-document/09-event-bridge.md | 156 ++
docs/en/design-document/10-knative-connector.md | 93 ++
docs/en/instruction/01-store-with-docker.md | 74 +-
docs/en/instruction/01-store.md | 47 +-
docs/en/instruction/02-runtime-with-docker.md | 22 +-
docs/en/instruction/02-runtime.md | 80 +-
docs/en/instruction/03-demo.md | 187 +--
docs/en/roadmap.md | 56 +-
.../images/design-document/event-bridge-detail.png | Bin 0 -> 563043 bytes
.../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/01-workflow.md | 258 ++++
docs/zh/desing-document/03-stream.md | 115 ++
docs/zh/desing-document/06-cloudevents.md | 102 ++
docs/zh/desing-document/09-event-bridge.md | 156 ++
docs/zh/desing-document/10-knative-connector.md | 91 ++
.../zh/desing-document/eventmesh-unit-test-rule.md | 124 --
docs/zh/desing-document/webhook.md | 268 ++++
docs/zh/instruction/00-eclipse.md | 2 +-
docs/zh/instruction/01-store-with-docker.md | 20 +-
docs/zh/instruction/02-runtime-with-docker.md | 2 +-
docs/zh/instruction/02-runtime.md | 94 +-
docs/zh/instruction/03-demo.md | 82 +-
docs/zh/roadmap.md | 54 +-
.../apache/eventmesh/admin/rocketmq/Constants.java | 6 +
.../admin/rocketmq/handler/TopicsHandler.java | 30 +-
.../eventmesh/admin/rocketmq/util/JsonUtils.java | 9 +
eventmesh-catalog-go/.golangci.yml | 99 ++
eventmesh-catalog-go/Makefile | 40 +
eventmesh-catalog-go/api/catalog.go | 112 ++
eventmesh-catalog-go/api/proto/catalog.pb.go | 390 +++++
.../api/proto/catalog.proto | 37 +-
eventmesh-catalog-go/api/proto/catalog_grpc.pb.go | 157 ++
eventmesh-catalog-go/cmd/main.go | 20 +
eventmesh-catalog-go/config/config.go | 28 +
eventmesh-catalog-go/configs/catalog.yaml | 44 +
eventmesh-catalog-go/go.mod | 74 +
eventmesh-catalog-go/go.sum | 406 +++++
.../internal/constants/constants.go | 18 +
eventmesh-catalog-go/internal/dal/catalog.go | 55 +
eventmesh-catalog-go/internal/dal/config.go | 48 +
eventmesh-catalog-go/internal/dal/model/event.go | 35 +
.../internal/dal/model/event_catalog.go | 35 +
eventmesh-catalog-go/internal/util/catalog_util.go | 60 +
eventmesh-catalog-go/main.go | 40 +
eventmesh-catalog-go/pkg/asyncapi/decode.go | 29 +
eventmesh-catalog-go/pkg/asyncapi/document.go | 212 +++
eventmesh-catalog-go/pkg/asyncapi/v2/decode.go | 114 ++
eventmesh-catalog-go/pkg/asyncapi/v2/v2.go | 887 +++++++++++
eventmesh-catalog-go/server.go | 141 ++
eventmesh-common/build.gradle | 6 +-
.../org/apache/eventmesh/common/Constants.java | 79 +-
.../common/config/CommonConfiguration.java | 47 +-
.../common/config/ConfigurationWrapper.java | 40 +-
.../protocol/catalog/protos/CatalogGrpc.java | 385 +++++
.../catalog/protos/EventmeshCatalogGrpc.java | 132 ++
.../common/protocol/catalog/protos/Operation.java | 969 ++++++++++++
.../catalog/protos/OperationOrBuilder.java | 80 +
.../catalog/protos/QueryOperationsRequest.java | 787 ++++++++++
.../protos/QueryOperationsRequestOrBuilder.java | 57 +
.../catalog/protos/QueryOperationsResponse.java | 858 +++++++++++
.../protos/QueryOperationsResponseOrBuilder.java | 55 +
.../protocol/catalog/protos/RegistryRequest.java | 787 ++++++++++
.../catalog/protos/RegistryRequestOrBuilder.java | 57 +
.../protocol/catalog/protos/RegistryResponse.java | 479 ++++++
.../catalog/protos/RegistryResponseOrBuilder.java | 10 +-
.../protocol/grpc/protos/ConsumerServiceGrpc.java | 2 +-
.../protocol/grpc/protos/HeartbeatServiceGrpc.java | 2 +-
.../protocol/grpc/protos/PublisherServiceGrpc.java | 2 +-
.../http/WebhookProtocolTransportObject.java | 32 +-
.../protocol/http/common/EventMeshRetCode.java | 29 +-
.../eventmesh/common/protocol/tcp/codec/Codec.java | 11 +-
.../workflow/protos/EventmeshWorkflowGrpc.java | 85 ++
.../protocol/workflow/protos/ExecuteRequest.java | 851 +++++++++++
.../workflow/protos/ExecuteRequestOrBuilder.java | 63 +
.../protocol/workflow/protos/ExecuteResponse.java | 575 +++++++
.../workflow/protos/ExecuteResponseOrBuilder.java | 30 +-
.../protocol/workflow/protos/WorkflowGrpc.java | 294 ++++
.../org/apache/eventmesh/common/utils/IPUtils.java | 4 +-
.../eventmesh/common/utils/PropertiesUtils.java | 64 +
.../common/utils/PropertiesUtilsTest.java | 43 +
.../apache/eventmesh/api/consumer/Consumer.java | 4 +-
.../eventmesh-connector-knative}/build.gradle | 28 +-
.../eventmesh-connector-knative/gradle.properties | 6 +-
.../knative/cloudevent/KnativeMessageFactory.java | 27 +-
.../impl/KnativeBinaryMessageReader.java | 56 +
.../knative/cloudevent/impl/KnativeHeaders.java | 19 +-
.../cloudevent/impl/KnativeMessageWriter.java | 73 +
.../knative/common/EventMeshConstants.java} | 7 +-
.../knative/config/ClientConfiguration.java | 44 +
.../knative/config/ConfigurationWrapper.java | 71 +
.../ConnectorResourceServiceKnativeImpl.java | 15 +-
.../knative/consumer/DefaultConsumer.java | 69 +
.../knative/consumer/KnativeConsumerImpl.java | 88 ++
.../knative/consumer/PullConsumerImpl.java | 168 ++
.../connector/knative/domain/NonStandardKeys.java | 12 +-
.../EventMeshConsumeConcurrentlyContext.java} | 13 +-
.../patch/EventMeshConsumeConcurrentlyStatus.java} | 18 +-
.../EventMeshMessageListenerConcurrently.java} | 7 +-
.../knative/producer/AbstractProducer.java | 64 +
.../knative/producer/KnativeProducerImpl.java | 93 ++
.../connector/knative/producer/ProducerImpl.java | 127 ++
.../connector/knative/utils/CloudEventUtils.java | 20 +-
...ventmesh.api.connector.ConnectorResourceService | 4 +-
.../org.apache.eventmesh.api.consumer.Consumer | 4 +-
.../org.apache.eventmesh.api.producer.Producer | 4 +-
.../src/main/resources/knative-client.properties | 4 +-
.../knative/consumer/KnativeConsumerImplTest.java | 22 +-
.../knative/producer/KnativeProducerImplTest.java | 58 +
.../eventmesh-connector-pravega/README.md | 19 +
.../eventmesh-connector-pravega}/build.gradle | 23 +-
.../eventmesh-connector-pravega/gradle.properties | 6 +-
.../pravega-connector.jpg | Bin 0 -> 143684 bytes
.../PravegaConnectorResourceServiceImpl.java | 24 +-
.../connector/pravega/PravegaConsumerImpl.java | 95 ++
.../connector/pravega/PravegaProducerImpl.java | 108 ++
.../connector/pravega/client/PravegaClient.java | 227 +++
.../pravega/client/PravegaCloudEventWriter.java | 70 +
.../connector/pravega/client/PravegaEvent.java | 76 +
.../connector/pravega/client/SubscribeTask.java | 87 ++
.../pravega/config/PravegaConnectorConfig.java | 113 ++
.../config/PravegaConnectorConfigWrapper.java | 71 +
.../exception/PravegaConnectorException.java | 16 +-
...ventmesh.api.connector.ConnectorResourceService | 4 +-
.../org.apache.eventmesh.api.consumer.Consumer | 4 +-
.../org.apache.eventmesh.api.producer.Producer | 4 +-
.../main/resources/pravega-connector.properties | 12 +-
.../pravega/client/PravegaClientTest.java | 183 +++
.../pravega/config/PravegaConnectorConfigTest.java | 81 +
.../test/resources/pravega-connector.properties | 12 +-
.../eventmesh-connector-pulsar}/build.gradle | 33 +-
.../eventmesh-connector-pulsar/gradle.properties | 4 +-
.../pulsar/common/EventMeshConstants.java} | 7 +-
.../pulsar/config/ClientConfiguration.java | 33 +-
.../pulsar/config/ConfigurationWrapper.java | 72 +
.../ConnectorResourceServicePulsarImpl.java | 17 +-
.../pulsar/producer/AbstractProducer.java | 58 +
.../connector/pulsar/producer/ProducerImpl.java | 102 ++
.../pulsar/producer/PulsarProducerImpl.java | 91 ++
.../connector/pulsar/utils/CloudEventUtils.java | 20 +-
...ventmesh.api.connector.ConnectorResourceService | 4 +-
.../org.apache.eventmesh.api.consumer.Consumer | 4 +-
.../org.apache.eventmesh.api.producer.Producer | 4 +-
.../src/main/resources/pulsar-client.properties | 2 +-
.../eventmesh-connector-redis}/build.gradle | 36 +-
.../eventmesh-connector-redis/gradle.properties | 4 +-
.../connector/redis/client/RedissonClient.java | 148 ++
.../redis/cloudevent/CloudEventCodec.java | 60 +
.../connector/redis/config/ConfigOptions.java | 51 +
.../redis/config/ConfigurationWrapper.java | 73 +
.../connector/redis/config/RedisProperties.java | 94 ++
.../connector/RedisConnectorResourceService.java | 33 +
.../connector/redis/consumer/RedisConsumer.java | 131 ++
.../connector/redis/producer/RedisProducer.java | 139 ++
...ventmesh.api.connector.ConnectorResourceService | 4 +-
.../org.apache.eventmesh.api.consumer.Consumer | 4 +-
.../org.apache.eventmesh.api.producer.Producer | 4 +-
.../src/main/resources/redis-client.properties | 1 -
.../connector/redis/AbstractRedisServer.java | 41 +
.../connector/redis/client/RedissonClientTest.java | 31 +
.../connector/redis/connector/UnitTest.java | 109 ++
.../redis/consumer/RedisConsumerTest.java | 90 ++
.../redis/producer/RedisProducerTest.java | 109 ++
.../src/test/resources/redis-client.properties | 2 +-
.../rocketmq/config/ClientConfiguration.java | 32 +-
.../rocketmq/consumer/PushConsumerImpl.java | 1 -
.../rocketmq/consumer/RocketMQConsumerImpl.java | 20 +-
.../rocketmq/producer/AbstractProducer.java | 4 +-
.../rocketmq/producer/RocketMQProducerImpl.java | 13 +-
.../apache/rocketmq/producer/ProducerImplTest.java | 3 +-
eventmesh-examples/build.gradle | 2 +-
.../cloudevents/CloudEventsPublishInstance.java | 2 +-
.../cloudevents/CloudEventsRequestInstance.java | 2 +-
.../eventmeshmessage/AsyncPublishBroadcast.java | 2 +-
.../pub/eventmeshmessage/AsyncPublishInstance.java | 2 +-
.../pub/eventmeshmessage/RequestReplyInstance.java | 2 +-
.../eventmesh/grpc/sub/app/service/SubService.java | 2 +-
.../demo/pub/cloudevents/AsyncPublishInstance.java | 6 +-
.../pub/eventmeshmessage/AsyncPublishInstance.java | 2 +-
.../http/demo/sub/service/SubService.java | 2 +-
.../eventmesh/tcp/common/EventMeshTestUtils.java | 106 +-
.../eventmesh/tcp/common/UtilsConstants.java | 52 +
.../config/PrometheusConfigurationTest.java | 2 +-
.../src/test/resources/prometheus.properties | 2 +-
.../eventmesh-protocol-cloudevents/build.gradle | 5 +-
.../cloudevents/CloudEventsProtocolAdaptor.java | 2 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 60 +-
.../eventmesh-protocol-grpc/build.gradle | 9 +-
.../eventmesh-protocol-http/build.gradle | 5 +-
.../protocol/http/HttpProtocolAdaptor.java | 3 +-
.../protocol/http/HttpProtocolConstant.java | 15 +
.../http/resolver/HttpRequestProtocolResolver.java | 34 +-
.../eventmesh-protocol-meshmessage/build.gradle | 5 +-
.../meshmessage/MeshMessageProtocolAdaptor.java | 2 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 4 +-
.../resolver/tcp/TcpMessageProtocolResolver.java | 12 +-
.../build.gradle | 2 -
.../eventmesh-protocol-webhook/gradle.properties | 4 +-
.../protocol/webhook/WebHookProtocolAdaptor.java | 87 ++
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 4 +-
.../api/registry/dto/EventMeshDataInfo.java | 4 +
.../eventmesh-registry-consul}/build.gradle | 10 +-
.../eventmesh-registry-consul/gradle.properties | 3 +-
.../consul/service/ConsulRegistryService.java | 165 ++
.../registry/consul/service/HeatBeatScheduler.java | 103 ++
...g.apache.eventmesh.api.registry.RegistryService | 4 +-
.../src/test/java/ConsulRegistryServiceTest.java | 128 ++
.../eventmesh-registry-etcd/build.gradle | 10 +-
.../eventmesh-registry-etcd/gradle.properties | 3 +-
.../registry/etcd/constant/EtcdConstant.java | 24 +-
.../registry/etcd/factory/EtcdClientFactory.java | 116 ++
.../registry/etcd/factory/EtcdClientWrapper.java | 79 +
.../registry/etcd/factory/EtcdLeaseId.java | 88 ++
.../registry/etcd/factory/EtcdStreamObserver.java | 38 +-
.../registry/etcd/service/EtcdRegistryService.java | 282 ++++
...g.apache.eventmesh.api.registry.RegistryService | 4 +-
.../etcd/service/EtcdRegistryServiceTest.java | 122 ++
eventmesh-runtime/build.gradle | 11 +-
eventmesh-runtime/conf/eventmesh.properties | 15 +-
.../admin/controller/ClientManageController.java | 24 +
.../admin/handler/DeleteWebHookConfigHandler.java | 64 +
.../admin/handler/InsertWebHookConfigHandler.java | 63 +
.../handler/QueryRecommendEventMeshHandler.java | 16 +-
.../handler/QueryWebHookConfigByIdHandler.java | 66 +
.../QueryWebHookConfigByManufacturerHandler.java | 68 +
.../handler/RedirectClientByIpPortHandler.java | 7 +-
.../admin/handler/RedirectClientByPathHandler.java | 7 +-
.../handler/RedirectClientBySubSystemHandler.java | 7 +-
.../admin/handler/RejectAllClientHandler.java | 5 +-
.../admin/handler/RejectClientByIpPortHandler.java | 7 +-
.../handler/RejectClientBySubSystemHandler.java | 7 +-
.../admin/handler/ShowClientBySystemHandler.java | 3 +-
.../runtime/admin/handler/ShowClientHandler.java | 3 +-
.../handler/ShowListenClientByTopicHandler.java | 3 +-
.../admin/handler/UpdateWebHookConfigHandler.java | 63 +
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 71 +-
.../runtime/boot/EventMeshGrpcServer.java | 4 -
.../runtime/boot/EventMeshHTTPServer.java | 50 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 30 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 8 +-
.../apache/eventmesh/runtime/boot/HTTPTrace.java | 138 ++
.../eventmesh/runtime/common/EventMeshTrace.java | 36 +
.../configuration/EventMeshGrpcConfiguration.java | 46 +-
.../configuration/EventMeshHTTPConfiguration.java | 56 +-
.../configuration/EventMeshTCPConfiguration.java | 52 +-
.../runtime/constants/EventMeshConstants.java | 13 +-
.../core/consumergroup/ProducerGroupConf.java | 9 +-
.../eventmesh/runtime/core/plugin/MQWrapper.java | 2 -
.../consumergroup/ConsumerGroupTopicConfig.java | 1 -
.../grpc/processor/HeartbeatProcessor.java | 1 -
.../protocol/grpc/producer/EventMeshProducer.java | 7 +-
.../protocol/grpc/push/WebhookPushRequest.java | 65 +-
.../protocol/grpc/service/ProducerService.java | 2 +-
.../protocol/http/consumer/EventMeshConsumer.java | 12 +-
.../protocol/http/consumer/HandleMsgContext.java | 8 +-
.../http/processor/AsyncHttpProcessor.java | 24 +-
.../http/processor/BatchSendMessageProcessor.java | 15 +-
.../processor/BatchSendMessageV2Processor.java | 2 -
.../protocol/http/processor/HandlerService.java | 366 +++++
.../protocol/http/processor/HttpProcessor.java | 14 +-
.../processor/LocalSubscribeEventProcessor.java | 104 +-
.../processor/LocalUnSubscribeEventProcessor.java | 90 +-
.../processor/RemoteSubscribeEventProcessor.java | 109 +-
.../processor/RemoteUnSubscribeEventProcessor.java | 81 +-
.../http/processor/ReplyMessageProcessor.java | 1 -
.../http/processor/SendAsyncEventProcessor.java | 180 +--
.../http/processor/SendAsyncMessageProcessor.java | 6 +-
.../processor/SendAsyncRemoteEventProcessor.java | 186 +--
.../protocol/http/processor/WebHookProcessor.java | 60 +
.../http/processor/inf/AbstractEventProcessor.java | 2 +-
.../core/protocol/http/push/HTTPClientPool.java | 19 +-
.../protocol/http/push/HTTPMessageHandler.java | 3 +-
.../tcp/client/group/ClientGroupWrapper.java | 55 +-
.../core/protocol/tcp/client/session/Session.java | 7 +
.../tcp/client/session/push/SessionPusher.java | 7 +-
.../client/session/send/UpStreamMsgContext.java | 26 +-
.../tcp/client/task/MessageTransferTask.java | 9 +-
.../eventmesh/runtime/registry/Registry.java | 37 +-
.../org/apache/eventmesh/runtime/trace/Trace.java | 6 +-
.../apache/eventmesh/runtime/trace/TraceUtils.java | 2 +-
.../eventmesh/runtime/util/EventMeshUtil.java | 36 +-
.../eventmesh/runtime/util/HttpResponseUtils.java | 69 +
.../eventmesh/runtime/util/RemotingHelper.java | 3 -
.../eventmesh/runtime/util/ValueComparator.java | 3 +-
.../apache/eventmesh/runtime/util/WebhookUtil.java | 5 +-
.../controller/ClientManageControllerTest.java | 65 +
.../QueryRecommendEventMeshHandlerTest.java | 98 ++
.../handler/RedirectClientByPathHandlerTest.java | 130 ++
.../runtime/client/common/MessageUtils.java | 2 +-
.../protocol/processor/WebHookProcessorTest.java | 116 ++
...st.java => EventMeshThreadFactoryImplTest.java} | 22 +-
.../eventmesh/runtime/util/EventMeshUtilTest.java | 155 ++
.../eventmesh/runtime/util/HttpTinyClientTest.java | 76 +
.../eventmesh/runtime/util/IOTinyUtilsTest.java | 130 ++
.../eventmesh/runtime/util/NetUtilsTest.java | 52 +
.../eventmesh/runtime/util/RemotingHelperTest.java | 59 +
...tMeshUtilTest.java => ValueComparatorTest.java} | 22 +-
.../eventmesh/runtime/util/WebhookUtilTest.java | 76 +
eventmesh-sdk-java/build.gradle | 9 +-
.../client/grpc/producer/CloudEventProducer.java | 4 +-
.../grpc/producer/EventMeshGrpcProducer.java | 4 +-
.../client/grpc/util/EventMeshClientUtil.java | 8 +-
.../producer/RRCallbackResponseHandlerAdapter.java | 2 +-
.../eventmesh/client/http/util/HttpUtils.java | 8 +-
.../apache/eventmesh/client/selector/Selector.java | 10 +-
.../client/selector/SelectorException.java | 16 +-
.../eventmesh/client/selector/SelectorFactory.java | 22 +-
.../eventmesh/client/selector/ServiceInstance.java | 30 +-
.../client/tcp/common/EventMeshCommon.java | 14 +-
.../client/workflow/EventMeshWorkflowClient.java | 62 +
.../config/EventMeshWorkflowClientConfig.java | 16 +-
.../client/grpc/util/EventMeshClientUtilTest.java | 2 +-
eventmesh-sdk-rust/.gitignore | 2 +
eventmesh-sdk-rust/.vscode/settings.json | 3 +
eventmesh-sdk-rust/Cargo.lock | 1606 ++++++++++++++++++++
.licenserc.yaml => eventmesh-sdk-rust/Cargo.toml | 30 +-
.../eventmesh/Cargo.toml | 44 +-
eventmesh-sdk-rust/eventmesh/build.rs | 21 +
.../eventmesh/proto/eventmesh-client.proto | 150 ++
eventmesh-sdk-rust/eventmesh/src/constants.rs | 24 +
eventmesh-sdk-rust/eventmesh/src/grpc/config.rs | 54 +
eventmesh-sdk-rust/eventmesh/src/grpc/consumer.rs | 263 ++++
eventmesh-sdk-rust/eventmesh/src/grpc/mod.rs | 27 +
eventmesh-sdk-rust/eventmesh/src/grpc/producer.rs | 127 ++
eventmesh-sdk-rust/eventmesh/src/http/config.rs | 29 +
eventmesh-sdk-rust/eventmesh/src/http/mod.rs | 38 +
eventmesh-sdk-rust/eventmesh/src/http/producer.rs | 117 ++
.../eventmesh/src/http/protocol_key.rs | 34 +
.../eventmesh/src/http/request_code.rs | 76 +
eventmesh-sdk-rust/eventmesh/src/lib.rs | 22 +
eventmesh-sdk-rust/eventmesh/src/message.rs | 55 +
eventmesh-sdk-rust/examples/Cargo.lock | 1044 +++++++++++++
eventmesh-sdk-rust/examples/Cargo.toml | 63 +
.../examples/grpc-consumer-stream.rs | 93 ++
eventmesh-sdk-rust/examples/grpc-consumer.rs | 81 +
.../examples/grpc-producer-batch-publish.rs | 57 +
.../examples/grpc-producer-publish.rs | 57 +
.../examples/grpc-producer-request.rs | 57 +
.../examples/http-producer-publish.rs | 56 +
.../examples/http-producer-request.rs | 56 +
.../org/apache/eventmesh/api/auth/AuthService.java | 2 +-
.../auth/http/basic/config/AuthConfigs.java | 12 +-
.../auth/http/basic/impl/AuthHttpBasicService.java | 4 +-
.../spi/loader/EventMeshExtensionConstant.java | 9 +-
.../spi/loader/JarExtensionClassLoader.java | 9 +-
.../spi/loader/MetaInfExtensionClassLoader.java | 4 +-
.../trace/api/common/EventMeshTraceConstants.java | 4 +
.../trace/api/config/ExporterConfiguration.java | 10 +-
.../eventmesh/trace/zipkin/ZipkinTraceService.java | 14 +-
.../trace/zipkin/common/ZipkinConstants.java | 21 +-
.../trace/zipkin/config/ZipkinConfiguration.java | 12 +-
.../build.gradle | 30 +-
.../eventmesh-webhook-admin/bin/.gitignore | 1 +
.../eventmesh-webhook-admin}/build.gradle | 17 +-
.../eventmesh-webhook-admin}/gradle.properties | 0
.../admin/AdminWebHookConfigOperationManage.java | 80 +
.../webhook/admin/FileWebHookConfigOperation.java | 172 +++
.../webhook/admin/NacosWebHookConfigOperation.java | 204 +++
.../admin/FileWebHookConfigOperationTest.java | 77 +
.../eventmesh-webhook-api/bin/.gitignore | 1 +
.../eventmesh-webhook-api/build.gradle | 9 +-
.../eventmesh-webhook-api}/gradle.properties | 0
.../eventmesh/webhook/api/ManufacturerObject.java | 64 +
.../eventmesh/webhook/api/WebHookConfig.java | 95 ++
.../webhook/api/WebHookConfigOperation.java | 24 +-
.../webhook/api/WebHookOperationConstant.java | 51 +
.../eventmesh/webhook/api/utils/StringUtils.java | 8 +-
.../eventmesh-webhook-receive/bin/.gitignore | 1 +
.../eventmesh-webhook-receive}/build.gradle | 35 +-
.../eventmesh-webhook-receive}/gradle.properties | 0
.../webhook/receive/ManufacturerProtocol.java | 27 +-
.../webhook/receive/WebHookController.java | 129 ++
.../webhook/receive/WebHookMQProducer.java | 68 +
.../eventmesh/webhook/receive/WebHookRequest.java | 33 +-
.../webhook/receive/protocol/GithubProtocol.java | 100 ++
.../webhook/receive/protocol/ProtocolManage.java | 31 +-
.../storage/AbstractWebHookConfigOperation.java | 9 +-
.../receive/storage/HookConfigOperationManage.java | 118 ++
.../receive/storage/WebhookFileListener.java | 201 +++
.../gradle.properties | 0
eventmesh-webhook/webhook.jmx | 122 ++
eventmesh-workflow-go/.golangci.yml | 99 ++
.../.licenserc.yaml | 1 +
eventmesh-workflow-go/Makefile | 40 +
eventmesh-workflow-go/api/proto/workflow.pb.go | 255 ++++
.../api/proto/workflow.proto | 24 +-
.../api/proto/workflow_grpc.pb.go | 121 ++
eventmesh-workflow-go/api/workflow.go | 54 +
eventmesh-workflow-go/cmd/main.go | 20 +
eventmesh-workflow-go/config/config.go | 36 +
eventmesh-workflow-go/configs/workflow.yaml | 71 +
eventmesh-workflow-go/flow/engine.go | 82 +
eventmesh-workflow-go/flow/error.go | 21 +
eventmesh-workflow-go/flow/model.go | 22 +
eventmesh-workflow-go/go.mod | 35 +
eventmesh-workflow-go/go.sum | 480 ++++++
.../internal/constants/constants.go | 60 +
eventmesh-workflow-go/internal/dal/config.go | 59 +
.../internal/dal/model/workflow.go | 46 +
.../internal/dal/model/workflow_task.go | 87 ++
eventmesh-workflow-go/internal/dal/workflow.go | 423 ++++++
.../internal/queue/in_memory_queue.go | 86 ++
eventmesh-workflow-go/internal/queue/queue.go | 40 +
.../internal/schedule/scheduler.go | 112 ++
eventmesh-workflow-go/internal/task/event_task.go | 35 +
.../internal/task/operation_task.go | 35 +
eventmesh-workflow-go/internal/task/switch_task.go | 34 +
eventmesh-workflow-go/internal/task/task.go | 37 +
eventmesh-workflow-go/internal/util/flow_util.go | 60 +
eventmesh-workflow-go/main.go | 41 +
eventmesh-workflow-go/middleware/dblock/errors.go | 27 +
eventmesh-workflow-go/middleware/dblock/lock.go | 70 +
.../middleware/dblock/lock_client.go | 116 ++
eventmesh-workflow-go/server.go | 130 ++
eventmesh-workflow-go/third_party/jqer/jqer.go | 377 +++++
eventmesh-workflow-go/third_party/jqer/options.go | 55 +
eventmesh-workflow-go/third_party/swf/swf.go | 29 +
eventmesh-workflow-go/third_party/swf/swf_test.go | 32 +
.../third_party/swf/testdata/greeting.yaml | 79 +
settings.gradle | 14 +
tools/dependency-check/check-dependencies.sh | 2 +-
tools/dependency-check/known-dependencies.txt | 111 +-
tools/third-party-licenses/LICENSE | 34 +-
.../java/LICENSE-animal-sniffer-annotations.txt | 21 +
...t => LICENSE-async-http-client-netty-utils.txt} | 0
...ertj-core.txt => LICENSE-async-http-client.txt} | 0
.../licenses/java/LICENSE-bcpkix-jdk15on.txt | 22 +
.../licenses/java/LICENSE-bcprov-jdk15on.txt | 22 +
.../licenses/java/LICENSE-bcutil-jdk15on.txt | 22 +
.../LICENSE-commons-io.txt} | 0
...LICENSE-snakeyam.txt => LICENSE-consul-api.txt} | 7 +-
...=> LICENSE-google-auth-library-credentials.txt} | 0
...ENSE-grpc-context.txt => LICENSE-grpc-auth.txt} | 0
...SE-grpc-context.txt => LICENSE-grpc-grpclb.txt} | 0
...NSE-jcommander.txt => LICENSE-jetcd-common.txt} | 0
...CENSE-jcommander.txt => LICENSE-jetcd-core.txt} | 0
...E-jcommander.txt => LICENSE-jetcd-resolver.txt} | 0
.../licenses/java/LICENSE-nacos-client.txt | 614 +++-----
...-all.txt => LICENSE-netty-reactive-streams.txt} | 0
.../LICENSE-pravega-client.txt} | 0
.../LICENSE-pravega-common.txt} | 0
.../LICENSE-pravega-shared-authplugin.txt} | 0
.../LICENSE-pravega-shared-controller-api.txt} | 0
.../LICENSE-pravega-shared-protocol.txt} | 0
.../LICENSE-pravega-shared-security.txt} | 0
...buf-java.txt => LICENSE-protobuf-java-util.txt} | 0
.../licenses/java/LICENSE-redisson.txt | 13 +
458 files changed, 29440 insertions(+), 2679 deletions(-)
create mode 100644 docs/en/design-document/09-event-bridge.md
create mode 100644 docs/en/design-document/10-knative-connector.md
create mode 100644 docs/images/design-document/event-bridge-detail.png
create mode 100644 docs/images/design-document/webhook/webhook-github-add.png
create mode 100644 docs/images/design-document/webhook/webhook-github-info.png
create mode 100644 docs/images/design-document/webhook/webhook-github-setting.png
create mode 100644 docs/images/design-document/webhook/webhook-github-webhooks.png
create mode 100644 docs/zh/desing-document/01-workflow.md
create mode 100644 docs/zh/desing-document/03-stream.md
create mode 100644 docs/zh/desing-document/06-cloudevents.md
create mode 100644 docs/zh/desing-document/09-event-bridge.md
create mode 100644 docs/zh/desing-document/10-knative-connector.md
delete mode 100644 docs/zh/desing-document/eventmesh-unit-test-rule.md
create mode 100644 docs/zh/desing-document/webhook.md
create mode 100644 eventmesh-catalog-go/.golangci.yml
create mode 100644 eventmesh-catalog-go/Makefile
create mode 100644 eventmesh-catalog-go/api/catalog.go
create mode 100644 eventmesh-catalog-go/api/proto/catalog.pb.go
copy eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/auth/AuthService.java => eventmesh-catalog-go/api/proto/catalog.proto (58%)
create mode 100644 eventmesh-catalog-go/api/proto/catalog_grpc.pb.go
create mode 100644 eventmesh-catalog-go/cmd/main.go
create mode 100644 eventmesh-catalog-go/config/config.go
create mode 100644 eventmesh-catalog-go/configs/catalog.yaml
create mode 100644 eventmesh-catalog-go/go.mod
create mode 100644 eventmesh-catalog-go/go.sum
create mode 100644 eventmesh-catalog-go/internal/constants/constants.go
create mode 100644 eventmesh-catalog-go/internal/dal/catalog.go
create mode 100644 eventmesh-catalog-go/internal/dal/config.go
create mode 100644 eventmesh-catalog-go/internal/dal/model/event.go
create mode 100644 eventmesh-catalog-go/internal/dal/model/event_catalog.go
create mode 100644 eventmesh-catalog-go/internal/util/catalog_util.go
create mode 100644 eventmesh-catalog-go/main.go
create mode 100644 eventmesh-catalog-go/pkg/asyncapi/decode.go
create mode 100644 eventmesh-catalog-go/pkg/asyncapi/document.go
create mode 100644 eventmesh-catalog-go/pkg/asyncapi/v2/decode.go
create mode 100644 eventmesh-catalog-go/pkg/asyncapi/v2/v2.go
create mode 100644 eventmesh-catalog-go/server.go
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/CatalogGrpc.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/EventmeshCatalogGrpc.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/Operation.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/OperationOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/QueryOperationsRequest.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/QueryOperationsRequestOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/QueryOperationsResponse.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/QueryOperationsResponseOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/RegistryRequest.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/RegistryRequestOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/RegistryResponse.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/RegistryResponseOrBuilder.java (68%)
copy eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/auth/AuthService.java => eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/WebhookProtocolTransportObject.java (60%)
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/EventmeshWorkflowGrpc.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/ExecuteRequest.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/ExecuteRequestOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/ExecuteResponse.java
copy eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/EventMeshUtilTest.java => eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/ExecuteResponseOrBuilder.java (56%)
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/WorkflowGrpc.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/PropertiesUtils.java
create mode 100644 eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/PropertiesUtilsTest.java
copy {eventmesh-examples => eventmesh-connector-plugin/eventmesh-connector-knative}/build.gradle (65%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-knative/gradle.properties (92%)
copy eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/java/org/apache/eventmesh/auth/http/basic/config/AuthConfigs.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/KnativeMessageFactory.java (57%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeBinaryMessageReader.java
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java (67%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/common/EventMeshConstants.java} (82%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ClientConfiguration.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ConfigurationWrapper.java
copy eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java (70%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/DefaultConsumer.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImpl.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/PullConsumerImpl.java
copy eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/domain/NonStandardKeys.java (81%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyContext.java} (72%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyStatus.java} (70%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshMessageListenerConcurrently.java} (73%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/AbstractProducer.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
copy eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/EventMeshUtilTest.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/utils/CloudEventUtils.java (60%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService (89%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer (91%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer (91%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/knative-client.properties (84%)
copy eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/EventMeshUtilTest.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImplTest.java (60%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/README.md
copy {eventmesh-examples => eventmesh-connector-plugin/eventmesh-connector-pravega}/build.gradle (63%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pravega/gradle.properties (92%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/pravega-connector.jpg
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java => eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java (61%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConsumerImpl.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaCloudEventWriter.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaEvent.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/SubscribeTask.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfig.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigWrapper.java
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java => eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java (68%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService (90%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer (92%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer (92%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/pravega-connector.properties (64%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/client/PravegaClientTest.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigTest.java
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/resources/pravega-connector.properties (64%)
copy {eventmesh-examples => eventmesh-connector-plugin/eventmesh-connector-pulsar}/build.gradle (55%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pulsar/gradle.properties (95%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/common/EventMeshConstants.java} (82%)
copy eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/java/org/apache/eventmesh/auth/http/basic/config/AuthConfigs.java => eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ClientConfiguration.java (50%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ConfigurationWrapper.java
copy eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.java => eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java (70%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/ProducerImpl.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
copy eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/EventMeshUtilTest.java => eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/utils/CloudEventUtils.java (66%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService (89%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer (91%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer (91%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/pulsar-client.properties (94%)
copy {eventmesh-examples => eventmesh-connector-plugin/eventmesh-connector-redis}/build.gradle (51%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-redis/gradle.properties (95%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/client/RedissonClient.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/ConfigOptions.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/ConfigurationWrapper.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/RedisProperties.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumer.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService (90%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer (92%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer (92%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/redis-client.properties (95%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/client/RedissonClientTest.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector/UnitTest.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumerTest.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/producer/RedisProducerTest.java
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-connector-plugin/eventmesh-connector-redis/src/test/resources/redis-client.properties (93%)
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/UtilsConstants.java
copy eventmesh-protocol-plugin/{eventmesh-protocol-http => eventmesh-protocol-webhook}/build.gradle (91%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-protocol-plugin/eventmesh-protocol-webhook/gradle.properties (95%)
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-webhook/src/main/java/org/apache/eventmesh/protocol/webhook/WebHookProtocolAdaptor.java
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-protocol-plugin/eventmesh-protocol-webhook/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.protocol.api.ProtocolAdaptor (92%)
copy {eventmesh-protocol-plugin/eventmesh-protocol-cloudevents => eventmesh-registry-plugin/eventmesh-registry-consul}/build.gradle (73%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-registry-plugin/eventmesh-registry-consul/gradle.properties (95%)
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry/consul/service/ConsulRegistryService.java
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry/consul/service/HeatBeatScheduler.java
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-registry-plugin/eventmesh-registry-consul/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.registry.RegistryService (91%)
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-consul/src/test/java/ConsulRegistryServiceTest.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-registry-plugin/eventmesh-registry-etcd/build.gradle (76%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-registry-plugin/eventmesh-registry-etcd/gradle.properties (95%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java => eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/constant/EtcdConstant.java (68%)
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdClientFactory.java
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdClientWrapper.java
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdLeaseId.java
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java => eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/factory/EtcdStreamObserver.java (50%)
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/java/org/apache/eventmesh/registry/etcd/service/EtcdRegistryService.java
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties => eventmesh-registry-plugin/eventmesh-registry-etcd/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.registry.RegistryService (92%)
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-etcd/src/test/java/org/apache/eventmesh/registry/etcd/service/EtcdRegistryServiceTest.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/DeleteWebHookConfigHandler.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/InsertWebHookConfigHandler.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByIdHandler.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByManufacturerHandler.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/UpdateWebHookConfigHandler.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/HTTPTrace.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventMeshTrace.java
copy eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/auth/AuthService.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/AsyncHttpProcessor.java (60%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HandlerService.java
copy eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HttpProcessor.java (72%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/WebHookProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/HttpResponseUtils.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/admin/controller/ClientManageControllerTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/admin/handler/QueryRecommendEventMeshHandlerTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/admin/handler/RedirectClientByPathHandlerTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/protocol/processor/WebHookProcessorTest.java
copy eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/{EventMeshUtilTest.java => EventMeshThreadFactoryImplTest.java} (59%)
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/HttpTinyClientTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/IOTinyUtilsTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/NetUtilsTest.java
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/RemotingHelperTest.java
copy eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/{EventMeshUtilTest.java => ValueComparatorTest.java} (60%)
create mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/WebhookUtilTest.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/selector/Selector.java (78%)
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/selector/SelectorException.java (69%)
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/selector/SelectorFactory.java (66%)
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/selector/ServiceInstance.java (61%)
create mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/workflow/EventMeshWorkflowClient.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/workflow/config/EventMeshWorkflowClientConfig.java (70%)
create mode 100644 eventmesh-sdk-rust/.gitignore
create mode 100644 eventmesh-sdk-rust/.vscode/settings.json
create mode 100644 eventmesh-sdk-rust/Cargo.lock
copy .licenserc.yaml => eventmesh-sdk-rust/Cargo.toml (62%)
copy .licenserc.yaml => eventmesh-sdk-rust/eventmesh/Cargo.toml (58%)
create mode 100644 eventmesh-sdk-rust/eventmesh/build.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/proto/eventmesh-client.proto
create mode 100644 eventmesh-sdk-rust/eventmesh/src/constants.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/grpc/config.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/grpc/consumer.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/grpc/mod.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/grpc/producer.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/http/config.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/http/mod.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/http/producer.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/http/protocol_key.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/http/request_code.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/lib.rs
create mode 100644 eventmesh-sdk-rust/eventmesh/src/message.rs
create mode 100644 eventmesh-sdk-rust/examples/Cargo.lock
create mode 100644 eventmesh-sdk-rust/examples/Cargo.toml
create mode 100644 eventmesh-sdk-rust/examples/grpc-consumer-stream.rs
create mode 100644 eventmesh-sdk-rust/examples/grpc-consumer.rs
create mode 100644 eventmesh-sdk-rust/examples/grpc-producer-batch-publish.rs
create mode 100644 eventmesh-sdk-rust/examples/grpc-producer-publish.rs
create mode 100644 eventmesh-sdk-rust/examples/grpc-producer-request.rs
create mode 100644 eventmesh-sdk-rust/examples/http-producer-publish.rs
create mode 100644 eventmesh-sdk-rust/examples/http-producer-request.rs
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/EventMeshExtensionConstant.java (78%)
copy eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/EventMeshUtilTest.java => eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/common/ZipkinConstants.java (62%)
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java => eventmesh-webhook/build.gradle (53%)
create mode 100644 eventmesh-webhook/eventmesh-webhook-admin/bin/.gitignore
copy {eventmesh-protocol-plugin/eventmesh-protocol-meshmessage => eventmesh-webhook/eventmesh-webhook-admin}/build.gradle (62%)
copy {eventmesh-admin => eventmesh-webhook/eventmesh-webhook-admin}/gradle.properties (100%)
create mode 100644 eventmesh-webhook/eventmesh-webhook-admin/src/main/java/org/apache/eventmesh/webhook/admin/AdminWebHookConfigOperationManage.java
create mode 100644 eventmesh-webhook/eventmesh-webhook-admin/src/main/java/org/apache/eventmesh/webhook/admin/FileWebHookConfigOperation.java
create mode 100644 eventmesh-webhook/eventmesh-webhook-admin/src/main/java/org/apache/eventmesh/webhook/admin/NacosWebHookConfigOperation.java
create mode 100644 eventmesh-webhook/eventmesh-webhook-admin/src/test/java/org/apache/eventmesh/webhook/admin/FileWebHookConfigOperationTest.java
create mode 100644 eventmesh-webhook/eventmesh-webhook-api/bin/.gitignore
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-webhook/eventmesh-webhook-api/build.gradle (76%)
copy {eventmesh-admin => eventmesh-webhook/eventmesh-webhook-api}/gradle.properties (100%)
create mode 100644 eventmesh-webhook/eventmesh-webhook-api/src/main/java/org/apache/eventmesh/webhook/api/ManufacturerObject.java
create mode 100644 eventmesh-webhook/eventmesh-webhook-api/src/main/java/org/apache/eventmesh/webhook/api/WebHookConfig.java
copy eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/auth/AuthService.java => eventmesh-webhook/eventmesh-webhook-api/src/main/java/org/apache/eventmesh/webhook/api/WebHookConfigOperation.java (57%)
create mode 100644 eventmesh-webhook/eventmesh-webhook-api/src/main/java/org/apache/eventmesh/webhook/api/WebHookOperationConstant.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-webhook/eventmesh-webhook-api/src/main/java/org/apache/eventmesh/webhook/api/utils/StringUtils.java (80%)
create mode 100644 eventmesh-webhook/eventmesh-webhook-receive/bin/.gitignore
copy {eventmesh-examples => eventmesh-webhook/eventmesh-webhook-receive}/build.gradle (62%)
copy {eventmesh-admin => eventmesh-webhook/eventmesh-webhook-receive}/gradle.properties (100%)
copy eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/auth/AuthService.java => eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/ManufacturerProtocol.java (55%)
create mode 100644 eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/WebHookController.java
create mode 100644 eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/WebHookMQProducer.java
copy eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/EventMeshUtilTest.java => eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/WebHookRequest.java (65%)
create mode 100644 eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/protocol/GithubProtocol.java
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java => eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/protocol/ProtocolManage.java (55%)
rename eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java => eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/storage/AbstractWebHookConfigOperation.java (77%)
create mode 100644 eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/storage/HookConfigOperationManage.java
create mode 100644 eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/storage/WebhookFileListener.java
copy {eventmesh-admin => eventmesh-webhook}/gradle.properties (100%)
create mode 100644 eventmesh-webhook/webhook.jmx
create mode 100644 eventmesh-workflow-go/.golangci.yml
copy .licenserc.yaml => eventmesh-workflow-go/.licenserc.yaml (98%)
create mode 100644 eventmesh-workflow-go/Makefile
create mode 100644 eventmesh-workflow-go/api/proto/workflow.pb.go
copy eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java => eventmesh-workflow-go/api/proto/workflow.proto (68%)
create mode 100644 eventmesh-workflow-go/api/proto/workflow_grpc.pb.go
create mode 100644 eventmesh-workflow-go/api/workflow.go
create mode 100644 eventmesh-workflow-go/cmd/main.go
create mode 100644 eventmesh-workflow-go/config/config.go
create mode 100644 eventmesh-workflow-go/configs/workflow.yaml
create mode 100644 eventmesh-workflow-go/flow/engine.go
create mode 100644 eventmesh-workflow-go/flow/error.go
create mode 100644 eventmesh-workflow-go/flow/model.go
create mode 100644 eventmesh-workflow-go/go.mod
create mode 100644 eventmesh-workflow-go/go.sum
create mode 100644 eventmesh-workflow-go/internal/constants/constants.go
create mode 100644 eventmesh-workflow-go/internal/dal/config.go
create mode 100644 eventmesh-workflow-go/internal/dal/model/workflow.go
create mode 100644 eventmesh-workflow-go/internal/dal/model/workflow_task.go
create mode 100644 eventmesh-workflow-go/internal/dal/workflow.go
create mode 100644 eventmesh-workflow-go/internal/queue/in_memory_queue.go
create mode 100644 eventmesh-workflow-go/internal/queue/queue.go
create mode 100644 eventmesh-workflow-go/internal/schedule/scheduler.go
create mode 100644 eventmesh-workflow-go/internal/task/event_task.go
create mode 100644 eventmesh-workflow-go/internal/task/operation_task.go
create mode 100644 eventmesh-workflow-go/internal/task/switch_task.go
create mode 100644 eventmesh-workflow-go/internal/task/task.go
create mode 100644 eventmesh-workflow-go/internal/util/flow_util.go
create mode 100644 eventmesh-workflow-go/main.go
create mode 100644 eventmesh-workflow-go/middleware/dblock/errors.go
create mode 100644 eventmesh-workflow-go/middleware/dblock/lock.go
create mode 100644 eventmesh-workflow-go/middleware/dblock/lock_client.go
create mode 100644 eventmesh-workflow-go/server.go
create mode 100644 eventmesh-workflow-go/third_party/jqer/jqer.go
create mode 100644 eventmesh-workflow-go/third_party/jqer/options.go
create mode 100644 eventmesh-workflow-go/third_party/swf/swf.go
create mode 100644 eventmesh-workflow-go/third_party/swf/swf_test.go
create mode 100644 eventmesh-workflow-go/third_party/swf/testdata/greeting.yaml
create mode 100644 tools/third-party-licenses/licenses/java/LICENSE-animal-sniffer-annotations.txt
copy tools/third-party-licenses/licenses/java/{LICENSE-snakeyam.txt => LICENSE-async-http-client-netty-utils.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-assertj-core.txt => LICENSE-async-http-client.txt} (100%)
create mode 100644 tools/third-party-licenses/licenses/java/LICENSE-bcpkix-jdk15on.txt
create mode 100644 tools/third-party-licenses/licenses/java/LICENSE-bcprov-jdk15on.txt
create mode 100644 tools/third-party-licenses/licenses/java/LICENSE-bcutil-jdk15on.txt
copy tools/third-party-licenses/licenses/{go/LICENSE-cloud.google.com-go.txt => java/LICENSE-commons-io.txt} (100%)
rename tools/third-party-licenses/licenses/java/{LICENSE-snakeyam.txt => LICENSE-consul-api.txt} (98%)
copy tools/third-party-licenses/licenses/java/{LICENSE-protobuf-java.txt => LICENSE-google-auth-library-credentials.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-grpc-context.txt => LICENSE-grpc-auth.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-grpc-context.txt => LICENSE-grpc-grpclb.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-jcommander.txt => LICENSE-jetcd-common.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-jcommander.txt => LICENSE-jetcd-core.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-jcommander.txt => LICENSE-jetcd-resolver.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-netty-all.txt => LICENSE-netty-reactive-streams.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-cloud.google.com-go.txt => java/LICENSE-pravega-client.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-cloud.google.com-go.txt => java/LICENSE-pravega-common.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-cloud.google.com-go.txt => java/LICENSE-pravega-shared-authplugin.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-cloud.google.com-go.txt => java/LICENSE-pravega-shared-controller-api.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-cloud.google.com-go.txt => java/LICENSE-pravega-shared-protocol.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-cloud.google.com-go.txt => java/LICENSE-pravega-shared-security.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-protobuf-java.txt => LICENSE-protobuf-java-util.txt} (100%)
create mode 100644 tools/third-party-licenses/licenses/java/LICENSE-redisson.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org
[incubator-eventmesh] 01/01: Merge remote-tracking branch 'apache/master' into kafka-connector
Posted by mi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch kafka-connector
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit e0cdb2c18202949e0d5f7a41d6f5831c74c9dd22
Merge: 2768d047 b560c2a3
Author: xwm1992 <mi...@126.com>
AuthorDate: Sun Sep 25 17:27:47 2022 +0800
Merge remote-tracking branch 'apache/master' into kafka-connector
# Conflicts:
# settings.gradle
# tools/dependency-check/known-dependencies.txt
.github/ISSUE_TEMPLATE/bug_report.yml | 1 +
.github/PULL_REQUEST_TEMPLATE.md | 4 +-
.github/workflows/greetings.yml | 4 +-
.gitignore | 3 +-
.licenserc.yaml | 1 +
README.md | 52 +-
README.zh-CN.md | 38 +-
build.gradle | 26 +-
docs/en/design-document/03-stream.md | 2 +-
docs/en/design-document/09-event-bridge.md | 156 ++
docs/en/design-document/10-knative-connector.md | 93 ++
docs/en/instruction/01-store-with-docker.md | 74 +-
docs/en/instruction/01-store.md | 47 +-
docs/en/instruction/02-runtime-with-docker.md | 22 +-
docs/en/instruction/02-runtime.md | 80 +-
docs/en/instruction/03-demo.md | 187 +--
docs/en/roadmap.md | 56 +-
.../images/design-document/event-bridge-detail.png | Bin 0 -> 563043 bytes
.../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/01-workflow.md | 258 ++++
docs/zh/desing-document/03-stream.md | 115 ++
docs/zh/desing-document/06-cloudevents.md | 102 ++
docs/zh/desing-document/09-event-bridge.md | 156 ++
docs/zh/desing-document/10-knative-connector.md | 91 ++
.../zh/desing-document/eventmesh-unit-test-rule.md | 124 --
docs/zh/desing-document/webhook.md | 268 ++++
docs/zh/instruction/00-eclipse.md | 2 +-
docs/zh/instruction/01-store-with-docker.md | 20 +-
docs/zh/instruction/02-runtime-with-docker.md | 2 +-
docs/zh/instruction/02-runtime.md | 94 +-
docs/zh/instruction/03-demo.md | 82 +-
docs/zh/roadmap.md | 54 +-
.../apache/eventmesh/admin/rocketmq/Constants.java | 6 +
.../admin/rocketmq/handler/TopicsHandler.java | 30 +-
.../eventmesh/admin/rocketmq/util/JsonUtils.java | 9 +
eventmesh-catalog-go/.golangci.yml | 99 ++
eventmesh-catalog-go/Makefile | 40 +
eventmesh-catalog-go/api/catalog.go | 112 ++
eventmesh-catalog-go/api/proto/catalog.pb.go | 390 +++++
.../api/proto/catalog.proto | 37 +-
eventmesh-catalog-go/api/proto/catalog_grpc.pb.go | 157 ++
eventmesh-catalog-go/cmd/main.go | 20 +
eventmesh-catalog-go/config/config.go | 28 +
eventmesh-catalog-go/configs/catalog.yaml | 44 +
eventmesh-catalog-go/go.mod | 74 +
eventmesh-catalog-go/go.sum | 406 +++++
.../internal/constants/constants.go | 18 +
eventmesh-catalog-go/internal/dal/catalog.go | 55 +
eventmesh-catalog-go/internal/dal/config.go | 48 +
eventmesh-catalog-go/internal/dal/model/event.go | 35 +
.../internal/dal/model/event_catalog.go | 35 +
eventmesh-catalog-go/internal/util/catalog_util.go | 60 +
eventmesh-catalog-go/main.go | 40 +
eventmesh-catalog-go/pkg/asyncapi/decode.go | 29 +
eventmesh-catalog-go/pkg/asyncapi/document.go | 212 +++
eventmesh-catalog-go/pkg/asyncapi/v2/decode.go | 114 ++
eventmesh-catalog-go/pkg/asyncapi/v2/v2.go | 887 +++++++++++
eventmesh-catalog-go/server.go | 141 ++
eventmesh-common/build.gradle | 6 +-
.../org/apache/eventmesh/common/Constants.java | 79 +-
.../common/config/CommonConfiguration.java | 47 +-
.../common/config/ConfigurationWrapper.java | 40 +-
.../protocol/catalog/protos/CatalogGrpc.java | 385 +++++
.../catalog/protos/EventmeshCatalogGrpc.java | 132 ++
.../common/protocol/catalog/protos/Operation.java | 969 ++++++++++++
.../catalog/protos/OperationOrBuilder.java | 80 +
.../catalog/protos/QueryOperationsRequest.java | 787 ++++++++++
.../protos/QueryOperationsRequestOrBuilder.java | 57 +
.../catalog/protos/QueryOperationsResponse.java | 858 +++++++++++
.../protos/QueryOperationsResponseOrBuilder.java | 55 +
.../protocol/catalog/protos/RegistryRequest.java | 787 ++++++++++
.../catalog/protos/RegistryRequestOrBuilder.java | 57 +
.../protocol/catalog/protos/RegistryResponse.java | 479 ++++++
.../catalog/protos/RegistryResponseOrBuilder.java | 10 +-
.../protocol/grpc/protos/ConsumerServiceGrpc.java | 2 +-
.../protocol/grpc/protos/HeartbeatServiceGrpc.java | 2 +-
.../protocol/grpc/protos/PublisherServiceGrpc.java | 2 +-
.../http/WebhookProtocolTransportObject.java | 32 +-
.../protocol/http/common/EventMeshRetCode.java | 29 +-
.../eventmesh/common/protocol/tcp/codec/Codec.java | 11 +-
.../workflow/protos/EventmeshWorkflowGrpc.java | 85 ++
.../protocol/workflow/protos/ExecuteRequest.java | 851 +++++++++++
.../workflow/protos/ExecuteRequestOrBuilder.java | 63 +
.../protocol/workflow/protos/ExecuteResponse.java | 575 +++++++
.../workflow/protos/ExecuteResponseOrBuilder.java | 30 +-
.../protocol/workflow/protos/WorkflowGrpc.java | 294 ++++
.../org/apache/eventmesh/common/utils/IPUtils.java | 4 +-
.../eventmesh/common/utils/PropertiesUtils.java | 64 +
.../common/utils/PropertiesUtilsTest.java | 43 +
.../apache/eventmesh/api/consumer/Consumer.java | 4 +-
.../eventmesh-connector-knative}/build.gradle | 28 +-
.../eventmesh-connector-knative/gradle.properties | 6 +-
.../knative/cloudevent/KnativeMessageFactory.java | 27 +-
.../impl/KnativeBinaryMessageReader.java | 56 +
.../knative/cloudevent/impl/KnativeHeaders.java | 19 +-
.../cloudevent/impl/KnativeMessageWriter.java | 73 +
.../knative/common/EventMeshConstants.java} | 7 +-
.../knative/config/ClientConfiguration.java | 44 +
.../knative/config/ConfigurationWrapper.java | 71 +
.../ConnectorResourceServiceKnativeImpl.java | 15 +-
.../knative/consumer/DefaultConsumer.java | 69 +
.../knative/consumer/KnativeConsumerImpl.java | 88 ++
.../knative/consumer/PullConsumerImpl.java | 168 ++
.../connector/knative/domain/NonStandardKeys.java | 12 +-
.../EventMeshConsumeConcurrentlyContext.java} | 13 +-
.../patch/EventMeshConsumeConcurrentlyStatus.java} | 18 +-
.../EventMeshMessageListenerConcurrently.java} | 7 +-
.../knative/producer/AbstractProducer.java | 64 +
.../knative/producer/KnativeProducerImpl.java | 93 ++
.../connector/knative/producer/ProducerImpl.java | 127 ++
.../connector/knative/utils/CloudEventUtils.java | 20 +-
...ventmesh.api.connector.ConnectorResourceService | 4 +-
.../org.apache.eventmesh.api.consumer.Consumer | 4 +-
.../org.apache.eventmesh.api.producer.Producer | 4 +-
.../src/main/resources/knative-client.properties | 4 +-
.../knative/consumer/KnativeConsumerImplTest.java | 22 +-
.../knative/producer/KnativeProducerImplTest.java | 58 +
.../eventmesh-connector-pravega/README.md | 19 +
.../eventmesh-connector-pravega}/build.gradle | 23 +-
.../eventmesh-connector-pravega/gradle.properties | 6 +-
.../pravega-connector.jpg | Bin 0 -> 143684 bytes
.../PravegaConnectorResourceServiceImpl.java | 24 +-
.../connector/pravega/PravegaConsumerImpl.java | 95 ++
.../connector/pravega/PravegaProducerImpl.java | 108 ++
.../connector/pravega/client/PravegaClient.java | 227 +++
.../pravega/client/PravegaCloudEventWriter.java | 70 +
.../connector/pravega/client/PravegaEvent.java | 76 +
.../connector/pravega/client/SubscribeTask.java | 87 ++
.../pravega/config/PravegaConnectorConfig.java | 113 ++
.../config/PravegaConnectorConfigWrapper.java | 71 +
.../exception/PravegaConnectorException.java | 16 +-
...ventmesh.api.connector.ConnectorResourceService | 4 +-
.../org.apache.eventmesh.api.consumer.Consumer | 4 +-
.../org.apache.eventmesh.api.producer.Producer | 4 +-
.../main/resources/pravega-connector.properties | 12 +-
.../pravega/client/PravegaClientTest.java | 183 +++
.../pravega/config/PravegaConnectorConfigTest.java | 81 +
.../test/resources/pravega-connector.properties | 12 +-
.../eventmesh-connector-pulsar}/build.gradle | 33 +-
.../eventmesh-connector-pulsar/gradle.properties | 4 +-
.../pulsar/common/EventMeshConstants.java} | 7 +-
.../pulsar/config/ClientConfiguration.java | 33 +-
.../pulsar/config/ConfigurationWrapper.java | 72 +
.../ConnectorResourceServicePulsarImpl.java | 17 +-
.../pulsar/producer/AbstractProducer.java | 58 +
.../connector/pulsar/producer/ProducerImpl.java | 102 ++
.../pulsar/producer/PulsarProducerImpl.java | 91 ++
.../connector/pulsar/utils/CloudEventUtils.java | 20 +-
...ventmesh.api.connector.ConnectorResourceService | 4 +-
.../org.apache.eventmesh.api.consumer.Consumer | 4 +-
.../org.apache.eventmesh.api.producer.Producer | 4 +-
.../src/main/resources/pulsar-client.properties | 2 +-
.../eventmesh-connector-redis}/build.gradle | 36 +-
.../eventmesh-connector-redis/gradle.properties | 4 +-
.../connector/redis/client/RedissonClient.java | 148 ++
.../redis/cloudevent/CloudEventCodec.java | 60 +
.../connector/redis/config/ConfigOptions.java | 51 +
.../redis/config/ConfigurationWrapper.java | 73 +
.../connector/redis/config/RedisProperties.java | 94 ++
.../connector/RedisConnectorResourceService.java | 33 +
.../connector/redis/consumer/RedisConsumer.java | 131 ++
.../connector/redis/producer/RedisProducer.java | 139 ++
...ventmesh.api.connector.ConnectorResourceService | 4 +-
.../org.apache.eventmesh.api.consumer.Consumer | 4 +-
.../org.apache.eventmesh.api.producer.Producer | 4 +-
.../src/main/resources/redis-client.properties | 1 -
.../connector/redis/AbstractRedisServer.java | 41 +
.../connector/redis/client/RedissonClientTest.java | 31 +
.../connector/redis/connector/UnitTest.java | 109 ++
.../redis/consumer/RedisConsumerTest.java | 90 ++
.../redis/producer/RedisProducerTest.java | 109 ++
.../src/test/resources/redis-client.properties | 2 +-
.../rocketmq/config/ClientConfiguration.java | 32 +-
.../rocketmq/consumer/PushConsumerImpl.java | 1 -
.../rocketmq/consumer/RocketMQConsumerImpl.java | 20 +-
.../rocketmq/producer/AbstractProducer.java | 4 +-
.../rocketmq/producer/RocketMQProducerImpl.java | 13 +-
.../apache/rocketmq/producer/ProducerImplTest.java | 3 +-
eventmesh-examples/build.gradle | 2 +-
.../cloudevents/CloudEventsPublishInstance.java | 2 +-
.../cloudevents/CloudEventsRequestInstance.java | 2 +-
.../eventmeshmessage/AsyncPublishBroadcast.java | 2 +-
.../pub/eventmeshmessage/AsyncPublishInstance.java | 2 +-
.../pub/eventmeshmessage/RequestReplyInstance.java | 2 +-
.../eventmesh/grpc/sub/app/service/SubService.java | 2 +-
.../demo/pub/cloudevents/AsyncPublishInstance.java | 6 +-
.../pub/eventmeshmessage/AsyncPublishInstance.java | 2 +-
.../http/demo/sub/service/SubService.java | 2 +-
.../eventmesh/tcp/common/EventMeshTestUtils.java | 106 +-
.../eventmesh/tcp/common/UtilsConstants.java | 52 +
.../config/PrometheusConfigurationTest.java | 2 +-
.../src/test/resources/prometheus.properties | 2 +-
.../eventmesh-protocol-cloudevents/build.gradle | 5 +-
.../cloudevents/CloudEventsProtocolAdaptor.java | 2 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 60 +-
.../eventmesh-protocol-grpc/build.gradle | 9 +-
.../eventmesh-protocol-http/build.gradle | 5 +-
.../protocol/http/HttpProtocolAdaptor.java | 3 +-
.../protocol/http/HttpProtocolConstant.java | 15 +
.../http/resolver/HttpRequestProtocolResolver.java | 34 +-
.../eventmesh-protocol-meshmessage/build.gradle | 5 +-
.../meshmessage/MeshMessageProtocolAdaptor.java | 2 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 4 +-
.../resolver/tcp/TcpMessageProtocolResolver.java | 12 +-
.../build.gradle | 2 -
.../eventmesh-protocol-webhook/gradle.properties | 4 +-
.../protocol/webhook/WebHookProtocolAdaptor.java | 87 ++
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 4 +-
.../api/registry/dto/EventMeshDataInfo.java | 4 +
.../eventmesh-registry-consul}/build.gradle | 10 +-
.../eventmesh-registry-consul/gradle.properties | 3 +-
.../consul/service/ConsulRegistryService.java | 165 ++
.../registry/consul/service/HeatBeatScheduler.java | 103 ++
...g.apache.eventmesh.api.registry.RegistryService | 4 +-
.../src/test/java/ConsulRegistryServiceTest.java | 128 ++
.../eventmesh-registry-etcd/build.gradle | 10 +-
.../eventmesh-registry-etcd/gradle.properties | 3 +-
.../registry/etcd/constant/EtcdConstant.java | 24 +-
.../registry/etcd/factory/EtcdClientFactory.java | 116 ++
.../registry/etcd/factory/EtcdClientWrapper.java | 79 +
.../registry/etcd/factory/EtcdLeaseId.java | 88 ++
.../registry/etcd/factory/EtcdStreamObserver.java | 38 +-
.../registry/etcd/service/EtcdRegistryService.java | 282 ++++
...g.apache.eventmesh.api.registry.RegistryService | 4 +-
.../etcd/service/EtcdRegistryServiceTest.java | 122 ++
eventmesh-runtime/build.gradle | 11 +-
eventmesh-runtime/conf/eventmesh.properties | 15 +-
.../admin/controller/ClientManageController.java | 24 +
.../admin/handler/DeleteWebHookConfigHandler.java | 64 +
.../admin/handler/InsertWebHookConfigHandler.java | 63 +
.../handler/QueryRecommendEventMeshHandler.java | 16 +-
.../handler/QueryWebHookConfigByIdHandler.java | 66 +
.../QueryWebHookConfigByManufacturerHandler.java | 68 +
.../handler/RedirectClientByIpPortHandler.java | 7 +-
.../admin/handler/RedirectClientByPathHandler.java | 7 +-
.../handler/RedirectClientBySubSystemHandler.java | 7 +-
.../admin/handler/RejectAllClientHandler.java | 5 +-
.../admin/handler/RejectClientByIpPortHandler.java | 7 +-
.../handler/RejectClientBySubSystemHandler.java | 7 +-
.../admin/handler/ShowClientBySystemHandler.java | 3 +-
.../runtime/admin/handler/ShowClientHandler.java | 3 +-
.../handler/ShowListenClientByTopicHandler.java | 3 +-
.../admin/handler/UpdateWebHookConfigHandler.java | 63 +
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 71 +-
.../runtime/boot/EventMeshGrpcServer.java | 4 -
.../runtime/boot/EventMeshHTTPServer.java | 50 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 30 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 8 +-
.../apache/eventmesh/runtime/boot/HTTPTrace.java | 138 ++
.../eventmesh/runtime/common/EventMeshTrace.java | 36 +
.../configuration/EventMeshGrpcConfiguration.java | 46 +-
.../configuration/EventMeshHTTPConfiguration.java | 56 +-
.../configuration/EventMeshTCPConfiguration.java | 52 +-
.../runtime/constants/EventMeshConstants.java | 13 +-
.../core/consumergroup/ProducerGroupConf.java | 9 +-
.../eventmesh/runtime/core/plugin/MQWrapper.java | 2 -
.../consumergroup/ConsumerGroupTopicConfig.java | 1 -
.../grpc/processor/HeartbeatProcessor.java | 1 -
.../protocol/grpc/producer/EventMeshProducer.java | 7 +-
.../protocol/grpc/push/WebhookPushRequest.java | 65 +-
.../protocol/grpc/service/ProducerService.java | 2 +-
.../protocol/http/consumer/EventMeshConsumer.java | 12 +-
.../protocol/http/consumer/HandleMsgContext.java | 8 +-
.../http/processor/AsyncHttpProcessor.java | 24 +-
.../http/processor/BatchSendMessageProcessor.java | 15 +-
.../processor/BatchSendMessageV2Processor.java | 2 -
.../protocol/http/processor/HandlerService.java | 366 +++++
.../protocol/http/processor/HttpProcessor.java | 14 +-
.../processor/LocalSubscribeEventProcessor.java | 104 +-
.../processor/LocalUnSubscribeEventProcessor.java | 90 +-
.../processor/RemoteSubscribeEventProcessor.java | 109 +-
.../processor/RemoteUnSubscribeEventProcessor.java | 81 +-
.../http/processor/ReplyMessageProcessor.java | 1 -
.../http/processor/SendAsyncEventProcessor.java | 180 +--
.../http/processor/SendAsyncMessageProcessor.java | 6 +-
.../processor/SendAsyncRemoteEventProcessor.java | 186 +--
.../protocol/http/processor/WebHookProcessor.java | 60 +
.../http/processor/inf/AbstractEventProcessor.java | 2 +-
.../core/protocol/http/push/HTTPClientPool.java | 19 +-
.../protocol/http/push/HTTPMessageHandler.java | 3 +-
.../tcp/client/group/ClientGroupWrapper.java | 55 +-
.../core/protocol/tcp/client/session/Session.java | 7 +
.../tcp/client/session/push/SessionPusher.java | 7 +-
.../client/session/send/UpStreamMsgContext.java | 26 +-
.../tcp/client/task/MessageTransferTask.java | 9 +-
.../eventmesh/runtime/registry/Registry.java | 37 +-
.../org/apache/eventmesh/runtime/trace/Trace.java | 6 +-
.../apache/eventmesh/runtime/trace/TraceUtils.java | 2 +-
.../eventmesh/runtime/util/EventMeshUtil.java | 36 +-
.../eventmesh/runtime/util/HttpResponseUtils.java | 69 +
.../eventmesh/runtime/util/RemotingHelper.java | 3 -
.../eventmesh/runtime/util/ValueComparator.java | 3 +-
.../apache/eventmesh/runtime/util/WebhookUtil.java | 5 +-
.../controller/ClientManageControllerTest.java | 65 +
.../QueryRecommendEventMeshHandlerTest.java | 98 ++
.../handler/RedirectClientByPathHandlerTest.java | 130 ++
.../runtime/client/common/MessageUtils.java | 2 +-
.../protocol/processor/WebHookProcessorTest.java | 116 ++
...st.java => EventMeshThreadFactoryImplTest.java} | 22 +-
.../eventmesh/runtime/util/EventMeshUtilTest.java | 155 ++
.../eventmesh/runtime/util/HttpTinyClientTest.java | 76 +
.../eventmesh/runtime/util/IOTinyUtilsTest.java | 130 ++
.../eventmesh/runtime/util/NetUtilsTest.java | 52 +
.../eventmesh/runtime/util/RemotingHelperTest.java | 59 +
...tMeshUtilTest.java => ValueComparatorTest.java} | 22 +-
.../eventmesh/runtime/util/WebhookUtilTest.java | 76 +
eventmesh-sdk-java/build.gradle | 9 +-
.../client/grpc/producer/CloudEventProducer.java | 4 +-
.../grpc/producer/EventMeshGrpcProducer.java | 4 +-
.../client/grpc/util/EventMeshClientUtil.java | 8 +-
.../producer/RRCallbackResponseHandlerAdapter.java | 2 +-
.../eventmesh/client/http/util/HttpUtils.java | 8 +-
.../apache/eventmesh/client/selector/Selector.java | 10 +-
.../client/selector/SelectorException.java | 16 +-
.../eventmesh/client/selector/SelectorFactory.java | 22 +-
.../eventmesh/client/selector/ServiceInstance.java | 30 +-
.../client/tcp/common/EventMeshCommon.java | 14 +-
.../client/workflow/EventMeshWorkflowClient.java | 62 +
.../config/EventMeshWorkflowClientConfig.java | 16 +-
.../client/grpc/util/EventMeshClientUtilTest.java | 2 +-
eventmesh-sdk-rust/.gitignore | 2 +
eventmesh-sdk-rust/.vscode/settings.json | 3 +
eventmesh-sdk-rust/Cargo.lock | 1606 ++++++++++++++++++++
.licenserc.yaml => eventmesh-sdk-rust/Cargo.toml | 30 +-
.../eventmesh/Cargo.toml | 44 +-
eventmesh-sdk-rust/eventmesh/build.rs | 21 +
.../eventmesh/proto/eventmesh-client.proto | 150 ++
eventmesh-sdk-rust/eventmesh/src/constants.rs | 24 +
eventmesh-sdk-rust/eventmesh/src/grpc/config.rs | 54 +
eventmesh-sdk-rust/eventmesh/src/grpc/consumer.rs | 263 ++++
eventmesh-sdk-rust/eventmesh/src/grpc/mod.rs | 27 +
eventmesh-sdk-rust/eventmesh/src/grpc/producer.rs | 127 ++
eventmesh-sdk-rust/eventmesh/src/http/config.rs | 29 +
eventmesh-sdk-rust/eventmesh/src/http/mod.rs | 38 +
eventmesh-sdk-rust/eventmesh/src/http/producer.rs | 117 ++
.../eventmesh/src/http/protocol_key.rs | 34 +
.../eventmesh/src/http/request_code.rs | 76 +
eventmesh-sdk-rust/eventmesh/src/lib.rs | 22 +
eventmesh-sdk-rust/eventmesh/src/message.rs | 55 +
eventmesh-sdk-rust/examples/Cargo.lock | 1044 +++++++++++++
eventmesh-sdk-rust/examples/Cargo.toml | 63 +
.../examples/grpc-consumer-stream.rs | 93 ++
eventmesh-sdk-rust/examples/grpc-consumer.rs | 81 +
.../examples/grpc-producer-batch-publish.rs | 57 +
.../examples/grpc-producer-publish.rs | 57 +
.../examples/grpc-producer-request.rs | 57 +
.../examples/http-producer-publish.rs | 56 +
.../examples/http-producer-request.rs | 56 +
.../org/apache/eventmesh/api/auth/AuthService.java | 2 +-
.../auth/http/basic/config/AuthConfigs.java | 12 +-
.../auth/http/basic/impl/AuthHttpBasicService.java | 4 +-
.../spi/loader/EventMeshExtensionConstant.java | 9 +-
.../spi/loader/JarExtensionClassLoader.java | 9 +-
.../spi/loader/MetaInfExtensionClassLoader.java | 4 +-
.../trace/api/common/EventMeshTraceConstants.java | 4 +
.../trace/api/config/ExporterConfiguration.java | 10 +-
.../eventmesh/trace/zipkin/ZipkinTraceService.java | 14 +-
.../trace/zipkin/common/ZipkinConstants.java | 21 +-
.../trace/zipkin/config/ZipkinConfiguration.java | 12 +-
.../build.gradle | 30 +-
.../eventmesh-webhook-admin/bin/.gitignore | 1 +
.../eventmesh-webhook-admin}/build.gradle | 17 +-
.../eventmesh-webhook-admin/gradle.properties | 4 +-
.../admin/AdminWebHookConfigOperationManage.java | 80 +
.../webhook/admin/FileWebHookConfigOperation.java | 172 +++
.../webhook/admin/NacosWebHookConfigOperation.java | 204 +++
.../admin/FileWebHookConfigOperationTest.java | 77 +
.../eventmesh-webhook-api/bin/.gitignore | 1 +
.../eventmesh-webhook-api/build.gradle | 9 +-
.../eventmesh-webhook-api/gradle.properties | 4 +-
.../eventmesh/webhook/api/ManufacturerObject.java | 64 +
.../eventmesh/webhook/api/WebHookConfig.java | 95 ++
.../webhook/api/WebHookConfigOperation.java | 24 +-
.../webhook/api/WebHookOperationConstant.java | 51 +
.../eventmesh/webhook/api/utils/StringUtils.java | 8 +-
.../eventmesh-webhook-receive/bin/.gitignore | 1 +
.../eventmesh-webhook-receive}/build.gradle | 35 +-
.../eventmesh-webhook-receive/gradle.properties | 4 +-
.../webhook/receive/ManufacturerProtocol.java | 27 +-
.../webhook/receive/WebHookController.java | 129 ++
.../webhook/receive/WebHookMQProducer.java | 68 +
.../eventmesh/webhook/receive/WebHookRequest.java | 33 +-
.../webhook/receive/protocol/GithubProtocol.java | 100 ++
.../webhook/receive/protocol/ProtocolManage.java | 31 +-
.../storage/AbstractWebHookConfigOperation.java | 9 +-
.../receive/storage/HookConfigOperationManage.java | 118 ++
.../receive/storage/WebhookFileListener.java | 201 +++
.../gradle.properties | 4 +-
eventmesh-webhook/webhook.jmx | 122 ++
eventmesh-workflow-go/.golangci.yml | 99 ++
.../.licenserc.yaml | 1 +
eventmesh-workflow-go/Makefile | 40 +
eventmesh-workflow-go/api/proto/workflow.pb.go | 255 ++++
.../api/proto/workflow.proto | 24 +-
.../api/proto/workflow_grpc.pb.go | 121 ++
eventmesh-workflow-go/api/workflow.go | 54 +
eventmesh-workflow-go/cmd/main.go | 20 +
eventmesh-workflow-go/config/config.go | 36 +
eventmesh-workflow-go/configs/workflow.yaml | 71 +
eventmesh-workflow-go/flow/engine.go | 82 +
eventmesh-workflow-go/flow/error.go | 21 +
eventmesh-workflow-go/flow/model.go | 22 +
eventmesh-workflow-go/go.mod | 35 +
eventmesh-workflow-go/go.sum | 480 ++++++
.../internal/constants/constants.go | 60 +
eventmesh-workflow-go/internal/dal/config.go | 59 +
.../internal/dal/model/workflow.go | 46 +
.../internal/dal/model/workflow_task.go | 87 ++
eventmesh-workflow-go/internal/dal/workflow.go | 423 ++++++
.../internal/queue/in_memory_queue.go | 86 ++
eventmesh-workflow-go/internal/queue/queue.go | 40 +
.../internal/schedule/scheduler.go | 112 ++
eventmesh-workflow-go/internal/task/event_task.go | 35 +
.../internal/task/operation_task.go | 35 +
eventmesh-workflow-go/internal/task/switch_task.go | 34 +
eventmesh-workflow-go/internal/task/task.go | 37 +
eventmesh-workflow-go/internal/util/flow_util.go | 60 +
eventmesh-workflow-go/main.go | 41 +
eventmesh-workflow-go/middleware/dblock/errors.go | 27 +
eventmesh-workflow-go/middleware/dblock/lock.go | 70 +
.../middleware/dblock/lock_client.go | 116 ++
eventmesh-workflow-go/server.go | 130 ++
eventmesh-workflow-go/third_party/jqer/jqer.go | 377 +++++
eventmesh-workflow-go/third_party/jqer/options.go | 55 +
eventmesh-workflow-go/third_party/swf/swf.go | 29 +
eventmesh-workflow-go/third_party/swf/swf_test.go | 32 +
.../third_party/swf/testdata/greeting.yaml | 79 +
settings.gradle | 14 +
tools/dependency-check/check-dependencies.sh | 2 +-
tools/dependency-check/known-dependencies.txt | 111 +-
tools/third-party-licenses/LICENSE | 34 +-
.../java/LICENSE-animal-sniffer-annotations.txt | 21 +
...t => LICENSE-async-http-client-netty-utils.txt} | 0
...-snakeyam.txt => LICENSE-async-http-client.txt} | 0
.../licenses/java/LICENSE-bcpkix-jdk15on.txt | 22 +
.../licenses/java/LICENSE-bcprov-jdk15on.txt | 22 +
.../licenses/java/LICENSE-bcutil-jdk15on.txt | 22 +
...LICENSE-snakeyam.txt => LICENSE-commons-io.txt} | 2 +-
...LICENSE-snakeyam.txt => LICENSE-consul-api.txt} | 7 +-
.../LICENSE-google-auth-library-credentials.txt | 48 +
...{LICENSE-snakeyam.txt => LICENSE-grpc-auth.txt} | 40 +
...ICENSE-snakeyam.txt => LICENSE-grpc-grpclb.txt} | 40 +
...CENSE-snakeyam.txt => LICENSE-jetcd-common.txt} | 2 +-
...LICENSE-snakeyam.txt => LICENSE-jetcd-core.txt} | 2 +-
...NSE-snakeyam.txt => LICENSE-jetcd-resolver.txt} | 2 +-
.../licenses/java/LICENSE-nacos-client.txt | 614 +++-----
...eyam.txt => LICENSE-netty-reactive-streams.txt} | 6 +-
...NSE-snakeyam.txt => LICENSE-pravega-client.txt} | 2 +-
...NSE-snakeyam.txt => LICENSE-pravega-common.txt} | 2 +-
...m.txt => LICENSE-pravega-shared-authplugin.txt} | 2 +-
...t => LICENSE-pravega-shared-controller-api.txt} | 2 +-
...yam.txt => LICENSE-pravega-shared-protocol.txt} | 2 +-
...yam.txt => LICENSE-pravega-shared-security.txt} | 2 +-
.../licenses/java/LICENSE-protobuf-java-util.txt | 48 +
.../licenses/java/LICENSE-redisson.txt | 13 +
458 files changed, 29633 insertions(+), 2704 deletions(-)
diff --cc eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java
index e7f8e976,12a3f8a0..3afac9f2
--- a/eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java
+++ b/eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java
@@@ -25,6 -25,6 +25,6 @@@ public class PrometheusConfigurationTes
@Test
public void getEventMeshPrometheusPort() {
int eventMeshPrometheusPort = PrometheusConfiguration.getEventMeshPrometheusPort();
- Assert.assertEquals(19091, eventMeshPrometheusPort);
+ Assert.assertEquals(19090, eventMeshPrometheusPort);
}
-}
+}
diff --cc eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
index 590043d8,65317c3d..f90be33b
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
@@@ -422,9 -422,9 +423,9 @@@ public class ClientGroupWrapper
persistentMsgConsumer.init(keyValue);
- EventListener listener = (event, context) -> {
+ EventListener listener = (CloudEvent event, AsyncConsumeContext context) -> {
String protocolVersion =
- Objects.requireNonNull(event.getExtension(Constants.PROTOCOL_VERSION)).toString();
+ Objects.requireNonNull(event.getSpecVersion()).toString();
Span span = TraceUtils.prepareServerSpan(
EventMeshUtil.getCloudEventExtensionMap(protocolVersion, event),
diff --cc settings.gradle
index 5ae496f7,dca98b25..ad11e768
--- a/settings.gradle
+++ b/settings.gradle
@@@ -24,9 -24,12 +24,13 @@@ include 'eventmesh-starter
include 'eventmesh-examples'
include 'eventmesh-spi'
include 'eventmesh-connector-plugin:eventmesh-connector-api'
+ include 'eventmesh-connector-plugin:eventmesh-connector-knative'
+ include 'eventmesh-connector-plugin:eventmesh-connector-pravega'
include 'eventmesh-connector-plugin:eventmesh-connector-rocketmq'
include 'eventmesh-connector-plugin:eventmesh-connector-standalone'
+include 'eventmesh-connector-plugin:eventmesh-connector-kafka'
+ include 'eventmesh-connector-plugin:eventmesh-connector-pulsar'
+ include 'eventmesh-connector-plugin:eventmesh-connector-redis'
include 'eventmesh-security-plugin:eventmesh-security-api'
include 'eventmesh-security-plugin:eventmesh-security-acl'
include 'eventmesh-registry-plugin:eventmesh-registry-api'
diff --cc tools/dependency-check/known-dependencies.txt
index b6f6a501,8fadc114..f604345b
--- a/tools/dependency-check/known-dependencies.txt
+++ b/tools/dependency-check/known-dependencies.txt
@@@ -1,10 -1,23 +1,24 @@@
- animal-sniffer-annotations-1.17.jar
+ animal-sniffer-annotations-1.19.jar
+ annotations-4.1.1.4.jar
assertj-core-2.6.0.jar
+ async-http-client-2.12.0.jar
+ async-http-client-netty-utils-2.12.0.jar
+ bcpkix-jdk15on-1.69.jar
+ bcprov-ext-jdk15on-1.69.jar
+ bcprov-ext-jdk15on-1.70.jar
+ bcprov-jdk15on-1.69.jar
+ bcutil-jdk15on-1.69.jar
+ bouncy-castle-bc-2.10.1-pkg.jar
+ byte-buddy-1.11.0.jar
+ cache-api-1.1.1.jar
checker-qual-3.12.0.jar
cloudevents-api-2.2.0.jar
+ cloudevents-api-2.3.0.jar
cloudevents-core-2.2.0.jar
+ cloudevents-core-2.3.0.jar
cloudevents-json-jackson-2.2.0.jar
+cloudevents-kafka-2.2.1.jar
+ cloudevents-protobuf-2.3.0.jar
commons-beanutils-1.9.4.jar
commons-cli-1.2.jar
commons-codec-1.11.jar
@@@ -37,13 -58,24 +59,25 @@@ j2objc-annotations-1.3.ja
jackson-annotations-2.13.0.jar
jackson-core-2.13.0.jar
jackson-databind-2.13.0.jar
- javassist-3.20.0-GA.jar
+ jackson-dataformat-yaml-2.13.2.jar
+ javassist-3.24.0-GA.jar
+ javax.activation-1.2.0.jar
javax.annotation-api-1.3.2.jar
+ javax.ws.rs-api-2.1.jar
+ jboss-marshalling-2.0.11.Final.jar
+ jboss-marshalling-river-2.0.11.Final.jar
+ jcip-annotations-1.0.jar
jcommander-1.72.jar
+ jcommander-1.78.jar
+ jetcd-common-0.3.0.jar
+ jetcd-core-0.3.0.jar
+ jetcd-resolver-0.3.0.jar
jna-4.2.2.jar
+ jodd-bean-5.1.6.jar
+ jodd-core-5.1.6.jar
jsr305-3.0.2.jar
junit-4.13.2.jar
+kafka-clients-3.0.0.jar
listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar
log4j-api-2.17.1.jar
log4j-core-2.17.1.jar
@@@ -116,24 -177,15 +180,17 @@@ rocketmq-srvutil-4.9.3.ja
rocketmq-store-4.9.3.jar
rocketmq-test-4.9.3.jar
rocketmq-tools-4.9.3.jar
- simpleclient-0.8.1.jar
+ rxjava-3.0.12.jar
simpleclient_common-0.8.1.jar
simpleclient_httpserver-0.8.1.jar
+ simpleclient-0.8.1.jar
slf4j-api-1.7.30.jar
+ snakeyaml-1.30.jar
+snappy-java-1.1.8.1.jar
system-rules-1.16.1.jar
truth-0.30.jar
+ validation-api-1.1.0.Final.jar
zipkin-2.23.2.jar
zipkin-reporter-2.16.3.jar
zipkin-sender-okhttp3-2.16.3.jar
+zstd-jni-1.5.0-2.jar
- httpasyncclient-4.1.3.jar
- httpcore-nio-4.4.6.jar
- javassist-3.21.0-GA.jar
- nacos-client-2.0.4.jar
- reflections-0.9.11.jar
- snakeyaml-1.23.jar
- snakeyaml-1.30.jar
- bcpkix-jdk15on-1.69.jar
- bcprov-jdk15on-1.69.jar
- bcutil-jdk15on-1.69.jar
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org