Skip to content

Conversation

@RiESAEX
Copy link
Contributor

@RiESAEX RiESAEX commented Aug 14, 2022

Resolve #815

Motivation

this PR is create to reduce potential duplicate work of rust sdk

Modifications

eventmesh-sdk-rust/

Jobs

  • grpc producer publish
  • grpc producer batch publish
  • grpc producer request
  • grpc consumer subscribe
  • grpc consumer unsubscribe
  • grpc consumer stream

Copy link
Contributor

@github-actions github-actions bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Welcome to the Apache EventMesh (incubating) community!!
This is your first PR in our project. We're very excited to have you onboard contributing. Your contributions are greatly appreciated!

Please make sure that the changes are covered by tests.
We will be here shortly.
Let us know if you need any help!

Want to get closer to the community?

WeChat Group:
wechat_qr

Mailing Lists:

Name Description Subscribe Unsubscribe Archive
Users User support and questions mailing list Subscribe Unsubscribe Mail Archives
Development Development related discussions Subscribe Unsubscribe Mail Archives
Commits All commits to repositories Subscribe Unsubscribe Mail Archives

@qqeasonchen
Copy link
Contributor

@RiESAEX Nice job, I suggest you submit by servral smaller PRs, thx.

unique_id: unique_id.to_string(),
topic: topic.to_string(),
content: content.to_string(),
ttl,
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

If the code is not used subsequently, it may be possible to remove the commented out code.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

for create_time
https://github.com/apache/incubator-eventmesh/blob/8b2f3fd38051fa85fe0f48421eb12e4d03205b42/eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshMessage.java#L44
there is a field in java code, but it was not used (may be used in logger?). I'm not sure if it's needed so I just commented it.

for ths prop, I just not sure what it is.
I found it only store the TTL (except test code of EventMeshMessage).
https://github.com/apache/incubator-eventmesh/blob/8b2f3fd38051fa85fe0f48421eb12e4d03205b42/eventmesh-protocol-plugin/eventmesh-protocol-grpc/src/main/proto/eventmesh-client.proto#L46-L50
In grpc producer, the message already has a TTL field and prop is sent,
https://github.com/apache/incubator-eventmesh/blob/8b2f3fd38051fa85fe0f48421eb12e4d03205b42/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshMessageProducer.java#L138
In http producer, I think the prop was not even send (It just pick up the ttl in it, and put it to header).

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Ok, I see, you don't seem to have added a license, maybe you need to add it.

@codecov
Copy link

codecov bot commented Aug 24, 2022

Codecov Report

Merging #1156 (fda3987) into master (29a40af) will decrease coverage by 1.04%.
The diff coverage is n/a.

❗ Current head fda3987 differs from pull request most recent head 4925c56. Consider uploading reports for the commit 4925c56 to get more accurate results

@@             Coverage Diff             @@
##             master   #1156      +/-   ##
===========================================
- Coverage     10.92%   9.88%   -1.05%     
+ Complexity      730     637      -93     
===========================================
  Files           403     382      -21     
  Lines         24346   23640     -706     
  Branches       2680    2619      -61     
===========================================
- Hits           2659    2336     -323     
+ Misses        21430   21081     -349     
+ Partials        257     223      -34     
Impacted Files Coverage Δ
...ntmesh/runtime/util/EventMeshCloudEventWriter.java 0.00% <0.00%> (-100.00%) ⬇️
...in/java/org/apache/eventmesh/common/Constants.java 0.00% <0.00%> (-85.72%) ⬇️
.../admin/handler/QueryRecommendEventMeshHandler.java 58.06% <0.00%> (-32.26%) ⬇️
...org/apache/eventmesh/runtime/util/IOTinyUtils.java 37.87% <0.00%> (-28.79%) ⬇️
...apache/eventmesh/runtime/util/ValueComparator.java 0.00% <0.00%> (-25.00%) ⬇️
...ime/admin/handler/RedirectClientByPathHandler.java 56.00% <0.00%> (-24.00%) ⬇️
...g/apache/eventmesh/runtime/util/EventMeshUtil.java 58.08% <0.00%> (-22.80%) ⬇️
.../apache/eventmesh/runtime/util/HttpTinyClient.java 74.13% <0.00%> (-13.80%) ⬇️
...org/apache/eventmesh/runtime/util/WebhookUtil.java 48.64% <0.00%> (-8.11%) ⬇️
...ava/org/apache/eventmesh/common/utils/IPUtils.java 33.33% <0.00%> (-6.49%) ⬇️
... and 62 more

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

@qqeasonchen
Copy link
Contributor

@RiESAEX I suggest submitting by several smaller PRs.

@qqeasonchen qqeasonchen changed the title [ISSUE #815] feat: Rust sdk [ISSUE #815] feature: Rust sdk Aug 30, 2022
@qqeasonchen qqeasonchen marked this pull request as ready for review September 1, 2022 11:10
@qqeasonchen
Copy link
Contributor

@RiESAEX please take care of the CI fail tasks.

Copy link
Contributor

@qqeasonchen qqeasonchen left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@qqeasonchen qqeasonchen merged commit 67ee666 into apache:master Sep 2, 2022
xwm1992 pushed a commit to xwm1992/EventMesh that referenced this pull request Sep 23, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Feature] Support Rust

3 participants