- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 113 for fakePod (0.13 sec)
-
cmd/kubeadm/app/preflight/utils_test.go
{"command not found", "", errors.New("kubelet not found"), false}, {"", "", nil, false}, } for _, tc := range cases { t.Run(tc.output, func(t *testing.T) { fcmd := fakeexec.FakeCmd{ OutputScript: []fakeexec.FakeAction{ func() ([]byte, []byte, error) { return []byte(tc.output), nil, tc.err }, }, } fexec := &fakeexec.FakeExec{ CommandScript: []fakeexec.FakeCommandAction{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 23 11:33:44 UTC 2022 - 2.3K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
host = volumetest.NewFakeVolumeHostWithCSINodeName(t, tmpDir, client, ProbeVolumePlugins(), "fakeNode", csiDriverLister, nil, ) case kubeletVolumeHostType: host = volumetest.NewFakeKubeletVolumeHostWithCSINodeName(t, tmpDir, client, ProbeVolumePlugins(), "fakeNode", csiDriverLister, volumeAttachmentLister, ) case attachDetachVolumeHostType:
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/controller/resourceclaim/controller_test.go
className = "my-resource-class" nodeName = "worker" testPod = makePod(testPodName, testNamespace, testPodUID) testPodWithResource = makePod(testPodName, testNamespace, testPodUID, *makePodResourceClaim(podResourceClaimName, templateName)) otherTestPod = makePod(testPodName+"-II", testNamespace, testPodUID+"-II")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
"istio.io/istio/tools/istio-iptables/pkg/constants" ) func TestMatchesFilter(t *testing.T) { makeDetectPod := func(name string, terminationMessage string, exitCode int) *corev1.Pod { return makePod(makePodArgs{ PodName: name, Annotations: map[string]string{"sidecar.istio.io/status": "something"}, InitContainerStatus: &corev1.ContainerStatus{ Name: constants.ValidationContainerName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/scheduler/testing/workload_prep.go
Label(v1.LabelHostname, fmt.Sprintf("node%d", i)).Obj() allNodes = append(allNodes, node) } filteredNodes = allNodes[:filteredNodesNum] // build pods for i := 0; i < existingPodsNum; i++ { podWrapper := MakePod().Name(fmt.Sprintf("pod%d", i)).Node(fmt.Sprintf("node%d", i%allNodesNum)) // apply labels[0], labels[0,1], ..., labels[all] to each pod in turn for _, p := range labelPairs[:i%len(labelPairs)+1] {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 13:43:36 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/fake.go
// FakeEnvironment for testing. type FakeEnvironment struct { Name string NumClusters int IDValue string } func (f FakeEnvironment) ID() resource.ID { return resource.FakeID(f.IDValue) } func (f FakeEnvironment) IsMultiCluster() bool { return false } func (f FakeEnvironment) IsMultiNetwork() bool { return false } func (f FakeEnvironment) EnvironmentName() string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 1.8K 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/proxy/conntrack/conntrack_test.go
return []byte(""), nil, fmt.Errorf("conntrack v1.4.2 (conntrack-tools): 0 flow entries have been deleted") } type testCT struct { execCT fcmd *fakeexec.FakeCmd } func makeCT(result fakeexec.FakeAction) *testCT { fcmd := &fakeexec.FakeCmd{ CombinedOutputScript: []fakeexec.FakeAction{result}, } fexec := &fakeexec.FakeExec{ CommandScript: []fakeexec.FakeCommandAction{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:08:36 UTC 2024 - 6.7K bytes - Viewed (0) -
src/net/http/client_test.go
}{ { desc: "Strip password from error message", in: "http://user:password@dummy.faketld/", out: `Get "http://user:***@dummy.faketld/": dummy impl`, }, { desc: "Don't Strip password from domain name", in: "http://user:password@password.faketld/", out: `Get "http://user:***@password.faketld/": dummy impl`, }, { desc: "Don't Strip password from path",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0)