- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 402 for getUid (0.49 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/accessors.go
// This accessor provides the methods needed to support matching against webhook // predicates namespace.NamespaceSelectorProvider object.ObjectSelectorProvider // GetUID gets a string that uniquely identifies the webhook. GetUID() string // GetConfigurationName gets the name of the webhook configuration that owns this webhook. GetConfigurationName() string // GetRESTClient gets the webhook client
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 12.4K bytes - Viewed (0) -
src/syscall/exec_linux_test.go
} func TestCloneNEWUSERAndRemap(t *testing.T) { for _, setgroups := range []bool{false, true} { setgroups := setgroups t.Run(fmt.Sprintf("setgroups=%v", setgroups), func(t *testing.T) { uid := os.Getuid() gid := os.Getgid() cmd := whoamiNEWUSER(t, uid, gid, setgroups) out, err := cmd.CombinedOutput() t.Logf("%v: %v", cmd, err) if uid != 0 && setgroups {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 20.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/basic_test.go
} // it should have a UUID createdMetadata, err := meta.Accessor(createdNoxuInstance) if err != nil { t.Fatal(err) } if e, a := createdMetadata.GetUID(), eventMetadata.GetUID(); e != a { t.Errorf("expected equal UID for (expected) %v, and (actual) %v", createdNoxuInstance, watchEvent.Object) } case <-time.After(5 * time.Second):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 11:35:33 UTC 2024 - 33.4K bytes - Viewed (0) -
src/os/removeall_test.go
t.Fatalf("Lstat %q succeeded after RemoveAll (third)", path) } // Chmod is not supported under Windows or wasip1 and test fails as root. if runtime.GOOS != "windows" && runtime.GOOS != "wasip1" && Getuid() != 0 { // Make directory with file and subdirectory and trigger error. if err = MkdirAll(dpath, 0777); err != nil { t.Fatalf("MkdirAll %q: %s", dpath, err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:21:29 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
func hasNonControllerOwner(claim *v1.PersistentVolumeClaim, set *apps.StatefulSet, pod *v1.Pod) bool { for _, ownerRef := range claim.GetOwnerReferences() { if ownerRef.UID == set.GetUID() || ownerRef.UID == pod.GetUID() { if ownerRef.Controller == nil || !*ownerRef.Controller { return true } } } return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/controller/controller_ref_manager.go
controllerRef := metav1.GetControllerOfNoCopy(obj) if controllerRef != nil { if controllerRef.UID != m.Controller.GetUID() { // Owned by someone else. Ignore. return false, nil } if match(obj) { // We already own it and the selector matches. // Return true (successfully claimed) before checking deletion timestamp.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 21.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/update.go
return err } objectMeta.SetGeneration(oldMeta.GetGeneration()) strategy.PrepareForUpdate(ctx, obj, old) // Use the existing UID if none is provided if len(objectMeta.GetUID()) == 0 { objectMeta.SetUID(oldMeta.GetUID()) } // ignore changes to timestamp if oldCreationTime := oldMeta.GetCreationTimestamp(); !oldCreationTime.IsZero() { objectMeta.SetCreationTimestamp(oldMeta.GetCreationTimestamp()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 27 11:48:28 UTC 2022 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/caching_object.go
func() { o.object.SetGenerateName(name) }, ) } func (o *cachingObject) GetUID() types.UID { o.lock.RLock() defer o.lock.RUnlock() return o.object.GetUID() } func (o *cachingObject) SetUID(uid types.UID) { o.conditionalSet( func() bool { return o.object.GetUID() == uid }, func() { o.object.SetUID(uid) }, ) } func (o *cachingObject) GetResourceVersion() string { o.lock.RLock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 18:03:48 UTC 2023 - 12.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DefaultDaemonConnector.java
// Look for 'our' daemon among the busy daemons - a daemon will start in busy state so that nobody else will grab it. for (DaemonInfo daemonInfo : daemonRegistry.getNotIdle()) { if (daemonInfo.getUid().equals(daemon.getUid())) { try { if (!constraint.isSatisfiedBy(daemonInfo.getContext())) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 14.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java
this.scheduledExecutorService = executorFactory.createScheduled("Daemon periodic checks", 1); this.listenerManager = listenerManager; } public String getUid() { return daemonContext.getUid(); } public Address getAddress() { return connectorAddress; } public DaemonContext getDaemonContext() { return daemonContext; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 12.9K bytes - Viewed (0)