- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 395 for podutil (0.14 sec)
-
pkg/kubelet/cm/devicemanager/manager.go
defer m.mutex.Unlock() m.pendingAdmissionPod = pod } func (m *ManagerImpl) isContainerAlreadyRunning(podUID, cntName string) bool { cntID, err := m.containerMap.GetContainerID(podUID, cntName) if err != nil { klog.V(4).InfoS("container not found in the initial map, assumed NOT running", "podUID", podUID, "containerName", cntName, "err", err) return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
test/fixedbugs/issue21576.go
package main import ( "bytes" "context" "io/ioutil" "log" "os" "os/exec" "path/filepath" "time" ) const prog = ` package main import _ "os/signal" func main() { c := make(chan int) c <- 1 } ` func main() { dir, err := ioutil.TempDir("", "21576") if err != nil { log.Fatal(err) } defer os.RemoveAll(dir)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 1.3K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/addons.go
"k8s.io/kubernetes/cmd/kubeadm/app/cmd/options" "k8s.io/kubernetes/cmd/kubeadm/app/cmd/phases/workflow" cmdutil "k8s.io/kubernetes/cmd/kubeadm/app/cmd/util" dnsaddon "k8s.io/kubernetes/cmd/kubeadm/app/phases/addons/dns" proxyaddon "k8s.io/kubernetes/cmd/kubeadm/app/phases/addons/proxy" ) var ( coreDNSAddonLongDesc = cmdutil.LongDesc(` Install the CoreDNS addon components via the API server.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota_linux.go
delete(podQuotaMap, poduid) delete(podUidMap, poduid) } else { err = removeProjectID(path, projid) podDirCountMap[poduid]-- klog.V(4).Infof("Not clearing quota for pod %s; still %v dirs outstanding", poduid, podDirCountMap[poduid]) } delete(dirPodMap, path) delete(dirQuotaMap, path) delete(supportsQuotasMap, path) clearApplier(path) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 07 08:07:51 UTC 2023 - 14.1K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/kubeconfig.go
"k8s.io/kubernetes/cmd/kubeadm/app/cmd/options" cmdutil "k8s.io/kubernetes/cmd/kubeadm/app/cmd/util" kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants" kubeconfigphase "k8s.io/kubernetes/cmd/kubeadm/app/phases/kubeconfig" kubeadmutil "k8s.io/kubernetes/cmd/kubeadm/app/util" configutil "k8s.io/kubernetes/cmd/kubeadm/app/util/config" ) var ( kubeconfigLongDesc = cmdutil.LongDesc(` Kubeconfig file utilities. `)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/certs_test.go
t.Log("The command generates key and CSR files in the configured --cert-dir") for _, name := range expectedCertificates { _, err = pkiutil.TryLoadKeyFromDisk(certDir, name) assert.NoErrorf(t, err, "failed to load key file: %s", name) _, err = pkiutil.TryLoadCSRFromDisk(certDir, name) assert.NoError(t, err, "failed to load CSR file: %s", name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 13:26:12 UTC 2024 - 20.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/tls_test.go
baseDir := os.TempDir() tempDir, err := ioutil.TempDir(baseDir, "etcd_certificates") if err != nil { t.Fatal(err) } certFile = path.Join(tempDir, "etcdcert.pem") if err := ioutil.WriteFile(certFile, []byte(testingcert.CertFileContent), 0644); err != nil { t.Fatal(err) } keyFile = path.Join(tempDir, "etcdkey.pem") if err := ioutil.WriteFile(keyFile, []byte(testingcert.KeyFileContent), 0644); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 3.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/staticpods_test.go
configutil "k8s.io/kubernetes/cmd/kubeadm/app/util/config" etcdutil "k8s.io/kubernetes/cmd/kubeadm/app/util/etcd" "k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil" pkiutiltesting "k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil/testing" testutil "k8s.io/kubernetes/cmd/kubeadm/test" ) const ( waitForHashes = "wait-for-hashes" waitForHashChange = "wait-for-hash-change"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 32K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
} func (kvh *kubeletVolumeHost) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string { dir := kvh.kubelet.getPodVolumeDir(podUID, pluginName, volumeName) if runtime.GOOS == "windows" { dir = util.GetWindowsPath(dir) } return dir } func (kvh *kubeletVolumeHost) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
test/fixedbugs/issue26411.go
// definition instead of the label delimiting token ":" package main import ( "bytes" "fmt" "io/ioutil" "log" "os" "os/exec" "path/filepath" "regexp" ) func main() { tmpdir, err := ioutil.TempDir("", "issue26411") if err != nil { log.Fatalf("Failed to create temporary directory: %v", err) } defer os.RemoveAll(tmpdir) tests := []struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 1.9K bytes - Viewed (0)