- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for eventChans (0.09 sec)
-
pkg/kubelet/pluginmanager/pluginwatcher/example_handler.go
} func (p *exampleHandler) SendEvent(pluginName string, event examplePluginEvent) { klog.V(2).InfoS("Sending event for plugin", "pluginName", pluginName, "event", event, "channel", p.eventChans[pluginName]) p.eventChans[pluginName] <- event } func (p *exampleHandler) DecreasePluginCount(pluginName string) (old int, ok bool) { p.m.Lock() defer p.m.Unlock() v, ok := p.ExpectedNames[pluginName]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 12:00:49 UTC 2023 - 4.6K bytes - Viewed (0) -
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)