Replacing port-forwarding with k8s events in recordevents#4171
Replacing port-forwarding with k8s events in recordevents#4171knative-prow-robot merged 23 commits into
Conversation
mattmoor
left a comment
There was a problem hiding this comment.
Produced via:
gofmt -s -w $(find -path './vendor' -prune -o -path './third_party' -prune -o -name '*.pb.go' -prune -o -type f -name '*.go' -print)
goimports -w $(find -name '*.go' | grep -v vendor | grep -v third_party | grep -v .pb.go | grep -v wire_gen.go)
mattmoor
left a comment
There was a problem hiding this comment.
Produced via:
gofmt -s -w $(find -path './vendor' -prune -o -path './third_party' -prune -o -name '*.pb.go' -prune -o -type f -name '*.go' -print)
goimports -w $(find -name '*.go' | grep -v vendor | grep -v third_party | grep -v .pb.go | grep -v wire_gen.go)
mattmoor
left a comment
There was a problem hiding this comment.
Produced via:
gofmt -s -w $(find -path './vendor' -prune -o -path './third_party' -prune -o -name '*.pb.go' -prune -o -type f -name '*.go' -print)
goimports -w $(find -name '*.go' | grep -v vendor | grep -v third_party | grep -v .pb.go | grep -v wire_gen.go)
b9b27bb to
bf8d8cf
Compare
mattmoor
left a comment
There was a problem hiding this comment.
Produced via:
gofmt -s -w $(find -path './vendor' -prune -o -path './third_party' -prune -o -name '*.pb.go' -prune -o -type f -name '*.go' -print)
goimports -w $(find -name '*.go' | grep -v vendor | grep -v third_party | grep -v .pb.go | grep -v wire_gen.go)
mattmoor
left a comment
There was a problem hiding this comment.
Produced via:
gofmt -s -w $(find -path './vendor' -prune -o -path './third_party' -prune -o -name '*.pb.go' -prune -o -type f -name '*.go' -print)
goimports -w $(find -name '*.go' | grep -v vendor | grep -v third_party | grep -v .pb.go | grep -v wire_gen.go)
mattmoor
left a comment
There was a problem hiding this comment.
Produced via:
gofmt -s -w $(find -path './vendor' -prune -o -path './third_party' -prune -o -name '*.pb.go' -prune -o -type f -name '*.go' -print)
goimports -w $(find -name '*.go' | grep -v vendor | grep -v third_party | grep -v .pb.go | grep -v wire_gen.go)
|
/assign @lionelvillard @n3wscott @n3wscott Can i remove the code under pkg/test/observer? At this point that code is orphan and not used in this repo (I've moved the bits i needed and modified them under test/lib/recordevents) |
| informerFactory := informers.NewSharedInformerFactoryWithOptions( | ||
| client, | ||
| 0, | ||
| informers.WithNamespace(namespace), | ||
| ) | ||
| eventsInformer := informerFactory.Core().V1().Events().Informer() | ||
|
|
||
| el := EventListener{ | ||
| cancel: cancelCtx, | ||
| } | ||
|
|
||
| eventsInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{ | ||
| AddFunc: func(obj interface{}) { | ||
| el.handle(obj.(*corev1.Event)) | ||
| }, | ||
| }) | ||
|
|
||
| go func() { | ||
| eventsInformer.Run(ctx.Done()) | ||
| logf("EventListener stopped") | ||
| }() |
There was a problem hiding this comment.
In reconciler-test the event informer is injected into the context (something to keep in mind when moving this code over).
There was a problem hiding this comment.
Cool so we can avoid creating it manually!
There was a problem hiding this comment.
We'll still need this EventListener, right? Note that this is shared between different EventInfoStore
|
The following jobs failed:
Failed non-flaky tests preventing automatic retry of pull-knative-eventing-conformance-tests: and 47 more. |
|
The following jobs failed:
Failed non-flaky tests preventing automatic retry of pull-knative-eventing-integration-tests: and 35 more. |
| package recordevents | ||
|
|
||
| // EventLog is the contract for an event logger to vent an event. | ||
| type EventLog interface { |
There was a problem hiding this comment.
why are you copying this to test/lib?
There was a problem hiding this comment.
now we have three copies of this code?
There was a problem hiding this comment.
Because that code is hard to reuse, I had to do some important changes (interfaces and impls looks similar, but they're different)
There was a problem hiding this comment.
That's why I'm saying, if we use that code only in recordevents, what if we just remove the one under test/lib?
There was a problem hiding this comment.
now we have three copies of this code?
Copying to the new test framework was a mistake, i'm going to port this new code there 😄
|
The issue here is weird, for some reason it timeouts on waiting for pods to delete |
|
Solved, I was not closing the http server correctly |
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
6996305 to
1196010
Compare
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
|
/retest |
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
| MessageFunc: func(event *corev1.Event) string { | ||
| return event.Message | ||
| }, | ||
| MaxEvents: 1, |
|
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: n3wscott, slinkydeveloper The full list of commands accepted by this bot can be found here. The pull request process is described here DetailsNeeds approval from an approver in each of these files:
Approvers can indicate their approval by writing |
|
@slinkydeveloper is it possible to backport this to 0.17 and 0.18 ? 😁 |
|
@matzew Not sure for 0.17, changes are too much extensive both on recordevents and lib test code... There are also other changes in that code before this one. If we need it i can work on it but that's not a trivial port :) 0.18 might be doable |
* WIP Replacing port-forwarding with k8s events in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * WIP Events are sent properly from recordevents to k8s events Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Sending the beast in battle Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Update Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Moved resources of recordevents in proper module Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * gofmt Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Another one Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other stuff Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other lints checks Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Warn Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Now the linter Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Missing decorator in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Simplified the sink definition, just sending events to myself Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Happy linter, happy me Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Correct HTTP server shutdown Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Try fix correlator config Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Just close the server Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Still messing up with the Event correlator options Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * lint check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit b7a7126) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
* WIP Replacing port-forwarding with k8s events in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * WIP Events are sent properly from recordevents to k8s events Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Sending the beast in battle Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Update Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Moved resources of recordevents in proper module Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * gofmt Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Another one Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other stuff Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other lints checks Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Warn Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Now the linter Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Missing decorator in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Simplified the sink definition, just sending events to myself Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Happy linter, happy me Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Correct HTTP server shutdown Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Try fix correlator config Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Just close the server Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Still messing up with the Event correlator options Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * lint check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit b7a7126) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
…nts (#4230) * Replacing port-forwarding with k8s events in recordevents (#4171) * WIP Replacing port-forwarding with k8s events in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * WIP Events are sent properly from recordevents to k8s events Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Sending the beast in battle Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Update Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Moved resources of recordevents in proper module Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * gofmt Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Another one Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other stuff Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other lints checks Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Warn Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Now the linter Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Missing decorator in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Simplified the sink definition, just sending events to myself Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Happy linter, happy me Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Correct HTTP server shutdown Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Try fix correlator config Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Just close the server Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Still messing up with the Event correlator options Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * lint check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit b7a7126) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Reverted gomod Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Regenerated go mod Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
* WIP Replacing port-forwarding with k8s events in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * WIP Events are sent properly from recordevents to k8s events Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Sending the beast in battle Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Update Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Moved resources of recordevents in proper module Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * gofmt Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Another one Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other stuff Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other lints checks Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Warn Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Now the linter Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Missing decorator in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Simplified the sink definition, just sending events to myself Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Happy linter, happy me Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Correct HTTP server shutdown Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Try fix correlator config Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Just close the server Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Still messing up with the Event correlator options Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * lint check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit b7a7126) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
* WIP Replacing port-forwarding with k8s events in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * WIP Events are sent properly from recordevents to k8s events Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Sending the beast in battle Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Update Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Moved resources of recordevents in proper module Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * gofmt Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Another one Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other stuff Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other lints checks Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Warn Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Now the linter Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Missing decorator in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Simplified the sink definition, just sending events to myself Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Happy linter, happy me Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Correct HTTP server shutdown Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Try fix correlator config Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Just close the server Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Still messing up with the Event correlator options Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * lint check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit b7a7126) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
* Replacing port-forwarding with k8s events in recordevents (#4171) * WIP Replacing port-forwarding with k8s events in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * WIP Events are sent properly from recordevents to k8s events Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Sending the beast in battle Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Update Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Moved resources of recordevents in proper module Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * gofmt Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Another one Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other stuff Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other copyrights Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * boilerplate check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Other lints checks Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Warn Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Now the linter Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Missing decorator in recordevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Simplified the sink definition, just sending events to myself Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Happy linter, happy me Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Correct HTTP server shutdown Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Try fix correlator config Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Just close the server Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Still messing up with the Event correlator options Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * lint check Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit b7a7126) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Reuse recordevents as transformevents (#4291) * transformevents done Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * transformevents done Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Test Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Fix copyright Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Did something Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit d5d4f42) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Using recordevents as sequencestepper (#4313) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit 656ab81) * Remove transformevents usages (#4309) * Remove transformevents Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Comments Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Let's be less breaky: brought back the image Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit 3e7f942) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Fixes after cherry pick Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Remove sequence stepper usages (#4344) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit 515f416) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Remove filterevents usages (#4347) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> (cherry picked from commit ca85d86) Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> # Conflicts: # test/lib/resources/kube.go * Update Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Not sure why SYSTEM_NAMESPACE doesn't work in 0.17 Signed-off-by: Francesco Guardiani <francescoguard@gmail.com> * Did the same error 2 times Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
Signed-off-by: Francesco Guardiani francescoguard@gmail.com
Fixes #3570
Proposed Changes