-
Notifications
You must be signed in to change notification settings - Fork 64
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
23 informers deliverable #314
Conversation
✔️ Deploy Preview for elated-stonebraker-105904 canceled. 🔨 Explore the source changes: 7f1aa7f 🔍 Inspect the deploy log: https://app.netlify.com/sites/elated-stonebraker-105904/deploys/618c21c08b98b00007d2cdb0 |
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.
We shouldn't review this until #304 lands
Also we've got a flake that should have died by now, will investigate:
723c1f8
to
7482de3
Compare
- Backofftests made sense when we used errors and timeouts to ensure reconcile was called again. - Now when a reconcile error occurs, backoff will be shortcircuited by informers. Testing informers work correctly is all we need. [#23] Co-authored-by: Emily Johnson <emjohnson@vmware.com>
- We're dependent on APIServer + our countroller resolving this stamp in under a second, which just doesn't always happen. Co-authored-by: Emily Johnson <emjohnson@vmware.com>
[#23] Co-authored-by: Emily Johnson <emjohnson@vmware.com>
0ffe53c
to
7ccd223
Compare
pkg/registrar/registrar.go
Outdated
}) | ||
if err != nil { | ||
return fmt.Errorf("controller new: %w", err) | ||
} | ||
|
||
reconciler.AddTracking(&external.ObjectTracker{ |
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.
one implicit detail of using external.ObjectTracker
is that one can actually "pause the watching" by making use of clusterapi's paused
annotation:
// PausedAnnotation is an annotation that can be applied to any Cluster API
// object to prevent a controller from processing a resource.
//
// Controllers working with Cluster API objects must check the existence of this annotation
// on the reconciled object.
PausedAnnotation = "cluster.x-k8s.io/paused"
used as a predicate in
log.Info("Adding watcher on external object", "GroupVersionKind", gvk.String())
err := o.Controller.Watch(
&source.Kind{Type: u},
handler,
predicates.ResourceNotPaused(log),
)
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.
Interesting...
d935c75
to
7f1aa7f
Compare
No description provided.