- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 201 for uids (0.13 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
{F: types.UID("delta"), T: types.UID("foxtrot")}, {F: types.UID("foxtrot"), T: types.UID("golf")}, }, }, { name: "two-chains-from-child", uidToNode: map[types.UID]*node{ types.UID("alpha"): alphaNode(), types.UID("bravo"): bravoNode(), types.UID("charlie"): charlieNode(), types.UID("delta"): deltaNode(), types.UID("foxtrot"): foxtrotNode(), types.UID("golf"): golfNode(),
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
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{} // build the set of nodes to inspect first, then use the normal construction on the subset for i := 0; i < len(uidsToCheck); i++ { uid := uidsToCheck[i]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 17:12:33 UTC 2022 - 9.5K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager.go
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, }) } for _, g := range userNs.GIDMappings { gids = append(gids, &runtimeapi.IDMapping{ HostId: g.HostId,
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/local-locker.go
defer l.mutex.Unlock() if len(args.UID) == 0 { for _, resource := range args.Resources { 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 {
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/local-locker_test.go
} if !ok { t.Fatal("did not get write lock") } rUIDs = append(rUIDs, uid) // RLock twice, different uid uid = mustGetUUID() arg.UID = uid ok, err = l.RLock(ctx, arg) if err != nil { t.Fatal(err) } if !ok { t.Fatal("did not get write lock") } rResources[i] = name rUIDs = append(rUIDs, uid) } // Each Lock has m entries
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 11.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/users/users_linux.go
// and assigns UIDs and GIDs to the users and groups to be created based on a list of provided UIDs and GIDs. // Returns an error if not enough UIDs or GIDs are passed. It does not perform any other validation. func assignUserAndGroupIDs(groups, usersToCreate, groupsToCreate []*entry, uids, gids []int64) error { if len(gids) < len(groupsToCreate) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 25 16:35:10 UTC 2023 - 20.7K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
// TranslatePodUID returns the actual UID of a pod. If the UID belongs to // a mirror pod, returns the UID of its static pod. Otherwise, returns the // original UID. // // 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
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
DriverName string // ClassName is a resource class of the claim ClassName string // ClaimUID is an UID of the resource claim 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]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 4.3K bytes - Viewed (0)