You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by vo...@apache.org on 2022/02/10 06:37:37 UTC
[incubator-eventmesh] branch grpc updated (d6f9c3e -> 7332d24)
This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a change to branch grpc
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git.
from d6f9c3e [Issue #417] Create getting started instructions for Grpc transport procotol (#711)
new 96306f7 [Issue #417] Create getting started instructions for Grpc transport procotol
new e8e481b [Issue #533] Adding design doc for EventMesh Workflow
new 6cfa401 [ISSUE #696] Add metrics plugin (#709)
new 96dd89a [ISSUE #713] Fix trace bug (#712)
new dd73a41 [Issue #553] update the design doc.
new 3763f0b small updates to doc
new 222bf40 small update
new 335271c adding asyncapi type to event defs
new d751188 Remove unnecessary call toString (#719)
new c971a76 [Issue #553] add workflow diagram to the design doc
new d26c558 Update intro.md (#722)
new bf7559a Update roadmap.md (#721)
new 802b010 [Issue #417] update Grpc Message Model name to SimpleMessage
new f0d1b8a [Issue #417] more update Grpc Message Model name to SimpleMessage
new dad432e [Issue #718] Fix readme file and protobuf file based on review comments
new 025eb2e [Issue #745] fix the ack bugs and cloudevent message resolver
new 97b3d8a [Issue #744] update SDK API message model
new 0ad24d7 [Issue #744] fix the gRPC Consumer SubscribeStream Message handler
new 2d84469 [Issue #744] Grpc Request-Reply API support
new 495a67e [Issue #744] Bug fix for Grpc Request-Reply API support
new e1c75a8 [Issue #744] minor fix for Grpc request-Reply API
new fceb1d8 [Issue #744] fix infinte message loop in Grpc CloudEvent request-Reply API
new 0450346 [Issue #744] Fix Grpc subscribe-unsubscribe bug
new 7d05921 [Issue #744] Fix Data models in Grpc Request-Reply API
new 2e085d8 [Issue #744] Code optimization for Grpc Request-Reply API
new 137497f [Issue #417] support Grpc broadcast async publish
new 0213180 Merge remote-tracking branch 'upstream/grpc' into grpc
new 48ab8d3 [Issue #718] add synchronized calls for grpc streamObserver
new 7332d24 Merge pull request #723 from jinrongluo/grpc
The 861 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
build.gradle | 1 +
docs/cn/instructions/eventmesh-runtime-protocol.md | 8 +-
.../instructions/eventmesh-sdk-java-quickstart.md | 4 +-
.../eventmesh-trace-Zipkin-instruction.md | 8 +-
docs/en/features/eventmesh-workflow-design.md | 287 +++
docs/en/instructions/eventmesh-runtime-protocol.md | 8 +-
.../instructions/eventmesh-sdk-java-quickstart.md | 4 +-
.../eventmesh-trace-Zipkin-instruction.md | 6 +-
docs/en/intro.md | 3 +
docs/en/roadmap.md | 31 +
docs/images/features/eventmesh-workflow-arch.jpg | Bin 0 -> 166972 bytes
docs/images/features/eventmesh-workflow-diag.png | Bin 0 -> 135137 bytes
.../images/features/eventmesh-workflow-usecase.jpg | Bin 0 -> 109159 bytes
.../common/config/CommonConfiguration.java | 80 +-
...ssageWrapper.java => SimpleMessageWrapper.java} | 14 +-
.../common/protocol/grpc/common/StatusCode.java | 3 +-
.../protocol/grpc/protos/ConsumerServiceGrpc.java | 77 +-
.../common/protocol/grpc/protos/EventmeshGrpc.java | 186 +-
.../protocol/grpc/protos/PublisherServiceGrpc.java | 102 +-
.../{EventMeshMessage.java => SimpleMessage.java} | 118 +-
...eOrBuilder.java => SimpleMessageOrBuilder.java} | 4 +-
.../common/protocol/grpc/protos/Subscription.java | 2031 +++++++++++++++++++-
.../grpc/protos/SubscriptionOrBuilder.java | 13 +
.../rocketmq/consumer/PushConsumerImpl.java | 6 +-
.../connector/rocketmq/utils/OMSUtil.java | 2 +-
.../CloudEventsBatchPublishInstance.java | 6 +-
.../cloudevents/CloudEventsPublishInstance.java | 4 +-
...stance.java => CloudEventsRequestInstance.java} | 8 +-
...ishInstance.java => AsyncPublishBroadcast.java} | 28 +-
.../pub/eventmeshmessage/AsyncPublishInstance.java | 24 +-
.../pub/eventmeshmessage/BatchPublishInstance.java | 29 +-
.../pub/eventmeshmessage/RequestReplyInstance.java | 22 +-
.../grpc/sub/CloudEventsAsyncSubscribe.java | 31 +-
...bscribe.java => CloudEventsSubscribeReply.java} | 45 +-
.../grpc/sub/EventmeshAsyncSubscribe.java | 34 +-
...cribe.java => EventmeshSubscribeBroadcast.java} | 42 +-
...Subscribe.java => EventmeshSubscribeReply.java} | 50 +-
.../eventmesh/grpc/sub/app/service/SubService.java | 29 +-
.../build.gradle | 0
.../eventmesh-metrics-api}/build.gradle | 9 +-
.../eventmesh-metrics-api}/gradle.properties | 0
.../metrics/api/MetricsPluginFactory.java | 23 +-
.../eventmesh/metrics/api/MetricsRegistry.java | 34 +-
.../metrics/api/model/HttpSummaryMetrics.java | 104 +-
.../apache/eventmesh/metrics/api/model/Metric.java | 6 +-
.../metrics/api/model/TcpSummaryMetrics.java | 123 ++
.../eventmesh-metrics-opentelemetry}/build.gradle | 21 +-
.../gradle.properties | 4 +-
.../OpenTelemetryMetricsRegistry.java | 87 +
.../config/OpenTelemetryConfiguration.java | 81 +
.../metrics/OpenTelemetryHttpExporter.java | 298 +++
.../metrics/OpenTelemetryTcpExporter.java | 89 +
...rg.apache.eventmesh.metrics.api.MetricsRegistry | 6 +-
.../src/main/resources/opentelemetry.properties | 3 +
.../src/main/resources}/prometheus.yml | 1 +
.../gradle.properties | 0
.../cloudevents/CloudEventsProtocolAdaptor.java | 13 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 95 +-
.../src/main/proto/eventmesh-client.proto | 26 +-
.../meshmessage/MeshMessageProtocolAdaptor.java | 11 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 44 +-
eventmesh-runtime/build.gradle | 23 +-
eventmesh-runtime/conf/eventmesh.properties | 6 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 10 +-
.../runtime/boot/EventMeshGrpcServer.java | 12 +-
.../runtime/boot/EventMeshHTTPServer.java | 20 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 16 +-
.../protocol/grpc/consumer/ConsumerManager.java | 12 +-
.../protocol/grpc/consumer/EventMeshConsumer.java | 11 +-
.../consumergroup/ConsumerGroupClient.java | 6 +-
.../consumer/consumergroup/StreamTopicConfig.java | 32 +-
.../consumer/consumergroup/WebhookTopicConfig.java | 3 -
.../processor/BatchPublishMessageProcessor.java | 10 +-
.../grpc/processor/HeartbeatProcessor.java | 13 +-
...geProcessor.java => ReplyMessageProcessor.java} | 66 +-
...Processor.java => RequestMessageProcessor.java} | 50 +-
.../grpc/processor/SendAsyncMessageProcessor.java | 27 +-
.../grpc/processor/SubscribeProcessor.java | 8 +-
.../grpc/processor/SubscribeStreamProcessor.java | 46 +-
.../grpc/processor/UnsubscribeProcessor.java | 7 +-
.../protocol/grpc/producer/EventMeshProducer.java | 10 +-
.../protocol/grpc/producer/SendMessageContext.java | 24 -
.../protocol/grpc/push/AbstractPushRequest.java | 26 +-
.../core/protocol/grpc/push/StreamPushRequest.java | 94 +-
.../protocol/grpc/push/WebhookPushRequest.java | 175 +-
.../protocol/grpc/service/ConsumerService.java | 114 +-
.../core/protocol/grpc/service/EventEmitter.java | 6 +-
.../protocol/grpc/service/HeartbeatService.java | 2 +-
.../protocol/grpc/service/ProducerService.java | 26 +-
.../core/protocol/grpc/service/ServiceUtils.java | 44 +-
.../http/processor/BatchSendMessageProcessor.java | 13 +-
.../processor/BatchSendMessageV2Processor.java | 34 +-
.../http/processor/HeartBeatProcessor.java | 6 +-
.../http/processor/ReplyMessageProcessor.java | 79 +-
.../http/processor/SendAsyncMessageProcessor.java | 16 +-
.../http/processor/SendSyncMessageProcessor.java | 34 +-
.../http/processor/SubscribeProcessor.java | 26 +-
.../http/processor/UnSubscribeProcessor.java | 11 +-
.../protocol/http/producer/SendMessageContext.java | 2 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 6 +-
.../core/protocol/http/retry/HttpRetryer.java | 9 +-
.../protocol/tcp/client/EventMeshTcp2Client.java | 2 +-
.../tcp/client/EventMeshTcpMessageDispatcher.java | 2 +-
.../tcp/client/group/ClientGroupWrapper.java | 138 +-
.../core/protocol/tcp/client/session/Session.java | 3 +-
.../tcp/client/session/push/SessionPusher.java | 2 +-
.../tcp/client/session/send/SessionSender.java | 4 +-
.../client/session/send/UpStreamMsgContext.java | 4 +-
.../tcp/client/task/MessageTransferTask.java | 2 +-
.../runtime/metrics/http/GroupMetrics.java | 34 -
.../runtime/metrics/http/HTTPMetricsServer.java | 158 +-
.../runtime/metrics/http/HealthMetrics.java | 38 -
.../runtime/metrics/http/TcpSummaryMetrics.java | 403 ----
.../runtime/metrics/http/TopicMetrics.java | 33 -
.../OpenTelemetryHTTPMetricsExporter.java | 310 ---
.../OpenTelemetryPrometheusExporter.java | 63 -
.../OpenTelemetryTCPMetricsExporter.java | 102 -
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 192 +-
.../eventmesh/runtime/util/RemotingHelper.java | 2 +-
.../org/apache/eventmesh/runtime/util/Utils.java | 4 +-
.../runtime/client/impl/PubClientImpl.java | 2 +-
.../runtime/client/impl/SubClientImpl.java | 2 +-
.../apache/eventmesh/runtime/demo/CClientDemo.java | 2 +-
.../eventmesh/runtime/demo/SyncPubClient.java | 2 +-
.../eventmesh/runtime/demo/SyncSubClient.java | 2 +-
.../grpc/{ => consumer}/EventMeshGrpcConsumer.java | 215 ++-
.../client/grpc/{ => consumer}/ReceiveMsgHook.java | 4 +-
.../client/grpc/consumer/SubStreamHandler.java | 142 ++
.../client/grpc/producer/CloudEventProducer.java | 86 +-
.../grpc/{ => producer}/EventMeshGrpcProducer.java | 67 +-
.../client/grpc/util/EventMeshClientUtil.java | 175 +-
.../eventmesh/spi/EventMeshExtensionType.java | 1 +
settings.gradle | 3 +
133 files changed, 5038 insertions(+), 2722 deletions(-)
create mode 100644 docs/en/features/eventmesh-workflow-design.md
create mode 100644 docs/images/features/eventmesh-workflow-arch.jpg
create mode 100644 docs/images/features/eventmesh-workflow-diag.png
create mode 100644 docs/images/features/eventmesh-workflow-usecase.jpg
rename eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/{EventMeshMessageWrapper.java => SimpleMessageWrapper.java} (70%)
rename eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/{EventMeshMessage.java => SimpleMessage.java} (93%)
rename eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/{EventMeshMessageOrBuilder.java => SimpleMessageOrBuilder.java} (97%)
rename eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/{CloudEventsRequestReplyInstance.java => CloudEventsRequestInstance.java} (91%)
copy eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/{AsyncPublishInstance.java => AsyncPublishBroadcast.java} (76%)
copy eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/{CloudEventsAsyncSubscribe.java => CloudEventsSubscribeReply.java} (51%)
copy eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/{EventmeshAsyncSubscribe.java => EventmeshSubscribeBroadcast.java} (52%)
copy eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/{EventmeshAsyncSubscribe.java => EventmeshSubscribeReply.java} (50%)
copy {eventmesh-security-plugin => eventmesh-metrics-plugin}/build.gradle (100%)
copy {eventmesh-connector-plugin/eventmesh-connector-api => eventmesh-metrics-plugin/eventmesh-metrics-api}/build.gradle (82%)
copy {eventmesh-connector-plugin => eventmesh-metrics-plugin/eventmesh-metrics-api}/gradle.properties (100%)
copy eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/ReceiveMsgHook.java => eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/MetricsPluginFactory.java (53%)
copy eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java => eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/MetricsRegistry.java (58%)
rename eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/SummaryMetrics.java => eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/HttpSummaryMetrics.java (84%)
copy eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java => eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/Metric.java (85%)
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/TcpSummaryMetrics.java
copy {eventmesh-connector-plugin/eventmesh-connector-api => eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry}/build.gradle (63%)
copy {eventmesh-connector-plugin/eventmesh-connector-standalone => eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry}/gradle.properties (94%)
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/java/org/apache/eventmesh/metrics/opentelemetry/OpenTelemetryMetricsRegistry.java
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/java/org/apache/eventmesh/metrics/opentelemetry/config/OpenTelemetryConfiguration.java
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/java/org/apache/eventmesh/metrics/opentelemetry/metrics/OpenTelemetryHttpExporter.java
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/java/org/apache/eventmesh/metrics/opentelemetry/metrics/OpenTelemetryTcpExporter.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/gradle.properties => eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.metrics.api.MetricsRegistry (90%)
copy eventmesh-runtime/gradle.properties => eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/resources/opentelemetry.properties (93%)
rename {eventmesh-runtime/conf => eventmesh-metrics-plugin/eventmesh-metrics-opentelemetry/src/main/resources}/prometheus.yml (99%)
copy {eventmesh-connector-plugin => eventmesh-metrics-plugin}/gradle.properties (100%)
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/{SendAsyncMessageProcessor.java => ReplyMessageProcessor.java} (67%)
rename eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/{RequestReplyMessageProcessor.java => RequestMessageProcessor.java} (69%)
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/GroupMetrics.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/HealthMetrics.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/TcpSummaryMetrics.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/TopicMetrics.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryHTTPMetricsExporter.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryPrometheusExporter.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryTCPMetricsExporter.java
rename eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/{ => consumer}/EventMeshGrpcConsumer.java (51%)
rename eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/{ => consumer}/ReceiveMsgHook.java (91%)
create mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java
rename eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/{ => producer}/EventMeshGrpcProducer.java (57%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org