- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for deletePodReference (0.29 sec)
-
pkg/kubelet/cm/dra/claiminfo.go
func (info *ClaimInfo) hasPodReference(podUID types.UID) bool { return info.PodUIDs.Has(string(podUID)) } // deletePodReference deletes a pod reference from the claim info. func (info *ClaimInfo) deletePodReference(podUID types.UID) { info.PodUIDs.Delete(string(podUID)) } // setPrepared marks the claim info as prepared. func (info *ClaimInfo) setPrepared() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/claiminfo_test.go
}, }, }, { description: "empty claim info", claimInfo: &ClaimInfo{}, }, } { t.Run(test.description, func(t *testing.T) { test.claimInfo.deletePodReference(podUID) assert.False(t, test.claimInfo.hasPodReference(podUID)) }) } } func TestClaimInfoSetPrepared(t *testing.T) { for _, test := range []struct { description string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 21K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager.go
// if the checkpoint has succeeded. That means if the kubelet // is ever restarted before this checkpoint succeeds, we will // simply call into this (idempotent) function again. claimInfo.deletePodReference(podUID) return nil } // This claimInfo name will be used to update ClaimInfo cache // after NodeUnprepareResources GRPC succeeds claimNamesMap[claimInfo.ClaimUID] = claimInfo.ClaimName
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0)