- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 78 for updateDir (0.14 sec)
-
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/AbstractFileWatcherUpdaterTest.groovy
updater.virtualFileSystemContentsChanged(removed, added, newRoot) } return newRoot } } List<File> movedPaths = [] AbstractFileWatcherUpdater.MovedDirectoryHandler movedWatchedDirectoriesSupplier = { SnapshotHierarchy vfsRoot -> movedPaths } def setup() { updater = createUpdater(watcher, watchableHierarchies) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_utils.go
fmt.Sprintf("sequence No: %v->%v", rs.Status.ObservedGeneration, newStatus.ObservedGeneration)) rs.Status = newStatus updatedRS, updateErr = c.UpdateStatus(context.TODO(), rs, metav1.UpdateOptions{}) if updateErr == nil { return updatedRS, nil } // Stop retrying if we exceed statusUpdateRetries - the replicaSet will be requeued with a rate limit. if i >= statusUpdateRetries { break
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:51 UTC 2023 - 7.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/structuredmerge.go
typeConverter TypeConverter objectConverter runtime.ObjectConvertor objectDefaulter runtime.ObjectDefaulter groupVersion schema.GroupVersion hubVersion schema.GroupVersion updater merge.Updater } var _ Manager = &structuredMergeManager{} // NewStructuredMergeManager creates a new Manager that merges apply requests // and update managed fields for other types of requests.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:55:50 UTC 2023 - 7.3K bytes - Viewed (0) -
pkg/volume/util/resize_util.go
} updatedClaim, updateErr := kubeClient.CoreV1().PersistentVolumeClaims(pvc.Namespace). Patch(context.TODO(), pvc.Name, types.StrategicMergePatchType, patchBytes, metav1.PatchOptions{}, "status") if updateErr != nil { return pvc, fmt.Errorf("patchPVCStatus failed to patch PVC %q: %v", pvc.Name, updateErr) } return updatedClaim, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 14.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
t.Cleanup(func() { close(stop) }) } for _, crd := range opts.CRDs { clienttest.MakeCRD(t, c.client, crd) } opts.Client.RunAndWait(c.stop) var fx *xdsfake.Updater if x, ok := xdsUpdater.(*xdsfake.Updater); ok { fx = x } if !opts.SkipRun { go c.Run(c.stop) kubelib.WaitForCacheSync("test", c.stop, c.HasSynced) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
pkg/registry/registrytest/service.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 13:43:36 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair_test.go
err error updateCalled bool updated *api.RangeAllocation updateErr error } func (r *mockRangeRegistry) Get() (*api.RangeAllocation, error) { r.getCalled = true return r.item, r.err } func (r *mockRangeRegistry) CreateOrUpdate(alloc *api.RangeAllocation) error { r.updateCalled = true r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/kubelet/util/cache/object_cache_test.go
deleteChan := make(chan string, 1) return &ObjectCache{ updater: f, cache: expirationcache.NewFakeExpirationStore(stringKeyFunc, deleteChan, ttlPolicy, clock), } } func TestAddAndGet(t *testing.T) { testObj := testObject{ key: "foo", val: "bar", } objectCache := NewFakeObjectCache(func() (interface{}, error) { return nil, fmt.Errorf("Unexpected Error: updater should never be called in this test")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 17 13:19:08 UTC 2021 - 2.6K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair_test.go
err error updateCalled bool updated *api.RangeAllocation updateErr error } func (r *mockRangeRegistry) Get() (*api.RangeAllocation, error) { r.getCalled = true return r.item, r.err } func (r *mockRangeRegistry) CreateOrUpdate(alloc *api.RangeAllocation) error { r.updateCalled = true r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) { clearMetrics()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
prevCfg := proxy.PrevSidecarScope.DestinationRuleByName(updatedDr.Name, updatedDr.Namespace) if prevCfg == nil { log.Debugf("Prev DestinationRule form PrevSidecarScope is missing for %s/%s", updatedDr.Namespace, updatedDr.Name) return nil, nil } dr := prevCfg.Spec.(*networking.DestinationRule) services = append(services, proxy.SidecarScope.ServicesForHostname(host.Name(dr.Host))...) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0)