- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 78 for updateDir (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
toUpdate, err := getFn(ctx, foo) if err != nil { t.Errorf("unexpected error: %v", err) } toUpdate = updateFn(toUpdate) toUpdateMeta := t.getObjectMetaOrFail(toUpdate) updated, created, err := t.storage.(rest.Updater).Update(ctx, toUpdateMeta.GetName(), rest.DefaultUpdatedObjectInfo(toUpdate), rest.ValidateAllObjectFunc, rest.ValidateAllObjectUpdateFunc, false, &metav1.UpdateOptions{}) if err != nil { t.Errorf("unexpected error: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/html/common.js
if (id == 'show-from') param = 'sf'; // We update on mouseenter so middle-click/right-click work properly. elem.addEventListener('mouseenter', updater); elem.addEventListener('touchstart', updater); function updater() { // The selection can be in one of two modes: regexp-based or // list-based. Construct regular expression depending on mode. let re = regexpActive
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 16 15:19:53 UTC 2024 - 20K bytes - Viewed (0) -
pkg/controller/daemon/update.go
} if currDS.Status.CollisionCount == nil { currDS.Status.CollisionCount = new(int32) } *currDS.Status.CollisionCount++ _, updateErr := dsc.kubeClient.AppsV1().DaemonSets(ds.Namespace).UpdateStatus(ctx, currDS, metav1.UpdateOptions{}) if updateErr != nil { return nil, updateErr }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdater.java
import org.gradle.internal.watch.registry.FileWatcherUpdater; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.File; import java.util.Collection; import java.util.List; /** * Updater for hierarchical file watchers. * * For hierarchical watchers, we can use the registered watchable hierarchies as watched directories. * Build root directories are always watchable hierarchies.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world.go
// SetNodeStatusUpdateNeeded sets statusUpdateNeeded for the specified // node to true indicating the AttachedVolume field in the Node's Status // object needs to be updated by the node updater again. // If the specified node does not exist in the nodesToUpdateStatusFor list, // log the error and return SetNodeStatusUpdateNeeded(logger klog.Logger, nodeName types.NodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
// Act // Mark the node unhealthy node2 := node1.DeepCopy() node2.Status.Conditions[0].Status = v1.ConditionFalse updateErr := informerFactory.Core().V1().Nodes().Informer().GetStore().Update(node2) if updateErr != nil { t.Fatalf("Update node failed. Expected: <no error> Actual: <%v>", updateErr) } // Assert -- Detach was not triggered after maxWaitForUnmountDuration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AtomicDouble.java
* long xBits = Double.doubleToRawLongBits(x); * long yBits = Double.doubleToRawLongBits(y); * return xBits == yBits; * } * }</pre> * * <p>It is possible to write a more scalable updater, at the cost of giving up strict atomicity. * See for example <a * href="http://gee.cs.oswego.edu/dl/jsr166/dist/docs/java.base/java/util/concurrent/atomic/DoubleAdder.html"> * DoubleAdder</a>. * * @author Doug Lea
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Feb 28 21:00:54 UTC 2022 - 7.2K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
if needUpdate { // PatchNodeStatus can update both node's status and labels or annotations // Updating status by directly updating node does not work _, _, updateErr := nodeutil.PatchNodeStatus(kubeClient.CoreV1(), types.NodeName(node.Name), originalNode, node) return updateErr } return nil } // Guarantees the map is non-nil if no error is returned.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
istiotest "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" ) func setupTest(t *testing.T) (model.ConfigStoreController, kubernetes.Interface, *xdsfake.Updater) { t.Helper() client := kubeclient.NewFakeClient() endpoints := model.NewEndpointIndex(model.DisabledCache{}) delegate := model.NewEndpointIndexUpdater(endpoints) xdsUpdater := xdsfake.NewWithDelegate(delegate)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
Name: "http-example", Protocol: corev1.ProtocolTCP, // Not added automatically by fake }, }, }, }) log.Infof("Created service %s", n) cl.opts.XDSUpdater.(*xdsfake.Updater).WaitOrFail(t, "service") } func TestController_GetPodLocality(t *testing.T) { pod1 := generatePod("128.0.1.1", "pod1", "nsA", "", "node1", map[string]string{"app": "prod-app"}, map[string]string{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0)