This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/io.cloudevents-cloudevents-kafka-2.5.0
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
discard b107435f7 Bump io.cloudevents:cloudevents-kafka from 2.2.1 to 2.5.0
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 10e28463d Update README.md (#4003)
add 7f7456b22 [ISSUE #3964]
add 3d2d42101 Merge pull request #3966 from piyush280599/patch-13
add e1ec9758f Update README.md (#4007)
add 1798e1f9b [ISSUE #4005]Resolve all checkstyle related errors in CI and
unify header to 'checkstyle-header.txt'
add 646808a8c [ISSUE #4013] rename the connect sdk module (#4014)
add ad3be2461 [ISSUE #3962 ]Code optimization.[TopicHandler] (#3997)
add b823c8b78 [ISSUE #3907] Replaced List with Collection (#4004)
add 9577511e2 [ISSUE #3961 ]Code optimization.[TCPClientHandler] (#3996)
add 8f26e0e45 [ISSUE #3960]Code optimization.[RegistryHandler] (#3995)
add 67041ac8e [ISSUE #3957]Code optimization.[GrpcClientHandler] (#3992)
add 4158a6300 [ISSUE #3956]Code optimization.[EventHandler] (#3991)
add 1cf305578 [ISSUE #3959 ]Code optimization.[MetricsHandler] (#3994)
add 56d237445 [ISSUE #3958 ] Code optimization.[HTTPClientHandler] (#3993)
add c27463427 [ISSUE #3908] Code optimization [HttpRequestProcessor]
add 0ce8d57e6 [ISSUE #3905] Method needlessly defines parameter with
concrete classes[RejectClientBySubSystemHandler]
add 782a1275c [ISSUE #3931]Optimize Body extends class toString method
(#3932)
add 869cb490f [ISSUE #3973]log.error should be in try-catch() instead of
log.warn (#3974)
add 4db76679e [ISSUE #3942]Update README.zh-CN.md (#3943)
add 2fed6c7d6 [ISSUE #3955 ]Code optimization.[ConfigurationHandler]
(#3972)
add c4a4ff85e [ISSUE #3900] Removed Additional Null Check
add 30926435b [ISSUE #3952]Optimize EventMeshServer#EventMeshServer method
(#3953)
add dc7903697 [ISSUE #4038]Optimize eventmesh-openconnect log print (#4039)
add dac28e388 Resolves Issue #4029
add 5b095892d Merge branch 'apache:master' into ISSUE-4029
add a6a279385 Merge pull request #4037 from nitheesh-daram/ISSUE-4029
add a4daa97fb Update README.md
add ae961bff7 Merge pull request #4048 from apache/xwm1992-patch-5
add c8d9df802 [ISSUE #3827] Changed Access Modifiers for MessageQueue
items (#3987)
add 207b9af9b [ISSUE #4044] Remove duplicate init connector operation in
worker (#4046)
add c5f3aba89 [ISSUE #3963] Method invocation 'getBytes' may produce
'NullPointerException'. (#3971)
add 1e8c5dba3 [ISSUE #3944]Var of type SpanProcessor no need to be defined
as global variables in ZipkinTraceService, PinpointTraceService (#3945)
add 2a0f165cf [ISSUE #3924]Add unit test for UrlMappingPattern,
RequestMapping (#3925)
add 6fbfd7acb [ISSUE #3909] Replaced anonymous new ChannelFutureListener()
with lambda (#3923)
add fb144bb1d [ISSUE #3918]RequestMapping, UrlMappingPattern can apply
some optimizing
add 0113c42ac [ISSUE #3933] Fix the tcp port. (#3936)
add e748f2472 [ISSUE #3912]There are boilerplate codes in
PrometheusTcpExporter, PrometheusHttpExporter (#3916)
add d3745519b [ISSUE #3897]Admin, RocketMQAdmin, StandaloneAdmin and
AbstractRmqAdmin can be more clearer. (#3898)
add c5bbd674c [ISSUE #3983] Optimize MessageQueue (#3984)
add 4b49642e8 [ISSUE #3978]Remove unnecessary annotations in
TopicCreateRequest and add unit test. (#3981)
add 46fad30aa [ISSUE #4050]Show logo in IDEA welcome screen (#4051)
add d182e55ae [ISSUE #4031] Specifies the default character set (#4057)
add 3f49cd4b7 [ISSUE #3485]Optimize Grpc protocol for Java (#3746)
add bbd6d9213 Bump io.cloudevents:cloudevents-kafka from 2.2.1 to 2.5.0
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 (b107435f7)
\
N -- N -- N
refs/heads/dependabot/gradle/io.cloudevents-cloudevents-kafka-2.5.0 (bbd6d9213)
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:
.gitignore | 1 +
.idea/icon.png | Bin 0 -> 14821 bytes
README.md | 7 +-
README.zh-CN.md | 6 +-
build.gradle | 17 +-
docker/Dockerfile | 2 +-
.../eventmesh-admin-rocketmq/build.gradle | 5 +-
.../admin/rocketmq/handler/TopicsHandler.java | 2 +-
.../admin/rocketmq/request/TopicCreateRequest.java | 17 +-
.../admin/rocketmq/util/RequestMapping.java | 38 +-
.../admin/rocketmq/util/UrlMappingPattern.java | 22 +-
.../rocketmq/request/TopicCreateRequestTest.java | 63 +
.../admin/rocketmq/util/RequestMappingTest.java | 79 +
.../admin/rocketmq/util/UrlMappingPatternTest.java | 102 +
eventmesh-common/build.gradle | 2 +-
.../eventmesh/common/config/ConfigService.java | 14 +-
...tpMethod.java => EventMeshDataContentType.java} | 13 +-
.../common/loadbalance/LoadBalanceType.java | 24 +-
.../eventmesh/common/protocol/HeartbeatItem.java | 16 +-
.../common/protocol/SubscriptionMode.java | 8 +-
.../common/protocol/SubscriptionType.java | 7 +-
.../common/protocol/catalog/protos/Operation.java | 3 -
.../protocol/grpc/cloudevents/CloudEvent.java | 3550 ++++++++++++++++++
.../protocol/grpc/cloudevents/CloudEventBatch.java | 772 ++++
.../grpc/cloudevents/CloudEventBatchOrBuilder.java | 33 +
.../grpc/cloudevents/CloudEventOrBuilder.java | 174 +
.../ConsumerServiceGrpc.java | 295 +-
.../grpc/cloudevents/EventMeshCloudEvents.java | 105 +
.../grpc/cloudevents/EventMeshGrpcService.java | 70 +
.../HeartbeatServiceGrpc.java | 170 +-
.../grpc/cloudevents/PublisherServiceGrpc.java | 632 ++++
...r.java => BatchEventMeshCloudEventWrapper.java} | 14 +-
.../protocol/{http => grpc}/common/ClientType.java | 21 +-
.../grpc/common/EventMeshCloudEventUtils.java | 427 +++
...rapper.java => EventMeshCloudEventWrapper.java} | 14 +-
...SimpleMessageWrapper.java => ProtoSupport.java} | 28 +-
.../common/protocol/grpc/common/ProtocolKey.java | 32 +-
.../common/protocol/grpc/common/Response.java | 23 +-
.../common/protocol/grpc/common/StatusCode.java | 4 +-
.../protocol/grpc/common/SubscriptionReply.java | 34 +-
.../common/protocol/grpc/protos/BatchMessage.java | 2453 ------------
.../grpc/protos/BatchMessageOrBuilder.java | 84 -
.../common/protocol/grpc/protos/EventmeshGrpc.java | 283 --
.../common/protocol/grpc/protos/Heartbeat.java | 1988 ----------
.../protocol/grpc/protos/HeartbeatOrBuilder.java | 93 -
.../protocol/grpc/protos/PublisherServiceGrpc.java | 476 ---
.../common/protocol/grpc/protos/RequestHeader.java | 1507 --------
.../grpc/protos/RequestHeaderOrBuilder.java | 147 -
.../common/protocol/grpc/protos/Response.java | 701 ----
.../protocol/grpc/protos/ResponseOrBuilder.java | 57 -
.../common/protocol/grpc/protos/SimpleMessage.java | 1802 ---------
.../grpc/protos/SimpleMessageOrBuilder.java | 144 -
.../common/protocol/grpc/protos/Subscription.java | 3932 --------------------
.../grpc/protos/SubscriptionOrBuilder.java | 97 -
.../http/body/message/PushMessageResponseBody.java | 5 +-
.../body/message/ReplyMessageResponseBody.java | 5 +-
.../body/message/SendMessageBatchResponseBody.java | 5 +-
.../message/SendMessageBatchV2ResponseBody.java | 5 +-
.../http/body/message/SendMessageResponseBody.java | 5 +-
.../eventmesh/common/utils/RandomStringUtils.java | 7 +
.../eventmesh/common/utils/ReflectUtils.java} | 42 +-
.../grpc/common/EventMeshCloudEventUtilsTest.java | 271 ++
.../common/utils/PropertiesUtilsTest.java | 24 +-
.../eventmesh/connector/ConnectorWorker.java | 34 -
.../eventmesh/connector/api/config/Config.java | 21 -
.../eventmesh/connector/api/config/Constants.java | 31 -
.../connector/api/config/PubSubConfig.java | 41 -
.../eventmesh/connector/api/config/SinkConfig.java | 27 -
.../connector/api/config/SourceConfig.java | 27 -
.../connector/api/connector/SinkConnector.java | 30 -
.../connector/api/connector/SourceConnector.java | 30 -
.../apache/eventmesh/connector/api/sink/Sink.java | 32 -
.../eventmesh/connector/api/source/Source.java | 32 -
eventmesh-connectors/README.md | 39 +-
.../sink-connector-rocketmq/build.gradle | 2 +-
.../connector/rocketmq/RocketMQSinkWorker.java | 2 +-
.../connector/rocketmq/config/ConnectorConfig.java | 10 +-
.../rocketmq/config/RocketMQSinkConfig.java | 12 +-
.../rocketmq/connector/RocketMQSinkConnector.java | 16 +-
.../src/main/resources/config.yml | 2 +-
.../source-connector-rocketmq/build.gradle | 2 +-
.../connector/rocketmq/RocketMQSourceWorker.java | 6 +-
.../connector/rocketmq/config/ConnectorConfig.java | 10 +-
.../rocketmq/config/RocketMQSourceConfig.java | 12 +-
.../connector/RocketMQSourceConnector.java | 20 +-
.../src/main/resources/config.yml | 2 +-
eventmesh-examples/build.gradle | 4 +-
.../eventmesh/grpc/sub/app/service/SubService.java | 24 +-
.../http/demo/sub/service/SubService.java | 24 +-
.../src/main/resources/application.properties | 2 +-
.../prometheus/metrics/PrometheusGrpcExporter.java | 45 +-
.../prometheus/metrics/PrometheusHttpExporter.java | 415 +--
.../prometheus/metrics/PrometheusTcpExporter.java | 110 +-
.../utils/PrometheusExporterConstants.java | 26 +-
.../prometheus/utils/PrometheusExporterUtils.java | 67 +
.../README.md | 0
.../build.gradle | 0
.../eventmesh-openconnect-java}/build.gradle | 2 +-
.../eventmesh-openconnect-java}/gradle.properties | 0
.../apache/eventmesh/openconnect}/Application.java | 26 +-
.../eventmesh/openconnect/ConnectorWorker.java | 15 +-
.../apache/eventmesh/openconnect}/SinkWorker.java | 26 +-
.../eventmesh/openconnect}/SourceWorker.java | 24 +-
.../eventmesh/openconnect/api/config/Config.java | 7 +-
.../openconnect/api/config}/Constants.java | 12 +-
.../openconnect/api/config/PubSubConfig.java | 27 +-
.../openconnect/api/config/SinkConfig.java | 8 +-
.../openconnect/api/config/SourceConfig.java | 8 +-
.../openconnect}/api/connector/Connector.java | 16 +-
.../openconnect/api/connector/SinkConnector.java | 24 +-
.../openconnect/api/connector/SourceConnector.java | 25 +-
.../openconnect}/api/data/ConnectRecord.java | 12 +-
.../openconnect}/api/data/DefaultKeyValue.java | 12 +-
.../eventmesh/openconnect}/api/data/KeyValue.java | 12 +-
.../openconnect}/api/data/RecordOffset.java | 12 +-
.../openconnect}/api/data/RecordPartition.java | 12 +-
.../openconnect}/api/data/RecordPosition.java | 12 +-
.../eventmesh/openconnect/api/sink/Sink.java | 16 +-
.../eventmesh/openconnect/api/source/Source.java | 16 +-
.../eventmesh/openconnect}/util/ConfigUtil.java | 16 +-
.../gradle.properties | 0
.../eventmesh-protocol-cloudevents/build.gradle | 7 +
.../cloudevents/CloudEventsProtocolAdaptor.java | 28 +-
.../cloudevents/CloudEventsProtocolConstant.java | 2 +
.../GrpcEventMeshCloudEventProtocolResolver.java | 66 +
.../resolver/grpc/GrpcMessageProtocolResolver.java | 182 -
.../eventmesh-protocol-grpc/build.gradle | 4 +-
.../src/main/proto/eventmesh-cloudevents.proto | 86 +
.../src/main/proto/eventmesh-service.proto | 58 +
.../eventmesh-protocol-meshmessage/build.gradle | 7 +
.../meshmessage/MeshMessageProtocolAdaptor.java | 34 +-
.../meshmessage/MeshMessageProtocolConstant.java | 2 +
.../GrpcEventMeshCloudEventProtocolResolver.java | 70 +
.../resolver/grpc/GrpcMessageProtocolResolver.java | 275 --
eventmesh-runtime/build.gradle | 1 +
eventmesh-runtime/conf/eventmesh.properties | 2 +-
.../admin/controller/HttpHandlerManager.java | 26 +-
.../admin/handler/ConfigurationHandler.java | 33 +-
.../runtime/admin/handler/EventHandler.java | 38 +-
.../runtime/admin/handler/GrpcClientHandler.java | 42 +-
.../runtime/admin/handler/HTTPClientHandler.java | 58 +-
.../runtime/admin/handler/MetricsHandler.java | 33 +-
.../handler/QueryWebHookConfigByIdHandler.java | 4 +-
.../QueryWebHookConfigByManufacturerHandler.java | 2 +-
.../runtime/admin/handler/RegistryHandler.java | 33 +-
.../handler/RejectClientBySubSystemHandler.java | 3 +-
.../runtime/admin/handler/TCPClientHandler.java | 45 +-
.../runtime/admin/handler/TopicHandler.java | 61 +-
.../runtime/admin/request/CreateTopicRequest.java | 26 +-
.../admin/request/DeleteGrpcClientRequest.java | 26 +-
.../admin/request/DeleteHTTPClientRequest.java | 26 +-
.../admin/request/DeleteTCPClientRequest.java | 26 +-
.../runtime/admin/request/DeleteTopicRequest.java | 26 +-
.../admin/response/GetConfigurationResponse.java | 26 +-
.../runtime/admin/utils/HttpExchangeUtils.java | 26 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 2 +-
.../runtime/boot/EventMeshGrpcServer.java | 8 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 31 +-
.../apache/eventmesh/runtime/boot/HTTPTrace.java | 2 +-
.../eventmesh/runtime/boot/SSLContextFactory.java | 24 +-
.../eventmesh/runtime/common/EventHttpHandler.java | 26 +-
.../eventmesh/runtime/common/EventMeshTrace.java | 26 +-
.../runtime/constants/EventMeshConstants.java | 6 +-
.../runtime/core/plugin/MQAdminWrapper.java | 26 +-
.../eventmesh/runtime/core/plugin/MQWrapper.java | 24 +-
.../protocol/grpc/consumer/ConsumerManager.java | 3 +-
.../protocol/grpc/consumer/EventMeshConsumer.java | 7 +-
.../consumergroup/ConsumerGroupClient.java | 32 +-
.../consumergroup/ConsumerGroupTopicConfig.java | 2 +-
.../consumer/consumergroup/StreamTopicConfig.java | 30 +-
.../consumer/consumergroup/WebhookTopicConfig.java | 3 +-
.../AbstractPublishBatchCloudEventProcessor.java | 105 +
.../AbstractPublishCloudEventProcessor.java | 104 +
.../processor/BatchPublishCloudEventProcessor.java | 92 +
.../processor/BatchPublishMessageProcessor.java | 146 -
.../grpc/processor/HeartbeatProcessor.java | 73 +-
.../processor/PublishCloudEventsProcessor.java | 87 +
.../protocol/grpc/processor/PublishProcessor.java | 20 +-
.../grpc/processor/ReplyMessageProcessor.java | 60 +-
.../grpc/processor/RequestCloudEventProcessor.java | 98 +
.../grpc/processor/RequestMessageProcessor.java | 156 -
.../grpc/processor/SendAsyncMessageProcessor.java | 146 -
.../grpc/processor/SubscribeProcessor.java | 62 +-
.../grpc/processor/SubscribeStreamProcessor.java | 62 +-
.../grpc/processor/UnsubscribeProcessor.java | 46 +-
.../protocol/grpc/push/AbstractPushRequest.java | 29 +-
.../core/protocol/grpc/push/HandleMsgContext.java | 2 +-
.../core/protocol/grpc/push/StreamPushRequest.java | 36 +-
.../protocol/grpc/push/WebhookPushRequest.java | 57 +-
.../protocol/grpc/service/ConsumerService.java | 83 +-
.../protocol/grpc/service/HeartbeatService.java | 15 +-
...{ProducerService.java => PublisherService.java} | 91 +-
.../core/protocol/grpc/service/ServiceUtils.java | 212 +-
.../protocol/http/consumer/EventMeshConsumer.java | 2 +-
.../http/processor/SendAsyncMessageProcessor.java | 2 +-
.../core/protocol/http/processor/inf/Client.java | 24 +-
.../http/processor/inf/HttpRequestProcessor.java | 7 +-
.../protocol/http/push/HTTPMessageHandler.java | 2 +-
.../tcp/client/EventMeshTcpMessageDispatcher.java | 2 +-
.../tcp/client/group/ClientGroupWrapper.java | 2 +-
.../tcp/client/session/push/SessionPusher.java | 2 +-
.../tcp/client/session/send/SessionSender.java | 2 +-
.../tcp/client/task/MessageTransferTask.java | 11 +-
.../org/apache/eventmesh/runtime/trace/Trace.java | 60 +-
.../apache/eventmesh/runtime/util/BannerUtil.java | 18 +-
.../eventmesh/runtime/util/HttpTinyClient.java | 5 +-
.../eventmesh/runtime/util/RemotingHelper.java | 24 +-
.../eventmesh/runtime/util/ServerGlobal.java | 1 -
.../runtime/{trace => util}/TraceUtils.java | 22 +-
.../controller/ClientManageControllerTest.java | 24 +-
.../QueryRecommendEventMeshHandlerTest.java | 24 +-
.../handler/RedirectClientByIpPortHandlerTest.java | 24 +-
.../handler/RedirectClientByPathHandlerTest.java | 24 +-
.../eventmesh/runtime/util/WebhookUtilTest.java | 1 -
eventmesh-sdk-go/log/logger.go | 163 -
.../client/grpc/producer/CloudEventProducer.java | 163 -
.../client/grpc/util/EventMeshClientUtil.java | 265 --
.../client/grpc/util/EventMeshClientUtilTest.java | 176 -
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 | 3 +-
.../eventmesh-sdk-java}/gradle.properties | 0
.../client/catalog/EventMeshCatalogClient.java | 0
.../config/EventMeshCatalogClientConfig.java | 0
.../grpc/config/EventMeshGrpcClientConfig.java | 5 +
.../grpc/consumer/EventMeshGrpcConsumer.java | 195 +-
.../client/grpc/consumer/ReceiveMsgHook.java | 0
.../client/grpc/consumer/SubStreamHandler.java | 82 +-
.../exception/ProtocolNotSupportException.java | 80 +
.../client/grpc/producer/CloudEventProducer.java | 124 +
.../grpc/producer/EventMeshGrpcProducer.java | 6 +-
.../grpc/producer/EventMeshMessageProducer.java | 52 +-
.../client/grpc/producer/GrpcProducer.java | 4 +-
.../grpc/util/EventMeshCloudEventBuilder.java | 309 ++
.../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 | 65 +-
.../grpc/producer/CloudEventProducerTest.java | 43 +-
.../grpc/producer/EventMeshGrpcProducerTest.java | 40 +-
.../producer/EventMeshMessageProducerTest.java | 32 +-
.../client/grpc/producer/MockCloudEvent.java | 0
.../grpc/util/EventMeshCloudEventBuilderTest.java | 170 +
.../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
.../apache/eventmesh/api/admin/AbstractAdmin.java} | 52 +-
.../java/org/apache/eventmesh/api/admin/Admin.java | 26 +-
.../eventmesh/api/admin/TopicProperties.java | 26 +-
.../api/factory/StoragePluginFactory.java | 24 +-
.../kafka/consumer/KafkaConsumerRunner.java | 6 +-
.../eventmesh-storage-knative/build.gradle | 4 +-
.../mongodb/client/MongodbClientManager.java | 10 +-
.../storage/mongodb/config/ConfigKey.java | 10 +-
.../mongodb/config/ConfigurationHolder.java | 10 +-
.../storage/mongodb/constant/MongodbConstants.java | 10 +-
.../storage/mongodb/consumer/MongodbConsumer.java | 10 +-
.../consumer/MongodbReplicaSetConsumer.java | 10 +-
.../consumer/MongodbStandaloneConsumer.java | 10 +-
.../storage/mongodb/producer/MongodbProducer.java | 10 +-
.../producer/MongodbReplicaSetProducer.java | 10 +-
.../producer/MongodbStandaloneProducer.java | 10 +-
.../storage/MongodbStorageResourceService.java | 10 +-
.../mongodb/utils/MongodbCloudEventUtil.java | 3 +-
.../storage/mongodb/MongodbConnectorTest.java | 10 +-
.../eventmesh/storage/mongodb/MongodbServer.java | 10 +-
.../storage/mongodb/MongodbServerTest.java | 10 +-
.../storage/pravega/client/PravegaClient.java | 2 +-
.../storage/rabbitmq/client/RabbitmqClient.java | 10 +-
.../rabbitmq/client/RabbitmqConnectionFactory.java | 10 +-
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 10 +-
.../rabbitmq/config/ConfigurationHolder.java | 10 +-
.../rabbitmq/consumer/RabbitmqConsumer.java | 10 +-
.../rabbitmq/consumer/RabbitmqConsumerHandler.java | 10 +-
.../rabbitmq/producer/RabbitmqProducer.java | 10 +-
.../storage/RabbitmqStorageResourceService.java | 10 +-
.../storage/rabbitmq/utils/ByteArrayUtils.java | 12 +-
.../rabbitmq/RabbitmqMockConnectionFactory.java | 10 +-
.../eventmesh/storage/rabbitmq/RabbitmqServer.java | 10 +-
.../cloudevent/RabbitmqCloudEventTest.java | 10 +-
.../rabbitmq/config/ConfigurationHolderTest.java | 10 +-
.../rabbitmq/consumer/RabbitmqConsumerTest.java | 10 +-
.../rabbitmq/producer/RabbitmqProducerTest.java | 10 +-
.../storage/redis/client/RedissonClient.java | 10 +-
.../storage/redis/cloudevent/CloudEventCodec.java | 10 +-
.../storage/redis/config/RedisProperties.java | 10 +-
.../storage/redis/consumer/RedisConsumer.java | 10 +-
.../storage/redis/producer/RedisProducer.java | 10 +-
.../redis/storage/RedisStorageResourceService.java | 10 +-
.../storage/redis/AbstractRedisServer.java | 24 +-
.../storage/redis/client/RedissonClientTest.java | 10 +-
.../storage/redis/config/RedisPropertiesTest.java | 10 +-
.../storage/redis/connector/UnitTest.java | 10 +-
.../storage/redis/consumer/RedisConsumerTest.java | 10 +-
.../storage/redis/producer/RedisProducerTest.java | 10 +-
.../storage/rocketmq/admin/AbstractRmqAdmin.java | 65 -
.../storage/rocketmq/admin/RocketMQAdmin.java | 115 +-
.../rocketmq/admin/RocketMQAdminAdaptor.java | 30 +-
.../cloudevent/RocketMQMessageFactory.java | 10 +-
.../impl/RocketMQBinaryMessageReader.java | 10 +-
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 10 +-
.../cloudevent/impl/RocketMQMessageWriter.java | 10 +-
.../rocketmq/promise/DefaultPromiseTest.java | 33 +-
.../storage/standalone/admin/StandaloneAdmin.java | 59 +-
.../standalone/admin/StandaloneAdminAdaptor.java | 26 +-
.../storage/standalone/broker/MessageQueue.java | 91 +-
.../standalone/broker/MessageQueueTest.java | 14 +-
.../broker/task/HistoryMessageClearTest.java | 2 +-
.../eventmesh/trace/api/AbstractTraceService.java | 149 +
.../trace/api/common/EventMeshTraceConstants.java | 3 +
.../eventmesh/trace/jaeger/JaegerTraceService.java | 117 +-
.../trace/jaeger/common/JaegerConstants.java | 23 -
.../trace/jaeger/JaegerTraceServiceTest.java | 22 +-
.../jaeger/config/JaegerConfigurationTest.java | 15 +-
.../trace/pinpoint/PinpointTraceService.java | 159 +-
.../trace/pinpoint/common/PinpointConstants.java | 2 -
.../pinpoint/exporter/PinpointSpanExporter.java | 28 +-
.../trace/pinpoint/PinpointTraceServiceTest.java | 38 +-
.../pinpoint/config/PinpointConfigurationTest.java | 24 +-
.../exporter/PinpointSpanExporterTest.java | 24 +-
.../eventmesh/trace/zipkin/ZipkinTraceService.java | 111 +-
.../trace/zipkin/common/ZipkinConstants.java | 3 -
.../trace/zipkin/ZipkinTraceServiceTest.java | 14 +-
.../webhook/admin/NacosWebHookConfigOperation.java | 4 +-
settings.gradle | 5 +-
style/checkStyle.xml | 6 +-
tools/dependency-check/known-dependencies.txt | 2 +-
532 files changed, 11137 insertions(+), 19085 deletions(-)
create mode 100644 .idea/icon.png
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/test/java/org/apache/eventmesh/admin/rocketmq/request/TopicCreateRequestTest.java
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/test/java/org/apache/eventmesh/admin/rocketmq/util/RequestMappingTest.java
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/test/java/org/apache/eventmesh/admin/rocketmq/util/UrlMappingPatternTest.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/enums/{HttpMethod.java
=> EventMeshDataContentType.java} (80%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/HeartbeatItem.java
(82%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/CloudEvent.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/CloudEventBatch.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/CloudEventBatchOrBuilder.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/CloudEventOrBuilder.java
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/{protos
=> cloudevents}/ConsumerServiceGrpc.java (54%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/EventMeshCloudEvents.java
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/EventMeshGrpcService.java
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/{protos
=> cloudevents}/HeartbeatServiceGrpc.java (58%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/PublisherServiceGrpc.java
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/{BatchMessageWrapper.java
=> BatchEventMeshCloudEventWrapper.java} (71%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/{http
=> grpc}/common/ClientType.java (76%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/EventMeshCloudEventUtils.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/{SimpleMessageWrapper.java
=> EventMeshCloudEventWrapper.java} (73%)
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/{SimpleMessageWrapper.java
=> ProtoSupport.java} (57%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/Response.java
(79%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
=>
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/SubscriptionReply.java
(62%)
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/BatchMessage.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/BatchMessageOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/EventmeshGrpc.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Heartbeat.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/HeartbeatOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/PublisherServiceGrpc.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/RequestHeader.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/RequestHeaderOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Response.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/ResponseOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SimpleMessage.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SimpleMessageOrBuilder.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Subscription.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SubscriptionOrBuilder.java
copy
eventmesh-common/src/{test/java/org/apache/eventmesh/common/utils/SystemUtilsTest.java
=> main/java/org/apache/eventmesh/common/utils/ReflectUtils.java} (53%)
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/grpc/common/EventMeshCloudEventUtilsTest.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/ConnectorWorker.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/config/Config.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/config/Constants.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/config/PubSubConfig.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/config/SinkConfig.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/config/SourceConfig.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/connector/SinkConnector.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/connector/SourceConnector.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/sink/Sink.java
delete mode 100644
eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector/api/source/Source.java
copy
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/ReceiveMsgHook.java
=>
eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/utils/PrometheusExporterConstants.java
(66%)
create mode 100644
eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/utils/PrometheusExporterUtils.java
rename {eventmesh-connector-sdks => eventmesh-openconnect}/README.md (100%)
copy {eventmesh-connector-sdks => eventmesh-openconnect}/build.gradle (100%)
rename {eventmesh-connector-sdks/eventmesh-connector-sdk-java =>
eventmesh-openconnect/eventmesh-openconnect-java}/build.gradle (95%)
rename {eventmesh-connector-sdks/eventmesh-connector-sdk-java =>
eventmesh-openconnect/eventmesh-openconnect-java}/gradle.properties (100%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/Application.java
(78%)
copy
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/EventMeshExtensionConstant.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/ConnectorWorker.java
(79%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/SinkWorker.java
(88%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/SourceWorker.java
(87%)
copy eventmesh-starter/build.gradle =>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/Config.java
(90%)
copy
{eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config}/Constants.java
(71%)
copy
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/conf/EventMeshTCPClientConfig.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/PubSubConfig.java
(73%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/SinkConfig.java
(82%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/config/SourceConfig.java
(82%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/api/connector/Connector.java
(75%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionType.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnector.java
(69%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionMode.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnector.java
(68%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/api/data/ConnectRecord.java
(90%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/api/data/DefaultKeyValue.java
(91%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/api/data/KeyValue.java
(79%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/api/data/RecordOffset.java
(78%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/api/data/RecordPartition.java
(79%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/api/data/RecordPosition.java
(79%)
copy
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/GrpcProducer.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/sink/Sink.java
(74%)
copy
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/GrpcProducer.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/source/Source.java
(74%)
rename
{eventmesh-connector-sdks/eventmesh-connector-sdk-java/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect}/util/ConfigUtil.java
(81%)
rename {eventmesh-connector-sdks => eventmesh-openconnect}/gradle.properties
(100%)
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java
delete mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcMessageProtocolResolver.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-grpc/src/main/proto/eventmesh-cloudevents.proto
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-grpc/src/main/proto/eventmesh-service.proto
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java
delete mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/grpc/GrpcMessageProtocolResolver.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/AbstractPublishBatchCloudEventProcessor.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/AbstractPublishCloudEventProcessor.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishCloudEventProcessor.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishMessageProcessor.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/PublishCloudEventsProcessor.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/BaseRequestBody.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/PublishProcessor.java
(72%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/RequestCloudEventProcessor.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/RequestMessageProcessor.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SendAsyncMessageProcessor.java
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/{ProducerService.java
=> PublisherService.java} (53%)
rename eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{trace =>
util}/TraceUtils.java (87%)
delete mode 100644 eventmesh-sdk-go/log/logger.go
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java
delete mode 100644
eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java
delete mode 100644 eventmesh-sdk-rust/.vscode/settings.json
rename {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
(96%)
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
(95%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java
(55%)
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
(58%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/exception/ProtocolNotSupportException.java
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/producer/EventMeshGrpcProducer.java
(94%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/producer/EventMeshMessageProducer.java
(59%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/main/java/org/apache/eventmesh/client/grpc/producer/GrpcProducer.java
(94%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshCloudEventBuilder.java
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
(68%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducerTest.java
(58%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/producer/EventMeshGrpcProducerTest.java
(80%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/producer/EventMeshMessageProducerTest.java
(77%)
rename {eventmesh-sdk-java =>
eventmesh-sdks/eventmesh-sdk-java}/src/test/java/org/apache/eventmesh/client/grpc/producer/MockCloudEvent.java
(100%)
create mode 100644
eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshCloudEventBuilderTest.java
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-storage-plugin/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/producer/AbstractProducer.java
=>
eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/admin/AbstractAdmin.java}
(53%)
delete mode 100644
eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/admin/AbstractRmqAdmin.java
create mode 100644
eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/AbstractTraceService.java
delete mode 100644
eventmesh-trace-plugin/eventmesh-trace-jaeger/src/main/java/org/apache/eventmesh/trace/jaeger/common/JaegerConstants.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
