- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for fakehost (0.2 sec)
-
pkg/kubelet/container/testing/fake_runtime.go
f.CalledFunctions = append(f.CalledFunctions, "GetExec") return &url.URL{Host: FakeHost}, f.Err } func (f *FakeStreamingRuntime) GetAttach(_ context.Context, id kubecontainer.ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error) { f.Lock() defer f.Unlock() f.CalledFunctions = append(f.CalledFunctions, "GetAttach") return &url.URL{Host: FakeHost}, f.Err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 00:23:50 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
"fakeNode", csiDriverLister, volumeAttachmentLister, ) default: t.Fatalf("Unsupported volume host type") } fakeHost, ok := host.(volumetest.FakeVolumeHost) if !ok { t.Fatalf("Unsupported volume host type") } pluginMgr := fakeHost.GetPluginMgr() plug, err := pluginMgr.FindPluginByName(CSIPluginName) if err != nil { t.Fatalf("can't find plugin %v", CSIPluginName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
Name: "fakeDestinationRule", Namespace: "default", Domain: "cluster.local", CreationTimestamp: GlobalTime, }, Spec: &networking.DestinationRule{ Host: "fakehost", }, } _, err := store.Create(cfg) if err != nil { t.Errorf("error occurred crearting ServiceEntry config: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
} return objectGVK, mapping.Resource, nil } type FakeList[T runtime.Object] struct { metav1.TypeMeta metav1.ListMeta Items []T } func (fl *FakeList[P]) DeepCopyObject() runtime.Object { copiedItems := make([]P, len(fl.Items)) for i, item := range fl.Items { copiedItems[i] = item.DeepCopyObject().(P) } return &FakeList[P]{ TypeMeta: fl.TypeMeta, ListMeta: fl.ListMeta,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox_test.go
func TestCreatePodSandbox(t *testing.T) { ctx := context.Background() fakeRuntime, _, m, err := createTestRuntimeManager() require.NoError(t, err) pod := newTestPod() fakeOS := m.osInterface.(*containertest.FakeOS) fakeOS.MkdirAllFn = func(path string, perm os.FileMode) error { // Check pod logs root directory is created. assert.Equal(t, filepath.Join(testPodLogsDirectory, pod.Namespace+"_"+pod.Name+"_12345678"), path)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_test.go
} // Create fake sandbox and container _, fakeContainers := makeAndSetFakePod(t, m, fakeRuntime, pod) assert.Equal(t, len(fakeContainers), 1) containerID := fakeContainers[0].Id fakeOS := m.osInterface.(*containertest.FakeOS) fakeOS.GlobFn = func(pattern, path string) bool { pattern = strings.Replace(pattern, "*", ".*", -1) pattern = strings.Replace(pattern, "\\", "\\\\", -1) return regexp.MustCompile(pattern).MatchString(path)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 28K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_windows_test.go
fakeStats := map[string]*volume.Metrics{ kuberuntime.BuildContainerLogsDirectory(testPodLogDirectory, "sb0-ns", "sb0-name", types.UID("sb0-uid"), "c0"): c0LogStats, } fakeOS := &kubecontainertest.FakeOS{} fakeHostStatsProvider := NewFakeHostStatsProviderWithData(fakeStats, fakeOS) p := &criStatsProvider{ clock: fakeClock, hostStatsProvider: fakeHostStatsProvider, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 17 00:02:10 UTC 2024 - 13.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc_test.go
err = m.containerGC.evictPodLogsDirectories(ctx, true) assert.NoError(t, err) assert.Equal(t, removed, fakeOS.Removes) // allSourcesReady == false, pod log directories should not be removed. fakeOS.Removes = []string{} err = m.containerGC.evictPodLogsDirectories(ctx, false) assert.NoError(t, err) assert.Empty(t, fakeOS.Removes) } func TestUnknownStateContainerGC(t *testing.T) { ctx := context.Background()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20.6K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/certs_test.go
"renew scheduler.conf", "renew controller-manager.conf", } renewCmd := newCmdCertsRenewal(os.Stdout) fakeRoot := &cobra.Command{} fakeRoot.AddCommand(renewCmd) for _, cmdPath := range expectedCommands { t.Run(cmdPath, func(t *testing.T) { cmd, rem, _ := fakeRoot.Find(strings.Split(cmdPath, " ")) if cmd == nil || len(rem) != 0 { t.Fatalf("couldn't locate command %q (%v)", cmdPath, rem) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 13:26:12 UTC 2024 - 20.1K bytes - Viewed (0)