- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for eventChans (0.17 sec)
-
pkg/kubelet/server/stats/volume_stat_calculator_test.go
assert.Nil(t, err) assert.Equal(t, fmt.Sprintf("Warning VolumeConditionAbnormal Volume %s: The target path of the volume doesn't exist", "vol0"), event) } func WatchEvent(eventChan <-chan string) (string, error) { select { case event := <-eventChan: return event, nil case <-time.After(5 * time.Second): return "", ErrorWatchTimeout } } // Fake volume/metrics provider var _ volume.Volume = &fakeVolume{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
eventChan := make(chan struct{}) stopFunc, err := eventBroadcaster.StartEventWatcher(func(obj runtime.Object) { e, _ := obj.(*eventsv1.Event) if e, a := item.eventReason, e.Reason; e != a { t.Errorf("expected %v, got %v", e, a) } close(eventChan) }) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0)