- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 116 for UIDs (0.04 sec)
-
pkg/controller/job/tracking_utils.go
logger.V(4).Info("Expecting tracking finalizers removed", "key", jobKey, "podUIDs", deletedKeys) uids := u.getSet(jobKey) if uids == nil { uids = &uidSet{ key: jobKey, set: sets.New[string](), } if err := u.store.Add(uids); err != nil { return err } } uids.Lock() uids.set.Insert(deletedKeys...) uids.Unlock() return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/controller/job/tracking_utils_test.go
for i, err := range errs { if err != nil { t.Errorf("Failed adding first round of UIDs for job %s: %v", tracks[i].job, err) } } for _, track := range tracks { uids := expectations.getSet(track.job) if uids == nil { t.Errorf("Set of UIDs is empty for job %s", track.job) } else if diff := cmp.Diff(track.firstRound, sets.List(uids.set)); diff != "" { t.Errorf("Unexpected keys for job %s (-want,+got):\n%s", track.job, diff)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/controller/garbagecollector/dump_test.go
name string uidToNode map[types.UID]*node uids []types.UID expectNodes []*dotVertex expectEdges []dotEdge }{ { name: "simple", uidToNode: map[types.UID]*node{ types.UID("alpha"): alphaNode(), types.UID("bravo"): bravoNode(), types.UID("charlie"): charlieNode(), }, uids: []types.UID{types.UID("bravo")}, expectNodes: []*dotVertex{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 11.2K bytes - Viewed (0) -
pkg/controller/garbagecollector/dump.go
} func (m *concurrentUIDToNode) ToDOTNodesAndEdgesForObj(uids ...types.UID) ([]*dotVertex, []dotEdge) { m.uidToNodeLock.Lock() defer m.uidToNodeLock.Unlock() return toDOTNodesAndEdgesForObj(m.uidToNode, uids...) } func toDOTNodesAndEdgesForObj(uidToNode map[types.UID]*node, uids ...types.UID) ([]*dotVertex, []dotEdge) { uidsToCheck := append([]types.UID{}, uids...) interestingNodes := map[types.UID]*node{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 17:12:33 UTC 2022 - 9.5K bytes - Viewed (0) -
cmd/local-locker.go
lris, ok := l.lockMap[resource] if !ok { continue } // Collect uids, so we don't mutate while we delete uids := make([]string, 0, len(lris)) for _, lri := range lris { uids = append(uids, lri.UID) } // Delete collected uids: for _, uid := range uids { lris, ok := l.lockMap[resource] if !ok { // Just to be safe, delete uuids.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 10.6K bytes - Viewed (0) -
cmd/kubeadm/app/util/users/users_linux_test.go
groups []*entry usersToCreate []*entry groupsToCreate []*entry uids []int64 gids []int64 expectedUsers []*entry expectedGroups []*entry expectedError bool }{ { name: "not enough UIDs", usersToCreate: []*entry{ {name: "foo"}, {name: "bar"}, }, uids: []int64{100}, expectedError: true, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 01 05:59:41 UTC 2022 - 16.3K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager.go
return nil, err } } else { userNs, err = m.createUserNs(pod) if err != nil { return nil, err } } var uids []*runtimeapi.IDMapping var gids []*runtimeapi.IDMapping for _, u := range userNs.UIDMappings { uids = append(uids, &runtimeapi.IDMapping{ HostId: u.HostId, ContainerId: u.ContainerId, Length: u.Length, }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/types/uid.go
*/ package types // UID is a type that holds unique ID values, including UUIDs. Because we // don't ONLY use UUIDs, this is an alias to string. Being a type captures // intent and helps make sure that UIDs and names do not get conflated.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 11 14:09:48 UTC 2017 - 825 bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
// // All public-facing functions should perform this translation for UIDs // because user may provide a mirror pod UID, which is not recognized by // internal Kubelet functions. TranslatePodUID(uid types.UID) kubetypes.ResolvedPodUID // GetUIDTranslations returns the mappings of static pod UIDs to mirror pod // UIDs and mirror pod UIDs to static pod UIDs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/state/state_checkpoint.go
ClaimUID types.UID // ClaimName is a name of the resource claim ClaimName string // Namespace is a claim namespace Namespace string // PodUIDs is a set of pod UIDs that reference a resource PodUIDs sets.Set[string] // ResourceHandles is a list of opaque resource data for processing by a specific kubelet plugin ResourceHandles []resourcev1alpha2.ResourceHandle
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 4.3K bytes - Viewed (0)