- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newSourceApiserverFromLW (0.36 sec)
-
pkg/kubelet/config/apiserver.go
klog.V(4).InfoS("node sync has not completed yet") } klog.InfoS("Watching apiserver") newSourceApiserverFromLW(lw, updates) }() } // newSourceApiserverFromLW holds creates a config source that watches and pulls from the apiserver. func newSourceApiserverFromLW(lw cache.ListerWatcher, updates chan<- interface{}) { send := func(objs []interface{}) { var pods []*v1.Pod for _, o := range objs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 21 19:46:27 UTC 2021 - 2.4K bytes - Viewed (0) -
pkg/kubelet/config/apiserver_test.go
// Setup fake api client. fakeWatch := watch.NewFake() lw := fakePodLW{ listResp: &v1.PodList{Items: []v1.Pod{*pod1v1}}, watchResp: fakeWatch, } ch := make(chan interface{}) newSourceApiserverFromLW(lw, ch) got, ok := <-ch if !ok { t.Errorf("Unable to read from channel when expected") } update := got.(kubetypes.PodUpdate)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 22 18:31:03 UTC 2017 - 5.6K bytes - Viewed (0)