- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewSourceFile (0.2 sec)
-
pkg/kubelet/config/file_test.go
err = os.WriteFile(fileName, []byte{1, 2, 3}, 0555) if err != nil { t.Fatalf("unable to write test file %#v", err) } ch := make(chan interface{}, 1) lw := newSourceFile(fileName, "localhost", time.Millisecond, ch) err = lw.listConfig() if err == nil { t.Fatalf("expected error, got nil") } expectEmptyChannel(t, ch) } func TestExtractFromEmptyDir(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 2.1K bytes - Viewed (0) -
pkg/kubelet/config/file_linux_test.go
) func TestExtractFromNonExistentFile(t *testing.T) { ch := make(chan interface{}, 1) lw := newSourceFile("/some/fake/file", "localhost", time.Millisecond, ch) err := lw.doWatch() if err == nil { t.Errorf("Expected error") } } func TestUpdateOnNonExistentFile(t *testing.T) { ch := make(chan interface{}) NewSourceFile("random_non_existent_path", "localhost", time.Millisecond, ch) select { case got := <-ch:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 12.3K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
ctx := context.TODO() // define file config source if kubeCfg.StaticPodPath != "" { klog.InfoS("Adding static pod path", "path", kubeCfg.StaticPodPath) config.NewSourceFile(kubeCfg.StaticPodPath, nodeName, kubeCfg.FileCheckFrequency.Duration, cfg.Channel(ctx, kubetypes.FileSource)) } // define url config source if kubeCfg.StaticPodURL != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)