- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 253 for podAdd (0.14 sec)
-
pkg/volume/git_repo/git_repo.go
volName: spec.Name(), podUID: pod.UID, plugin: plugin, }, pod: *pod, source: spec.Volume.GitRepo.Repository, revision: spec.Volume.GitRepo.Revision, target: spec.Volume.GitRepo.Directory, exec: exec.New(), opts: opts, }, nil } func (plugin *gitRepoPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 8.2K bytes - Viewed (0) -
src/internal/chacha8rand/chacha8_amd64.s
REPLREG(SI, X1) REPLREG(R8, X2) REPLREG(R9, X3) REPLREG(R10, X12) REPLREG(R11, X13) REPLREG(R12, X14) REPLREG(R13, X15) PADDD X0, X4 PADDD X1, X5 PADDD X2, X6 PADDD X3, X7 PADDD X12, X8 PADDD X13, X9 PADDD X14, X10 PADDD X15, X11 MOVOU X4, (4*16)(BX) MOVOU X5, (5*16)(BX) MOVOU X6, (6*16)(BX) MOVOU X7, (7*16)(BX) MOVOU X8, (8*16)(BX) MOVOU X9, (9*16)(BX)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox.go
} if state != nil { filter.State = &runtimeapi.PodSandboxStateValue{ State: *state, } } sandboxes, err := m.runtimeService.ListPodSandbox(ctx, filter) if err != nil { klog.ErrorS(err, "Failed to list sandboxes for pod", "podUID", podUID) return nil, err } if len(sandboxes) == 0 { return nil, nil } // Sort with newest first.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider.go
} return managed } // getCadvisorPodInfoFromPodUID returns a pod cgroup information by matching the podUID with its CgroupName identifier base name func getCadvisorPodInfoFromPodUID(podUID types.UID, infos map[string]cadvisorapiv2.ContainerInfo) *cadvisorapiv2.ContainerInfo { if info, found := infos[cm.GetPodCgroupNameSuffix(podUID)]; found { return &info } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 16 13:34:22 UTC 2023 - 18.9K bytes - Viewed (0) -
pkg/volume/secret/secret.go
}, nil } func (plugin *secretPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &secretVolumeUnmounter{ &secretVolume{ volName, podUID, plugin, plugin.host.GetMounter(plugin.GetPluginName()), volume.NewCachedMetrics(volume.NewMetricsDu(getPath(podUID, volName, plugin.host))), }, }, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc.go
sandboxInfo.active = true } sandboxesByPod[podUID] = append(sandboxesByPod[podUID], sandboxInfo) } for podUID, sandboxes := range sandboxesByPod { if cgc.podStateProvider.ShouldPodContentBeRemoved(podUID) || (evictNonDeletedPods && cgc.podStateProvider.ShouldPodRuntimeBeRemoved(podUID)) { // Remove all evictable sandboxes if the pod has been removed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/kubelet/server/auth_test.go
// Path -> ExpectedSubresource testPaths := map[string]string{ "/attach/{podNamespace}/{podID}/{containerName}": "proxy", "/attach/{podNamespace}/{podID}/{uid}/{containerName}": "proxy", "/checkpoint/{podNamespace}/{podID}/{containerName}": "checkpoint", "/configz": "proxy", "/containerLogs/{podNamespace}/{podID}/{containerName}": "proxy", "/debug/flags/v": "proxy",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 18:09:38 UTC 2024 - 5K bytes - Viewed (0) -
pkg/kubelet/cm/dra/claiminfo_test.go
expectedLen: 2, }, } { t.Run(test.description, func(t *testing.T) { test.claimInfo.addPodReference(podUID) assert.True(t, test.claimInfo.hasPodReference(podUID)) assert.Len(t, test.claimInfo.PodUIDs, test.expectedLen) }) } } func TestClaimInfoHasPodReference(t *testing.T) { podUID := types.UID("pod-uid") for _, test := range []struct { description string claimInfo *ClaimInfo
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 21K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
func (p *csiPlugin) NewUnmounter(specName string, podUID types.UID) (volume.Unmounter, error) { klog.V(4).Infof(log("setting up unmounter for [name=%v, podUID=%v]", specName, podUID)) kvh, ok := p.host.(volume.KubeletVolumeHost) if !ok { return nil, errors.New(log("cast from VolumeHost to KubeletVolumeHost failed")) } unmounter := &csiMountMgr{ plugin: p, podUID: podUID, specVolumeID: specName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/kubelet/cm/dra/claiminfo.go
} // addPodReference adds a pod reference to the claim info. func (info *ClaimInfo) addPodReference(podUID types.UID) { info.PodUIDs.Insert(string(podUID)) } // hasPodReference checks if a pod reference exists in the claim info. func (info *ClaimInfo) hasPodReference(podUID types.UID) bool { return info.PodUIDs.Has(string(podUID)) } // deletePodReference deletes a pod reference from the claim info.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 7.9K bytes - Viewed (0)