-
Notifications
You must be signed in to change notification settings - Fork 592
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
Use knative service for wathola receiver if available #4430
Conversation
[APPROVALNOTIFIER] This PR is NOT APPROVED This pull-request has been approved by: cardil The full list of commands accepted by this bot can be found here.
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
Codecov Report
@@ Coverage Diff @@
## master #4430 +/- ##
=======================================
Coverage 81.06% 81.06%
=======================================
Files 281 281
Lines 7981 7981
=======================================
Hits 6470 6470
Misses 1122 1122
Partials 389 389 Continue to review full report at Codecov.
|
3d87c4b
to
b6a8721
Compare
/hold Some additional changes are required |
/unhold |
c3b5447
to
4606e66
Compare
/test all |
4606e66
to
28fbbb2
Compare
/assign @zhongduo |
Thanks for adding this. I do think having the requirement of accessing from external can be a big headache and was considering doing similar thing for our CI test. |
Do I understand correctly that all the extra logic, including the forwarder, is just to make an http request to |
/hold Upgrading serving component causes the receiver ksvc to restart and loose track of transmitted events. |
Those are sending, and receiving cloud events. On receiving part those are keep track. At test end sender sends finished event with number of events he successfully pushed to eventing broker. That's why receiver can calculate and return report of propagated events. Forwarder component is there to test that if we don't loose events on ksvc autoscaling components. More info on upgrade readme file. Yes. I think that's possible to deploy curl like job, request an internal in cluster address, and read json from jobs logs. That's good alternative to original idea of using configmaps and k8s events. |
return u | ||
} | ||
|
||
func fetchReceiverReport(u *url.URL, log *zap.SugaredLogger) *Report { | ||
log.Infof("Fetching receiver report from: %v", u) |
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.
minor: perhaps this log should be updated as well since the preferred pattern seems to be not using Infof
when there is a single variable at the end
Is related to #3175
This PR isn't doing #3175 a full justice. This is a minor improvement, in which we can get receiver report even if given K8s cluster doesn't a worker node external, reachable address. It's done when there is a Serving component available.
Such a situation arisen on our team when we were trying to incorporate upgrade tests in our product (see openshift-knative/serverless-operator#530 (comment)).
Proposed Changes