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/02 10:01:01 UTC
[incubator-eventmesh] branch redis-connector updated (4f2c1376 -> 29a40af8)
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch redis-connector
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 4f2c1376 Merge pull request #990 from mytang0/feature/redis-connector
add 4d7388ba Update some docs
add 61eba763 Update some docs
add 5ce1d642 Skip UT in license check
add 3c86cf52 Merge pull request #978 from ruanwenjun/dev_wenjun_skipTestInLicenseCheck
add 13f3a9a5 Fix gradle license header
add a2b53c36 Ignore the gradlew/gradlew.bat
add b4545632 Merge pull request #977 from ruanwenjun/dev_wenjun_fixGradleLicenseHeader
add 117951e4 Fix the abnormal display of pictures in some documents
add cdbfa247 Merge pull request #968 from walterlife/walterlife/fix-doc-images-show-problem
add 0188a7db update issue template
add 7d7e5cb2 Merge pull request #969 from Alonexc/Alone
add 68f3b647 Merge remote-tracking branch 'upstream/master' into fix-patch-kirinzhu
add 931bd758 Use Apache release rather than Github release in README
add 03777ddf Add incubating
add dd009696 Add incubating
add f518be6d Remove -x
add 73eccf17 fix ci yml
add 2d7a8e2b Merge pull request #976 from ruanwenjun/dev_wenjun_useApacheRelease
add e4d3e80f Merge remote-tracking branch 'upstream/master' into fix-patch-kirinzhu
add 90013fa1 Merge pull request #962 from kirinzhu/fix-patch-kirinzhu
add b3d0d692 Fix Error when Running/Debugging the Application on Linux Platform (#991)
add 5757d35d [ISSUE #987] try-with-resource to close the BufferedReader (#987)
add 3bfba3fb Merge pull request #994 from wuyiliang1/fix_patch_close_resource
add 344878de Add System.exit(-1) in catch block EventMeshStartup.main()
add 1bfab012 Merge pull request #1002 from kirinzhu/fix-zlx-1
add 6026a3ad Add parameter checking before sending message For EventMeshMessageTCPClient .
add 10105b66 Fix imports invalid order .
add b23ac6d8 Fix imports invalid order .
add a62f029b Merge pull request #996 from misselvexu/i/gh-995
add dd4b700f Remove invalid imports (#1005)
add ec197e29 Update quick-start docs (CN)
add 590b3f13 Update quick-start docs (CN)
add 6f455cdd Merge pull request #1007 from kirinzhu/doc-zlx-1
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 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
No new revisions were added by this update.
Summary of changes:
.github/ISSUE_TEMPLATE/bug_report.yml | 1 +
.github/ISSUE_TEMPLATE/documentation_related.yml | 2 +-
.github/ISSUE_TEMPLATE/unit_test.yml | 4 +-
.github/PULL_REQUEST_TEMPLATE.md | 4 +-
.github/workflows/ci.yml | 3 +-
.github/workflows/greetings.yml | 4 +-
.gitignore | 3 +-
.licenserc.yaml | 2 +
README.md | 45 +-
README.zh-CN.md | 37 +-
build.gradle | 25 +-
docs/en/design-document/01-workflow.md | 6 +-
docs/en/design-document/02-runtime-protocol.md | 6 +-
docs/en/design-document/03-stream.md | 10 +-
docs/en/design-document/04-schema-registry.md | 6 +-
docs/en/design-document/06-cloudevents.md | 2 +-
docs/en/design-document/09-event-bridge.md | 156 ++++
docs/en/installation/03-store.md | 5 -
docs/en/instruction/01-store-with-docker.md | 71 ++
docs/en/instruction/01-store.md | 44 +
.../02-runtime-with-docker.md | 22 +-
.../01-runtime.md => instruction/02-runtime.md} | 87 +-
docs/en/instruction/03-demo.md | 152 ++++
.../{installation => instruction}/_category_.json | 0
docs/en/introduction.md | 2 +-
docs/en/roadmap.md | 56 +-
docs/en/sdk-java/{01-introduction.md => intro.md} | 0
.../images/design-document/event-bridge-detail.png | Bin 0 -> 563043 bytes
docs/images/design-document/tcp-protocol.png | Bin 0 -> 52135 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/{en => zh}/contribute/01-release.md | 0
docs/{en => zh}/contribute/02-write-unit-test.md | 0
.../contribute/03-new-contributor-guidelines.md | 0
docs/{en => zh}/contribute/_category_.json | 0
docs/zh/desing-document/01-workflow.md | 258 ++++++
.../02-runtime-protocol.md} | 8 +-
docs/zh/desing-document/03-stream.md | 115 +++
docs/zh/desing-document/06-cloudevents.md | 102 +++
.../{features/spi.md => desing-document/08-spi.md} | 1 -
docs/zh/desing-document/09-event-bridge.md | 156 ++++
.../_category_.json | 0
.../eventmesh-unit-test-rule.md | 0
docs/zh/{features => desing-document}/https.md | 0
docs/zh/desing-document/webhook.md | 268 +++++++
docs/zh/features/_category_.json | 4 -
.../eclipse.md => instruction/00-eclipse.md} | 66 +-
docs/zh/instruction/01-store-with-docker.md | 40 +
docs/zh/instruction/01-store.md | 51 ++
.../02-runtime-with-docker.md} | 80 +-
docs/zh/instruction/02-runtime.md | 114 +++
.../03-demo.md} | 85 +-
.../{instructions => instruction}/_category_.json | 0
.../instructions/eventmesh-runtime-quickstart.md | 286 -------
docs/zh/instructions/eventmesh-store-quickstart.md | 53 --
docs/zh/instructions/quickstart.md | 29 -
docs/zh/intro.md | 81 --
docs/zh/introduction.md | 49 ++
.../01-prometheus.md} | 0
.../02-zipkin.md} | 0
docs/{en => zh}/metrics-tracing/_category_.json | 0
docs/zh/roadmap.md | 47 ++
.../sdk-java/{01-introduction.md => 01-intro.md} | 0
.../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 | 31 +-
.../common/config/CommonConfiguration.java | 43 +-
.../common/config/ConfigurationWrapper.java | 40 +-
.../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 +-
.../org/apache/eventmesh/common/utils/IPUtils.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 | 14 +-
.../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 +-
.../patch/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/connector/KnativeConnectorTest.java | 118 +++
.../knative/consumer/KnativeConsumerImplTest.java | 22 +-
.../knative/producer/KnativeProducerImplTest.java | 58 ++
.../eventmesh-connector-pravega}/build.gradle | 23 +-
.../eventmesh-connector-pravega/gradle.properties | 6 +-
.../PravegaConnectorResourceServiceImpl.java | 24 +-
.../connector/pravega/PravegaConsumerImpl.java | 91 +++
.../connector/pravega/PravegaProducerImpl.java | 108 +++
.../eventmesh/connector/pravega/SubscribeTask.java | 70 ++
.../connector/pravega/client/PravegaClient.java | 214 +++++
.../pravega/client/PravegaCloudEventWriter.java | 70 ++
.../connector/pravega/client/PravegaEvent.java | 74 ++
.../pravega/config/PravegaConnectorConfig.java | 113 +++
.../config/PravegaConnectorConfigWrapper.java | 71 ++
.../exception/PravegaConnectorException.java | 18 +-
...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 +-
.../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 +-
.../config/PrometheusConfigurationTest.java | 2 +-
.../src/test/resources/prometheus.properties | 2 +-
.../eventmesh-protocol-cloudevents/build.gradle | 5 +-
.../cloudevents/WebHookProtocolAdaptor.java | 62 ++
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 3 +-
.../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 +-
.../resolver/tcp/TcpMessageProtocolResolver.java | 12 +-
.../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 | 19 +-
.../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 | 10 +-
eventmesh-runtime/conf/eventmesh.properties | 15 +-
.../admin/controller/ClientManageController.java | 24 +
.../admin/handler/DeleteWebHookConfigHandler.java | 64 ++
.../admin/handler/InsertWebHookConfigHandler.java | 63 ++
.../handler/QueryRecommendEventMeshHandler.java | 5 +-
.../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/EventMeshStartup.java | 1 +
.../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 +-
.../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 +-
.../protocol/http/processor/HandlerService.java | 366 +++++++++
.../protocol/http/processor/HttpProcessor.java | 14 +-
.../processor/LocalSubscribeEventProcessor.java | 104 +--
.../processor/LocalUnSubscribeEventProcessor.java | 90 +--
.../processor/RemoteSubscribeEventProcessor.java | 111 +--
.../processor/RemoteUnSubscribeEventProcessor.java | 81 +-
.../http/processor/SendAsyncEventProcessor.java | 179 ++---
.../http/processor/SendAsyncMessageProcessor.java | 4 +-
.../processor/SendAsyncRemoteEventProcessor.java | 186 ++---
.../protocol/http/processor/WebHookProcessor.java | 59 ++
.../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/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 +-
...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 +-
.../grpc/producer/EventMeshGrpcProducer.java | 4 +-
.../producer/RRCallbackResponseHandlerAdapter.java | 2 +-
.../eventmesh/client/http/util/HttpUtils.java | 8 +-
.../client/tcp/common/EventMeshCommon.java | 14 +-
.../EventMeshMessageTCPClient.java | 14 +
.../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 | 180 +++++
.../webhook/admin/NacosWebHookConfigOperation.java | 207 +++++
.../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-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 | 131 +++
.../webhook/receive/WebHookMQProducer.java | 61 ++
.../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 | 120 +++
.../receive/storage/WebhookFileListener.java | 194 +++++
.../gradle.properties | 0
eventmesh-webhook/webhook.jmx | 122 +++
eventmesh-workflow-go/.golangci.yml | 99 +++
.../.licenserc.yaml | 3 +
eventmesh-workflow-go/Makefile | 40 +
eventmesh-workflow-go/api/proto/workflow.pb.go | 255 ++++++
.../api/proto/workflow.proto | 19 +-
.../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 ++
gradlew | 59 +-
gradlew.bat | 13 +-
settings.gradle | 13 +-
tools/dependency-check/check-dependencies.sh | 2 +-
tools/dependency-check/known-dependencies.txt | 138 ++--
tools/third-party-licenses/LICENSE | 32 +-
.../java/LICENSE-animal-sniffer-annotations.txt | 21 +
.../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-consul-api.txt} | 7 +-
...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 +++++---------
...buf-java.txt => LICENSE-protobuf-java-util.txt} | 0
384 files changed, 17385 insertions(+), 2576 deletions(-)
create mode 100644 docs/en/design-document/09-event-bridge.md
delete mode 100644 docs/en/installation/03-store.md
create mode 100644 docs/en/instruction/01-store-with-docker.md
create mode 100644 docs/en/instruction/01-store.md
rename docs/en/{installation => instruction}/02-runtime-with-docker.md (90%)
rename docs/en/{installation/01-runtime.md => instruction/02-runtime.md} (59%)
create mode 100644 docs/en/instruction/03-demo.md
rename docs/en/{installation => instruction}/_category_.json (100%)
rename docs/en/sdk-java/{01-introduction.md => intro.md} (100%)
create mode 100644 docs/images/design-document/event-bridge-detail.png
create mode 100644 docs/images/design-document/tcp-protocol.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
copy docs/{en => zh}/contribute/01-release.md (100%)
copy docs/{en => zh}/contribute/02-write-unit-test.md (100%)
copy docs/{en => zh}/contribute/03-new-contributor-guidelines.md (100%)
copy docs/{en => zh}/contribute/_category_.json (100%)
create mode 100644 docs/zh/desing-document/01-workflow.md
rename docs/zh/{instructions/eventmesh-runtime-protocol.md => desing-document/02-runtime-protocol.md} (98%)
create mode 100644 docs/zh/desing-document/03-stream.md
create mode 100644 docs/zh/desing-document/06-cloudevents.md
rename docs/zh/{features/spi.md => desing-document/08-spi.md} (99%)
create mode 100644 docs/zh/desing-document/09-event-bridge.md
rename docs/zh/{documentation => desing-document}/_category_.json (100%)
rename docs/zh/{instructions => desing-document}/eventmesh-unit-test-rule.md (100%)
rename docs/zh/{features => desing-document}/https.md (100%)
create mode 100644 docs/zh/desing-document/webhook.md
delete mode 100644 docs/zh/features/_category_.json
rename docs/zh/{instructions/eclipse.md => instruction/00-eclipse.md} (83%)
create mode 100644 docs/zh/instruction/01-store-with-docker.md
create mode 100644 docs/zh/instruction/01-store.md
rename docs/zh/{instructions/eventmesh-runtime-quickstart-with-docker.md => instruction/02-runtime-with-docker.md} (54%)
create mode 100644 docs/zh/instruction/02-runtime.md
rename docs/zh/{instructions/eventmesh-sdk-java-quickstart.md => instruction/03-demo.md} (61%)
rename docs/zh/{instructions => instruction}/_category_.json (100%)
delete mode 100644 docs/zh/instructions/eventmesh-runtime-quickstart.md
delete mode 100644 docs/zh/instructions/eventmesh-store-quickstart.md
delete mode 100644 docs/zh/instructions/quickstart.md
delete mode 100644 docs/zh/intro.md
create mode 100644 docs/zh/introduction.md
rename docs/zh/{instructions/eventmesh-metrics-Prometheus-instruction.md => metrics-tracing/01-prometheus.md} (100%)
rename docs/zh/{instructions/eventmesh-trace-Zipkin-instruction.md => metrics-tracing/02-zipkin.md} (100%)
copy docs/{en => zh}/metrics-tracing/_category_.json (100%)
create mode 100644 docs/zh/roadmap.md
rename docs/zh/sdk-java/{01-introduction.md => 01-intro.md} (100%)
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
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%)
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-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/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-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/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-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/domain/NonStandardKeys.java} (81%)
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/patch/EventMeshConsumeConcurrentlyContext.java (72%)
copy eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolConstant.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyStatus.java (70%)
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/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%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/connector/KnativeConnectorTest.java
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
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%)
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/SubscribeTask.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/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
rename 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/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%)
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/WebHookProtocolAdaptor.java
copy {eventmesh-protocol-plugin/eventmesh-protocol-http => 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-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolConstant.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-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.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
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-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/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-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/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
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%)
copy eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/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 (95%)
create mode 100644 eventmesh-workflow-go/Makefile
create mode 100644 eventmesh-workflow-go/api/proto/workflow.pb.go
copy eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.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
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
rename tools/third-party-licenses/licenses/java/{LICENSE-snakeyam.txt => LICENSE-consul-api.txt} (98%)
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-protobuf-java.txt => LICENSE-protobuf-java-util.txt} (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org