This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/com.fasterxml.jackson.core-jackson-annotations-2.15.1
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
discard 5f401673b Bump com.fasterxml.jackson.core:jackson-annotations
add 09548ed93 [ISSUE #3977] update source/sink connector rocketmq module
add 8b03365d7 update build.gradle
add af6b92447 Merge pull request #3980 from
xwm1992/add-eventmesh-connector-sdks
add 498de9e97 Print banner when EventMesh up
add c30dc9fd7 Adjust the logo size and name style.
add 79ac5903f Modify var name and adjust style.
add c3327cbe4 Merge pull request #3941 from pandaapo/master-issue3940
add 3d1e94b3b Update .asf.yaml
add 6bd2f4b7a Merge pull request #3982 from apache/xwm1992-patch-2
add 7c0ed46bc [ISSUE #3985]Fix cannot resolve method getSubystem in
PubSubConfig and code style (#3986)
add cdfec8287 [ISSUE #3926]checkStyle.xml can not check the file header
(#3927)
add 46fa6bde7 [ISSUE #3946]Add unit test method or class for classes:
NetUtils, TopicResponse (#3947)
add 26f2be3f6 [ISSUE #3948]Add HttpUtils test case (#3949)
add a18e4a0fe [ISSUE #3950]Add MessageUtils unit test case (#3951)
add 3b4426bad [ISSUE #3503] Replace this call to "replaceAll()" by a call
to the "replace()" method.[PravegaClient]
add f2cb8cb07 Fix the bug of CI
add 66a652afc Merge pull request #4000 from pandaapo/master-issue3999
add c137e513e [ISSUE #4001] Add eventmesh-sdks module (#4002)
add 4346c915b Bump com.fasterxml.jackson.core:jackson-annotations
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5f401673b)
\
N -- N -- N
refs/heads/dependabot/gradle/com.fasterxml.jackson.core-jackson-annotations-2.15.1
(4346c915b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 12 +-
README.md | 2 +-
README.zh-CN.md | 2 +-
build.gradle | 1 +
.../admin/rocketmq/response/TopicResponseTest.java | 56 +++++++
.../eventmesh/common/utils/NetUtilsTest.java | 9 ++
.../eventmesh-connector-sdk-java/build.gradle | 2 +-
.../apache/eventmesh/connector/Application.java | 2 +-
.../eventmesh/connector/ConnectorWorker.java | 27 ++++
.../org/apache/eventmesh/connector/SinkWorker.java | 4 +-
.../apache/eventmesh/connector/SourceWorker.java | 4 +-
.../connector/api/connector/Connector.java | 31 ++++
.../eventmesh/connector/util/ConfigUtil.java | 16 +-
eventmesh-connectors/README.md | 31 +++-
.../sink-connector-rocketmq/build.gradle | 3 +-
.../connector/rocketmq/EventMeshTestUtils.java | 115 --------------
.../connector/rocketmq/RocketMQSinkWorker.java | 77 +---------
.../sink/connector/rocketmq/UtilsConstants.java | 52 -------
.../connector/rocketmq/config/ConnectorConfig.java | 9 +-
.../rocketmq/config/RocketMQSinkConfig.java | 42 +-----
.../rocketmq/connector/RocketMQSinkConnector.java | 10 +-
.../src/main/resources/config.yml | 15 +-
.../source-connector-rocketmq/build.gradle | 3 +-
.../connector/rocketmq/EventMeshTestUtils.java | 115 --------------
.../connector/rocketmq/RocketMQSourceWorker.java | 50 +-----
.../source/connector/rocketmq/UtilsConstants.java | 51 -------
.../connector/rocketmq/config/ConnectorConfig.java | 10 +-
.../rocketmq/config/RocketMQSourceConfig.java | 43 +-----
.../connector/RocketMQSourceConnector.java | 10 +-
.../src/main/resources/config.yml | 15 +-
eventmesh-examples/build.gradle | 2 +-
eventmesh-runtime/conf/server.env | 25 ++-
.../eventmesh/runtime/boot/EventMeshStartup.java | 3 +-
.../apache/eventmesh/runtime/util/BannerUtil.java | 71 +++++++++
.../eventmesh/runtime/util/BannerUtilTest.java | 16 +-
eventmesh-sdk-go/log/logger.go | 163 --------------------
eventmesh-sdk-rust/.vscode/settings.json | 3 -
.../build.gradle | 0
.../eventmesh-sdk-go}/.golangci.yml | 0
.../eventmesh-sdk-go}/Makefile | 0
.../eventmesh-sdk-go}/README.md | 0
.../eventmesh-sdk-go}/common/constants.go | 0
.../eventmesh-sdk-go}/common/id/api.go | 0
.../eventmesh-sdk-go}/common/id/id_snake.go | 0
.../eventmesh-sdk-go}/common/id/id_snake_test.go | 0
.../eventmesh-sdk-go}/common/id/id_suite_test.go | 0
.../eventmesh-sdk-go}/common/id/id_uuid.go | 0
.../eventmesh-sdk-go}/common/id/id_uuid_test.go | 0
.../common/protocol/eventmesh_message.go | 0
.../common/protocol/http/body/body.go | 0
.../http/body/client/heartbeat_request_body.go | 0
.../http/body/client/subscribe_request_body.go | 0
.../common/protocol/http/common/client_type.go | 0
.../protocol/http/common/eventmesh_ret_code.go | 0
.../common/protocol/http/common/protocol_key.go | 0
.../protocol/http/common/protocol_version.go | 0
.../common/protocol/http/common/request_code.go | 0
.../http/message/send_message_request_body.go | 0
.../common/protocol/message_type.go | 0
.../common/protocol/subscription_item.go | 0
.../common/protocol/subscription_mode.go | 0
.../common/protocol/subscription_type.go | 0
.../common/protocol/tcp/codec/codec.go | 0
.../common/protocol/tcp/command.go | 0
.../common/protocol/tcp/header.go | 0
.../common/protocol/tcp/package.go | 0
.../common/protocol/tcp/user_agent.go | 0
.../eventmesh-sdk-go}/common/seq/num.go | 0
.../eventmesh-sdk-go}/common/seq/num_suite_test.go | 0
.../eventmesh-sdk-go}/common/seq/num_test.go | 0
.../eventmesh-sdk-go}/common/utils/ip.go | 0
.../eventmesh-sdk-go}/common/utils/ip_test.go | 0
.../eventmesh-sdk-go}/common/utils/json_utils.go | 0
.../common/utils/json_utils_test.go | 0
.../eventmesh-sdk-go}/common/utils/pid.go | 0
.../eventmesh-sdk-go}/common/utils/pid_test.go | 0
.../eventmesh-sdk-go}/common/utils/random_utils.go | 0
.../common/utils/random_utils_test.go | 0
.../common/utils/util_suite_test.go | 0
.../examples/grpc/consumer/asyncsub/main.go | 0
.../examples/grpc/consumer/boradcast/main.go | 0
.../examples/grpc/consumer/broadcast/main.go | 0
.../examples/grpc/consumer/rr/main.go | 0
.../examples/grpc/consumer/stream/main.go | 0
.../examples/grpc/producer/bp/main.go | 0
.../examples/grpc/producer/publish/main.go | 0
.../examples/grpc/producer/rr/main.go | 0
.../examples/http/async_pub_cloudevents.go | 0
.../examples/http/sub_cloudevents.go | 0
.../examples/tcp/async_pub_cloudevents.go | 0
.../eventmesh-sdk-go}/go.mod | 0
.../eventmesh-sdk-go}/go.sum | 0
.../eventmesh-sdk-go}/grpc/README.md | 0
.../eventmesh-sdk-go}/grpc/api.go | 0
.../eventmesh-sdk-go}/grpc/client.go | 0
.../eventmesh-sdk-go}/grpc/client_test.go | 0
.../eventmesh-sdk-go}/grpc/conf/config.go | 0
.../eventmesh-sdk-go}/grpc/conf/config_test.go | 0
.../eventmesh-sdk-go}/grpc/consts.go | 0
.../eventmesh-sdk-go}/grpc/consumer.go | 0
.../eventmesh-sdk-go}/grpc/dispatcher.go | 0
.../eventmesh-sdk-go}/grpc/dispatcher_test.go | 0
.../eventmesh-sdk-go}/grpc/fake_grpcserver.go | 0
.../eventmesh-sdk-go}/grpc/fake_webhookserver.go | 0
.../eventmesh-sdk-go}/grpc/grpc_suite_test.go | 0
.../eventmesh-sdk-go}/grpc/heartbeat.go | 0
.../eventmesh-sdk-go}/grpc/heartbeat_test.go | 0
.../eventmesh-sdk-go}/grpc/loadbalancer/README.md | 0
.../grpc/loadbalancer/loadbalancer.go | 0
.../grpc/loadbalancer/loadbalancer_test.go | 0
.../eventmesh-sdk-go}/grpc/loadbalancer/rule.go | 0
.../grpc/loadbalancer/rule_iphash.go | 0
.../grpc/loadbalancer/rule_iphash_test.go | 0
.../grpc/loadbalancer/rule_random.go | 0
.../grpc/loadbalancer/rule_random_test.go | 0
.../grpc/loadbalancer/rule_roundrobin.go | 0
.../grpc/loadbalancer/rule_roundrobin_test.go | 0
.../grpc/loadbalancer/status_server.go | 0
.../grpc/loadbalancer/status_server_test.go | 0
.../eventmesh-sdk-go}/grpc/msg.go | 0
.../eventmesh-sdk-go}/grpc/option.go | 0
.../eventmesh-sdk-go}/grpc/producer.go | 0
.../eventmesh-sdk-go}/grpc/proto/README.md | 0
.../grpc/proto/eventmesh-client.pb.go | 0
.../grpc/proto/eventmesh-client.proto | 0
.../grpc/proto/eventmesh-client_grpc.pb.go | 0
.../eventmesh-sdk-go}/grpc/protocol_type.go | 0
.../eventmesh-sdk-go}/http/abstract_http_client.go | 0
.../http/conf/eventmesh_http_client_config.go | 0
.../http/constants/protocol_type.go | 0
.../http/consumer/consumer_suite_test.go | 0
.../http/consumer/eventmesh_http_consumer.go | 0
.../http/consumer/eventmesh_http_consumer_test.go | 0
.../eventmesh-sdk-go}/http/eventmesh_ret_obj.go | 0
.../eventmesh-sdk-go}/http/model/request_param.go | 0
.../http/producer/cloudevent_producer.go | 0
.../http/producer/cloudevent_producer_test.go | 0
.../http/producer/eventmesh_message_producer.go | 0
.../producer/eventmesh_message_producer_test.go | 0
.../http/producer/http_producer.go | 0
.../http/producer/http_producer_api.go | 0
.../http/producer/producer_suite_test.go | 0
.../http/selector/random_selector.go | 0
.../http/selector/random_selector_test.go | 0
.../eventmesh-sdk-go}/http/selector/selector.go | 0
.../http/selector/selector_suite_test.go | 0
.../http/selector/selector_test.go | 0
.../http/selector/weight_random_selector.go | 0
.../http/selector/weight_random_selector_test.go | 0
.../http/selector/weight_round_robin_selector.go | 0
.../selector/weight_round_robin_selector_test.go | 0
.../eventmesh-sdk-go}/http/utils/http_utils.go | 0
.../eventmesh-sdk-go}/tcp/cloudevent_tcp_client.go | 0
.../tcp/cloudevent_tcp_pub_client.go | 0
.../tcp/cloudevent_tcp_sub_client.go | 0
.../tcp/common/eventmesh_common.go | 0
.../tcp/common/request_context.go | 0
.../tcp/conf/eventmesh_tcp_client_config.go | 0
.../eventmesh-sdk-go}/tcp/eventmesh_tcp_client.go | 0
.../tcp/eventmesh_tcp_client_factory.go | 0
.../tcp/eventmesh_tcp_pub_client.go | 0
.../tcp/eventmesh_tcp_sub_client.go | 0
.../eventmesh-sdk-go}/tcp/tcp_client.go | 0
.../eventmesh-sdk-go}/tcp/utils/message_utils.go | 0
.../eventmesh-sdk-java}/build.gradle | 0
.../eventmesh-sdk-java}/gradle.properties | 0
.../client/catalog/EventMeshCatalogClient.java | 0
.../config/EventMeshCatalogClientConfig.java | 0
.../grpc/config/EventMeshGrpcClientConfig.java | 0
.../grpc/consumer/EventMeshGrpcConsumer.java | 0
.../client/grpc/consumer/ReceiveMsgHook.java | 0
.../client/grpc/consumer/SubStreamHandler.java | 0
.../client/grpc/producer/CloudEventProducer.java | 0
.../grpc/producer/EventMeshGrpcProducer.java | 0
.../grpc/producer/EventMeshMessageProducer.java | 0
.../client/grpc/producer/GrpcProducer.java | 0
.../client/grpc/util/EventMeshClientUtil.java | 0
.../eventmesh/client/http/AbstractHttpClient.java | 0
.../client/http/AbstractProducerHttpClient.java | 0
.../eventmesh/client/http/EventMeshRetObj.java | 0
.../eventmesh/client/http/ProtocolConstant.java | 0
.../http/conf/EventMeshHttpClientConfig.java | 0
.../http/consumer/EventMeshHttpConsumer.java | 0
.../eventmesh/client/http/model/RequestParam.java | 0
.../client/http/producer/CloudEventProducer.java | 0
.../http/producer/EventMeshHttpProducer.java | 0
.../http/producer/EventMeshMessageProducer.java | 0
.../http/producer/EventMeshProtocolProducer.java | 0
.../client/http/producer/OpenMessageProducer.java | 0
.../eventmesh/client/http/producer/RRCallback.java | 0
.../producer/RRCallbackResponseHandlerAdapter.java | 0
.../client/http/ssl/MyX509TrustManager.java | 0
.../client/http/util/HttpLoadBalanceUtils.java | 0
.../eventmesh/client/http/util/HttpUtils.java | 0
.../apache/eventmesh/client/selector/Selector.java | 0
.../client/selector/SelectorException.java | 0
.../eventmesh/client/selector/SelectorFactory.java | 0
.../eventmesh/client/selector/ServiceInstance.java | 0
.../eventmesh/client/tcp/EventMeshTCPClient.java | 0
.../client/tcp/EventMeshTCPClientFactory.java | 0
.../client/tcp/EventMeshTCPPubClient.java | 0
.../client/tcp/EventMeshTCPSubClient.java | 0
.../client/tcp/common/AsyncRRCallback.java | 0
.../client/tcp/common/EventMeshCommon.java | 0
.../eventmesh/client/tcp/common/MessageUtils.java | 0
.../client/tcp/common/ReceiveMsgHook.java | 0
.../client/tcp/common/RequestContext.java | 0
.../eventmesh/client/tcp/common/TcpClient.java | 0
.../client/tcp/conf/EventMeshTCPClientConfig.java | 0
.../tcp/impl/AbstractEventMeshTCPPubHandler.java | 0
.../tcp/impl/AbstractEventMeshTCPSubHandler.java | 0
.../tcp/impl/cloudevent/CloudEventTCPClient.java | 0
.../impl/cloudevent/CloudEventTCPPubClient.java | 0
.../impl/cloudevent/CloudEventTCPSubClient.java | 0
.../EventMeshMessageTCPClient.java | 0
.../EventMeshMessageTCPPubClient.java | 0
.../EventMeshMessageTCPSubClient.java | 0
.../tcp/impl/openmessage/OpenMessageTCPClient.java | 0
.../impl/openmessage/OpenMessageTCPPubClient.java | 0
.../impl/openmessage/OpenMessageTCPSubClient.java | 0
.../client/workflow/EventMeshWorkflowClient.java | 0
.../config/EventMeshWorkflowClientConfig.java | 0
.../src/main/resources/log4j2.xml | 0
.../grpc/consumer/EventMeshGrpcConsumerTest.java | 0
.../grpc/producer/CloudEventProducerTest.java | 0
.../grpc/producer/EventMeshGrpcProducerTest.java | 0
.../producer/EventMeshMessageProducerTest.java | 0
.../client/grpc/producer/MockCloudEvent.java | 0
.../client/grpc/util/EventMeshClientUtilTest.java | 0
.../client/http/demo/AsyncPublishInstance.java | 0
.../client/http/demo/AsyncSyncRequestInstance.java | 0
.../client/http/demo/SyncRequestInstance.java | 0
.../client/http/util/HttpLoadBalanceUtilsTest.java | 0
.../eventmesh/client/http/util/HttpUtilsTest.java | 105 +++++++++++++
.../tcp/common/EventMeshTestCaseTopicSet.java | 0
.../client/tcp/common/EventMeshTestUtils.java | 0
.../client/tcp/common/MessageUtilsTest.java | 167 +++++++++++++++++++++
.../tcp/impl/EventMeshTCPClientFactoryTest.java | 0
.../src/test/resources/application.properties | 0
.../src/test/resources/log4j2.xml | 0
.../eventmesh-sdk-rust}/.gitignore | 0
.../eventmesh-sdk-rust}/Cargo.lock | 0
.../eventmesh-sdk-rust}/Cargo.toml | 0
.../eventmesh-sdk-rust}/eventmesh/Cargo.toml | 0
.../eventmesh-sdk-rust}/eventmesh/build.rs | 0
.../eventmesh/proto/eventmesh-client.proto | 0
.../eventmesh-sdk-rust}/eventmesh/src/constants.rs | 0
.../eventmesh/src/grpc/config.rs | 0
.../eventmesh/src/grpc/consumer.rs | 0
.../eventmesh-sdk-rust}/eventmesh/src/grpc/mod.rs | 0
.../eventmesh/src/grpc/producer.rs | 0
.../eventmesh/src/http/config.rs | 0
.../eventmesh-sdk-rust}/eventmesh/src/http/mod.rs | 0
.../eventmesh/src/http/producer.rs | 0
.../eventmesh/src/http/protocol_key.rs | 0
.../eventmesh/src/http/request_code.rs | 0
.../eventmesh-sdk-rust}/eventmesh/src/lib.rs | 0
.../eventmesh-sdk-rust}/eventmesh/src/message.rs | 0
.../eventmesh-sdk-rust}/examples/Cargo.lock | 0
.../eventmesh-sdk-rust}/examples/Cargo.toml | 0
.../examples/grpc-consumer-stream.rs | 0
.../eventmesh-sdk-rust}/examples/grpc-consumer.rs | 0
.../examples/grpc-producer-batch-publish.rs | 0
.../examples/grpc-producer-publish.rs | 0
.../examples/grpc-producer-request.rs | 0
.../examples/http-producer-publish.rs | 0
.../examples/http-producer-request.rs | 0
.../gradle.properties | 0
.../eventmesh-storage-knative/build.gradle | 4 +-
.../storage/pravega/client/PravegaClient.java | 2 +-
settings.gradle | 3 +-
style/checkStyle.xml | 14 +-
.../build.gradle => style/checkstyle-header1.txt | 0
.../checkstyle-header2.txt | 0
.../server.env => style/checkstyle-header3.txt | 2 +-
tools/dependency-check/known-dependencies.txt | 2 +-
276 files changed, 620 insertions(+), 781 deletions(-)
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/test/java/org/apache/eventmesh/admin/rocketmq/response/TopicResponseTest.java
delete mode 100644
eventmesh-connectors/sink-connector-rocketmq/src/main/java/org/apache/eventmesh/sink/connector/rocketmq/EventMeshTestUtils.java
delete mode 100644
eventmesh-connectors/sink-connector-rocketmq/src/main/java/org/apache/eventmesh/sink/connector/rocketmq/UtilsConstants.java
copy
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/config/SinkConfig.java
=>
eventmesh-connectors/sink-connector-rocketmq/src/main/java/org/apache/eventmesh/sink/connector/rocketmq/config/ConnectorConfig.java
(82%)
copy
eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/resources/prometheus.properties
=> eventmesh-connectors/sink-connector-rocketmq/src/main/resources/config.yml
(72%)
delete mode 100644
eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/EventMeshTestUtils.java
delete mode 100644
eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/UtilsConstants.java
copy
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/config/SinkConfig.java
=>
eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/config/ConnectorConfig.java
(81%)
copy
eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/resources/prometheus.properties
=>
eventmesh-connectors/source-connector-rocketmq/src/main/resources/config.yml
(72%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/BannerUtil.java
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/RegRequestHeaderTest.java
=>
eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/BannerUtilTest.java
(73%)
delete mode 100644 eventmesh-sdk-go/log/logger.go
delete mode 100644 eventmesh-sdk-rust/.vscode/settings.json
copy {eventmesh-connector-sdks => eventmesh-sdks}/build.gradle (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/.golangci.yml
(100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/Makefile (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/README.md (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/constants.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/common/id/api.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/id/id_snake.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/id/id_snake_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/id/id_suite_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/id/id_uuid.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/id/id_uuid_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/eventmesh_message.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/body/body.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/body/client/heartbeat_request_body.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/body/client/subscribe_request_body.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/common/client_type.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/common/eventmesh_ret_code.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/common/protocol_key.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/common/protocol_version.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/common/request_code.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/http/message/send_message_request_body.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/message_type.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/subscription_item.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/subscription_mode.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/subscription_type.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/tcp/codec/codec.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/tcp/command.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/tcp/header.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/tcp/package.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/protocol/tcp/user_agent.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/common/seq/num.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/seq/num_suite_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/seq/num_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/ip.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/ip_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/json_utils.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/json_utils_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/pid.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/pid_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/random_utils.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/random_utils_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/common/utils/util_suite_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/grpc/consumer/asyncsub/main.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/grpc/consumer/boradcast/main.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/grpc/consumer/broadcast/main.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/grpc/consumer/rr/main.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/grpc/consumer/stream/main.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/grpc/producer/bp/main.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/grpc/producer/publish/main.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/grpc/producer/rr/main.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/http/async_pub_cloudevents.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/http/sub_cloudevents.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/examples/tcp/async_pub_cloudevents.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/go.mod (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/go.sum (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/README.md
(100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/api.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/client.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/client_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/conf/config.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/conf/config_test.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/consts.go
(100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/consumer.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/dispatcher.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/dispatcher_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/fake_grpcserver.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/fake_webhookserver.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/grpc_suite_test.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/heartbeat.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/heartbeat_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/README.md (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/loadbalancer.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/loadbalancer_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/rule.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/rule_iphash.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/rule_iphash_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/rule_random.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/rule_random_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/rule_roundrobin.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/rule_roundrobin_test.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/status_server.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/loadbalancer/status_server_test.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/msg.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/option.go
(100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/grpc/producer.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/proto/README.md (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/proto/eventmesh-client.pb.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/proto/eventmesh-client.proto (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/proto/eventmesh-client_grpc.pb.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/grpc/protocol_type.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/abstract_http_client.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/conf/eventmesh_http_client_config.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/constants/protocol_type.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/consumer/consumer_suite_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/consumer/eventmesh_http_consumer.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/consumer/eventmesh_http_consumer_test.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/eventmesh_ret_obj.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/model/request_param.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/producer/cloudevent_producer.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/producer/cloudevent_producer_test.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/producer/eventmesh_message_producer.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/producer/eventmesh_message_producer_test.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/producer/http_producer.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/producer/http_producer_api.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/producer/producer_suite_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/random_selector.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/random_selector_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/selector.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/selector_suite_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/selector_test.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/weight_random_selector.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/weight_random_selector_test.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/weight_round_robin_selector.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/selector/weight_round_robin_selector_test.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/http/utils/http_utils.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/cloudevent_tcp_client.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/cloudevent_tcp_pub_client.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/cloudevent_tcp_sub_client.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/common/eventmesh_common.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/common/request_context.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/conf/eventmesh_tcp_client_config.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/eventmesh_tcp_client.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/eventmesh_tcp_client_factory.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/eventmesh_tcp_pub_client.go (100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/eventmesh_tcp_sub_client.go (100%)
rename {eventmesh-sdk-go => eventmesh-sdks/eventmesh-sdk-go}/tcp/tcp_client.go
(100%)
rename {eventmesh-sdk-go =>
eventmesh-sdks/eventmesh-sdk-go}/tcp/utils/message_utils.go (100%)
rename {eventmesh-sdk-java => eventmesh-sdks/eventmesh-sdk-java}/build.gradle
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/gradle.properties (100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/catalog/EventMeshCatalogClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/catalog/config/EventMeshCatalogClientConfig.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/config/EventMeshGrpcClientConfig.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/consumer/ReceiveMsgHook.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/producer/EventMeshGrpcProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/producer/EventMeshMessageProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/producer/GrpcProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/AbstractHttpClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/AbstractProducerHttpClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/EventMeshRetObj.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/ProtocolConstant.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/conf/EventMeshHttpClientConfig.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/consumer/EventMeshHttpConsumer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/model/RequestParam.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/producer/CloudEventProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshHttpProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshMessageProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshProtocolProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/producer/OpenMessageProducer.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/producer/RRCallback.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/producer/RRCallbackResponseHandlerAdapter.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/ssl/MyX509TrustManager.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/util/HttpLoadBalanceUtils.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/http/util/HttpUtils.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/selector/Selector.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/selector/SelectorException.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/selector/SelectorFactory.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/selector/ServiceInstance.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/EventMeshTCPClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/EventMeshTCPClientFactory.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/EventMeshTCPPubClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/EventMeshTCPSubClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/common/AsyncRRCallback.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/common/EventMeshCommon.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/common/ReceiveMsgHook.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/common/RequestContext.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/conf/EventMeshTCPClientConfig.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPPubHandler.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPSubHandler.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPSubClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPPubClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPSubClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/openmessage/OpenMessageTCPClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/openmessage/OpenMessageTCPPubClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/tcp/impl/openmessage/OpenMessageTCPSubClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/workflow/EventMeshWorkflowClient.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/workflow/config/EventMeshWorkflowClientConfig.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/resources/log4j2.xml (100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumerTest.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducerTest.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/producer/EventMeshGrpcProducerTest.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/producer/EventMeshMessageProducerTest.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/producer/MockCloudEvent.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/http/demo/AsyncPublishInstance.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/http/demo/AsyncSyncRequestInstance.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/http/demo/SyncRequestInstance.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/http/util/HttpLoadBalanceUtilsTest.java
(100%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/http/util/HttpUtilsTest.java
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestCaseTopicSet.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestUtils.java
(100%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/MessageUtilsTest.java
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/tcp/impl/EventMeshTCPClientFactoryTest.java
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/resources/application.properties
(100%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/resources/log4j2.xml (100%)
rename {eventmesh-sdk-rust => eventmesh-sdks/eventmesh-sdk-rust}/.gitignore
(100%)
rename {eventmesh-sdk-rust => eventmesh-sdks/eventmesh-sdk-rust}/Cargo.lock
(100%)
rename {eventmesh-sdk-rust => eventmesh-sdks/eventmesh-sdk-rust}/Cargo.toml
(100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/Cargo.toml (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/build.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/proto/eventmesh-client.proto (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/constants.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/grpc/config.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/grpc/consumer.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/grpc/mod.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/grpc/producer.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/http/config.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/http/mod.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/http/producer.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/http/protocol_key.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/http/request_code.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/lib.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/eventmesh/src/message.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/Cargo.lock (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/Cargo.toml (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/grpc-consumer-stream.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/grpc-consumer.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/grpc-producer-batch-publish.rs
(100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/grpc-producer-publish.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/grpc-producer-request.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/http-producer-publish.rs (100%)
rename {eventmesh-sdk-rust =>
eventmesh-sdks/eventmesh-sdk-rust}/examples/http-producer-request.rs (100%)
copy {eventmesh-admin => eventmesh-sdks}/gradle.properties (100%)
copy eventmesh-admin/build.gradle => style/checkstyle-header1.txt (100%)
copy eventmesh-common/gradle.properties => style/checkstyle-header2.txt (100%)
copy eventmesh-runtime/conf/server.env => style/checkstyle-header3.txt (89%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
