- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,291 for getUid (0.22 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/skipnonapplied.go
// If the operation is create, P(tracking managed fields) = f.probability // If the operation is update, skip tracking managed fields, since we already know managed fields is empty. if len(accessor.GetUID()) == 0 { if f.probability <= rand.Float32() { return newObj, managed, nil } } else { return newObj, managed, nil } } return f.fieldManager.Update(liveObj, newObj, managed, manager) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 16 20:03:48 UTC 2023 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/request/context_test.go
} expectedName := "bob" if result.GetName() != expectedName { t.Fatalf("Get user name error, Expected: %s, Actual: %s", expectedName, result.GetName()) } expectedUID := "123" if result.GetUID() != expectedUID { t.Fatalf("Get UID error, Expected: %s, Actual: %s", expectedUID, result.GetName()) } expectedGroup := "group1" actualGroup := result.GetGroups() if len(actualGroup) != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.7K 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) -
staging/src/k8s.io/apiserver/pkg/registry/rest/delete.go
if options.Preconditions.UID != nil && *options.Preconditions.UID != objectMeta.GetUID() { return false, false, errors.NewConflict(schema.GroupResource{Group: gvk.Group, Resource: gvk.Kind}, objectMeta.GetName(), fmt.Errorf("the UID in the precondition (%s) does not match the UID in record (%s). The object might have been deleted and then recreated", *options.Preconditions.UID, objectMeta.GetUID())) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 07 17:43:41 UTC 2021 - 9.3K 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/configuration/DefaultDaemonServerConfiguration.java
return idleTimeoutMs; } @Override public int getPeriodicCheckIntervalMs() { return periodicCheckIntervalMs; } @Override public String getUid() { return daemonUid; } @Override public DaemonParameters.Priority getPriority() { return priority; } @Override public List<String> getJvmOptions() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 12:13:32 UTC 2024 - 4K bytes - Viewed (0) -
src/io/ioutil/ioutil_test.go
t.Fatalf("contents = %q\nexpected = %q", string(contents), data) } // cleanup f.Close() os.Remove(filename) // ignore error } func TestReadOnlyWriteFile(t *testing.T) { if os.Getuid() == 0 { t.Skipf("Root can write to read-only files anyway, so skip the read-only test.") } if runtime.GOOS == "wasip1" { t.Skip("file permissions are not supported by wasip1") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:56:32 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/registry/authentication/tokenreview/storage.go
return nil, badAuthenticatorAuds } if resp != nil && resp.User != nil { tokenReview.Status.User = authentication.UserInfo{ Username: resp.User.GetName(), UID: resp.User.GetUID(), Groups: resp.User.GetGroups(), Extra: map[string]authentication.ExtraValue{}, } for k, v := range resp.User.GetExtra() { tokenReview.Status.User.Extra[k] = authentication.ExtraValue(v) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 3.7K 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) -
pkg/fieldpath/fieldpath.go
return FormatMap(accessor.GetLabels()), nil case "metadata.name": return accessor.GetName(), nil case "metadata.namespace": return accessor.GetNamespace(), nil case "metadata.uid": return string(accessor.GetUID()), nil } return "", fmt.Errorf("unsupported fieldPath: %v", fieldPath) } // SplitMaybeSubscriptedPath checks whether the specified fieldPath is // subscripted, and
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 02 06:26:55 UTC 2023 - 3.7K bytes - Viewed (0)