-
Notifications
You must be signed in to change notification settings - Fork 1.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
remote target and transmission protocol #13357
Conversation
bb2906f
to
591bacc
Compare
591bacc
to
b49761e
Compare
} | ||
|
||
// A request is uniquely identified by the message id and the hash of the payload to prevent a malicious | ||
// actor from sending a different payload with the same message id |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I'm still not a fan of this. I'm worried that it'll make debugging harder. IMO a more natural logic will be to cluster messages based on WorkflowExecutionID and then pick F+1 identical payloads once we have them. Your logic achieves the same outcome so I'm not going to block it.
1605484
to
77271e0
Compare
77271e0
to
5fcc3b3
Compare
dispatcher types.Dispatcher | ||
requestTimeout time.Duration | ||
|
||
messageIDToCallerRequest map[string]*request.CallerRequest |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why did you choose to put the Request objects in separate packages? In my mind organising all of the objects that talk to one another into the same package feels like it makes more sense (so caller + caller request; receiver + its request).
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
to prevent accidental call of non-threadsafe methods, just caution really
65a6b37
to
65bf532
Compare
22676f7
to
20a3061
Compare
b8cde07
to
12962e4
Compare
Quality Gate passedIssues Measures |
ks-119