-
Notifications
You must be signed in to change notification settings - Fork 39.5k
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
Running node selector predicate on kubelet. #5715
Conversation
cc @dchen1107 |
Feel free to reassign to load balance. |
@@ -94,3 +98,14 @@ func (c *nodes) Update(minion *api.Node) (*api.Node, error) { | |||
err := c.r.Put().Resource(c.resourceName()).Name(minion.Name).Body(minion).Do().Into(result) | |||
return result, err | |||
} | |||
|
|||
func (c *nodes) Watch(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error) { |
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.
Add documentation for public method.
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.
Done.
LGTM mod nit |
Added checking on kubelet if scheduled pods have matching node selector. This is the last step to fix kubernetes#5207.
d374f03
to
34a8a3a
Compare
Comments applied, e2e tests pass. |
Thanks Jerzy. LGTM |
Running node selector predicate on kubelet.
Added checking on kubelet if scheduled pods have matching node selector. This is the last step to fix #5207.