-
Notifications
You must be signed in to change notification settings - Fork 40k
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
Etcd watcher #535
Etcd watcher #535
Conversation
@@ -303,3 +307,91 @@ func TestPolling(t *testing.T) { | |||
f() | |||
} | |||
} | |||
|
|||
var watchTestTable = []struct { |
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.
Any reason this isn't part of TestWatch? Feels like this is the real test case (which should be prominent in the TestWatch method), and the rest of the code is the boilerplate necessary to make the test.
@smarterclayton, both comments addressed in #505. |
I think my implementation here isn't quite right-- I fixed it in #549. Can just combine with that (and drop this PR) if you want. |
@smarterclayton: Comment addressed (ew -> w). |
LGTM with answers to the two questions |
Ok, LGTM and this is a net new interface so folks on vacation can register their discontent in subsequent pulls |
Feel free to merge this any time... :) |
Added a basic api interface for events
* Support provisioning baremetal cluster with ansible
* Support provisioning baremetal cluster with ansible
Follow sig list to kubernetes/community
…rry-pick-531-to-release-4.6 [release-4.6] Bug 1919069: UPSTREAM: 98103: kubelet: Delete static pod gracefully and fix mirrorPodTerminationMap leak
Building on #505, this implements etcd's watch in a form that I can hook up to the apiserver.