- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 395 for podutil (0.23 sec)
-
pkg/kubelet/cm/containermap/container_map_test.go
} if podUID != tc.podUID { t.Errorf("mismatched pod UID %v, %v", tc.podUID, podUID) } if containerName != tc.containerNames[i] { t.Errorf("mismatched container Name %v, %v", tc.containerNames[i], containerName) } } // Remove all entries from the containerMap, checking proper removal of // each along the way. cm.Visit(func(podUID string, containerName string, containerID string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 02 13:40:55 UTC 2023 - 2.6K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/diff.go
kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm/v1beta4" "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm/validation" "k8s.io/kubernetes/cmd/kubeadm/app/cmd/options" cmdutil "k8s.io/kubernetes/cmd/kubeadm/app/cmd/util" "k8s.io/kubernetes/cmd/kubeadm/app/constants" "k8s.io/kubernetes/cmd/kubeadm/app/phases/controlplane" kubeadmutil "k8s.io/kubernetes/cmd/kubeadm/app/util"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_test.go
name string containerName string podUID string expected TopologyHint }{ { name: "case1", containerName: "nginx", podUID: "0aafa4c4-38e8-11e9-bcb1-a4bf01040474", expected: TopologyHint{}, }, } for _, tc := range tcases { scope := scope{} actual := scope.GetAffinity(tc.podUID, tc.containerName) if !reflect.DeepEqual(actual, tc.expected) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 10 11:44:15 UTC 2021 - 3.3K bytes - Viewed (0) -
cmd/kubeadm/test/util.go
kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants" certtestutil "k8s.io/kubernetes/cmd/kubeadm/app/util/certs" configutil "k8s.io/kubernetes/cmd/kubeadm/app/util/config" "k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil" ) // SetupTempDir is a utility function for kubeadm testing, that creates a temporary directory // NB. it is up to the caller to cleanup the folder at the end of the test with defer os.RemoveAll(tmpdir)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 01 05:59:41 UTC 2022 - 3.8K bytes - Viewed (0) -
cmd/kubeadm/app/phases/copycerts/main_test.go
See the License for the specific language governing permissions and limitations under the License. */ package copycerts import ( "testing" pkiutiltesting "k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil/testing" ) func TestMain(m *testing.M) { // see: https://github.com/kubernetes/kubernetes/issues/104265 setNoUmask() pkiutiltesting.RunWithPrivateKeyFixtureDirectory(m)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 11 05:42:35 UTC 2021 - 850 bytes - Viewed (0) -
security/pkg/k8s/chiron/utils_test.go
} }) } } func createFakeCsr(t *testing.T) []byte { options := pkiutil.CertOptions{ Host: "fake.com", RSAKeySize: 2048, PKCS8Key: false, ECSigAlg: pkiutil.SupportedECSignatureAlgorithms("ECDSA"), } csrPEM, _, err := pkiutil.GenCSR(options) if err != nil { t.Fatalf("Error creating Mock CA client: %v", err) return nil } return csrPEM
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 03:58:11 UTC 2024 - 13K bytes - Viewed (0) -
pkg/kubelet/status/testing/mock_pod_status_provider.go
func (m *MockPodStartupLatencyStateHelper) DeletePodStartupState(podUID types.UID) { m.ctrl.T.Helper() m.ctrl.Call(m, "DeletePodStartupState", podUID) } // DeletePodStartupState indicates an expected call of DeletePodStartupState. func (mr *MockPodStartupLatencyStateHelperMockRecorder) DeletePodStartupState(podUID any) *gomock.Call { mr.mock.ctrl.T.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager.go
return err } for _, podUID := range found { allFound.Insert(string(podUID)) } // Lets remove all the pods "found" that are not known. for _, podUID := range found { if allPods.Has(string(podUID)) { continue } klog.V(5).InfoS("Clean up orphaned pod user namespace possible allocation", "podUID", podUID) m.releaseWithLock(podUID) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/main_test.go
See the License for the specific language governing permissions and limitations under the License. */ package upgrade import ( "testing" pkiutiltesting "k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil/testing" ) func TestMain(m *testing.M) { pkiutiltesting.RunWithPrivateKeyFixtureDirectory(m)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jul 04 08:41:27 UTC 2021 - 770 bytes - Viewed (0) -
src/io/ioutil/example_test.go
// license that can be found in the LICENSE file. package ioutil_test import ( "fmt" "io/ioutil" "log" "os" "path/filepath" "strings" ) func ExampleReadAll() { r := strings.NewReader("Go is a general-purpose language designed with systems programming in mind.") b, err := ioutil.ReadAll(r) if err != nil { log.Fatal(err) } fmt.Printf("%s", b) // Output:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jan 22 23:03:58 UTC 2021 - 2.7K bytes - Viewed (0)