- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 40 for fakePods (0.19 sec)
-
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/stats/host_stats_provider_test.go
rootFsInfo: nil, want: nil, wantErr: false, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { h := hostStatsProvider{ osInterface: &kubecontainertest.FakeOS{}, podEtcHostsPathFunc: tt.podEtcHostsPathFunc, } got, err := h.getPodEtcHostsStats(tt.podUID, tt.rootFsInfo) if (err != nil) != tt.wantErr {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 10 11:26:59 UTC 2022 - 1.9K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
Name: test.driver, }, Spec: *test.driverSpec, } objs = append(objs, driverInfo) } objs = append(objs, &api.Node{ ObjectMeta: meta.ObjectMeta{ Name: "fakeNode", }, Spec: api.NodeSpec{}, }) client := fakeclient.NewSimpleClientset(objs...) factory := informers.NewSharedInformerFactory(client, time.Hour /* disable resync */)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
cni/pkg/plugin/plugin_dryrun_test.go
} } func buildFakeDryRunPod() *corev1.Pod { app := corev1.Container{Name: "test"} proxy := corev1.Container{Name: "istio-proxy"} validate := corev1.Container{Name: "istio-validate"} fakePod := &corev1.Pod{ TypeMeta: metav1.TypeMeta{ APIVersion: "core/v1", Kind: "Pod", }, ObjectMeta: metav1.ObjectMeta{ Name: testPodName, Namespace: testNSName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/kubelet/stats/host_stats_provider_fake.go
} // NewFakeHostStatsProvider provides a way to test with fake host statistics func NewFakeHostStatsProvider() HostStatsProvider { return &fakeHostStatsProvider{ osInterface: &kubecontainertest.FakeOS{}, } } // NewFakeHostStatsProviderWithData provides a way to test with fake host statistics
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:57:17 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
} ctrl := gomock.NewController(t) defer ctrl.Finish() fakeOS := &kubecontainertest.FakeOS{} fakeOS.ReadDirFn = func(path string) ([]os.DirEntry, error) { var dirEntries []os.DirEntry mockDE := kubecontainertest.NewMockDirEntry(ctrl) switch path {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
// stop1 should be killed early, as part of test if !stopped1 { close(stop1) } }() defer close(stop2) go c1.Run(stop1) go c2.Run(stop2) go store.Run(stop2) n := fakeNode("reg1", "zone1", "subzone1") var p1conn1, p1conn2 *fakeConn p := fakeProxy("1.2.3.4", wgA, "nw1", "sa-a") p.Locality = n.Locality var p2conn1 *fakeConn p2 := fakeProxy("1.2.3.4", wgA, "nw2", "sa-a")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
tensorflow/c/kernels_test.cc
std::unique_ptr<OpKernel> GetFakeKernelWithAttr(const char* op_name, AttrValue v, Status* status) { NodeDef def; def.set_op(op_name); def.set_name("FakeNode"); def.set_device("FakeDevice"); (*def.mutable_attr())["Attr"] = v; return CreateOpKernel(DeviceType("FakeDevice"), nullptr, nullptr, def, 1, status); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 50.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
ambientEnabled, "mock", ) } func buildFakePodAndNSForClient() (*corev1.Pod, *corev1.Namespace) { proxy := corev1.Container{Name: "mockContainer"} app := corev1.Container{Name: "foo-init"} fakePod := &corev1.Pod{ TypeMeta: metav1.TypeMeta{ APIVersion: "core/v1", Kind: "Pod", }, ObjectMeta: metav1.ObjectMeta{ Name: testPodName, Namespace: testNSName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 17.5K bytes - Viewed (0)