Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 157 for deleteRS (0.27 sec)

  1. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    func TestController_ExternalNameService(t *testing.T) {
    	test.SetForTest(t, &features.EnableExternalNameAlias, false)
    	deleteWg := sync.WaitGroup{}
    	controller, fx := NewFakeControllerWithOptions(t, FakeControllerOptions{
    		ServiceHandler: func(_, _ *model.Service, e model.Event) {
    			if e == model.EventDelete {
    				deleteWg.Done()
    			}
    		},
    	})
    
    	k8sSvcs := []*corev1.Service{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  2. tests/migrate_test.go

    	}
    
    	ids := make([]int64, 0, len(rows))
    	for _, row := range rows {
    		ids = append(ids, row.ID)
    	}
    	lastID := ids[len(ids)-1]
    
    	if err := DB.Where("id IN (?)", ids).Delete(&AutoIncrementStruct{}).Error; err != nil {
    		t.Fatalf("delete auto_increment_struct fail, err: %v", err)
    	}
    
    	newRow := &AutoIncrementStruct{}
    	if err := DB.Create(newRow).Error; err != nil {
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Mon Mar 18 11:24:16 UTC 2024
    - 56.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    		// We only encode those to deliver DELETE watch events, so if
    		// event.Object is not nil it can be used only for watchers for which
    		// selector was satisfied for its previous version and is no longer
    		// satisfied for the current version.
    		// This is rare enough that it doesn't justify making deep-copy of the
    		// object (done by newCachingObject) every time.
    	case watch.Deleted:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  4. cmd/iam.go

    				return fmt.Errorf("inbuilt policy `%s` not allowed to be deleted", policyName)
    			}
    		}
    	}
    
    	err := sys.store.DeletePolicy(ctx, policyName, !notifyPeers)
    	if err != nil {
    		return err
    	}
    
    	if !notifyPeers || sys.HasWatcher() {
    		return nil
    	}
    
    	// Notify all other MinIO peers to delete policy
    	for _, nerr := range globalNotificationSys.DeletePolicy(ctx, policyName) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 71.9K bytes
    - Viewed (0)
  5. subprojects/core-api/src/main/java/org/gradle/api/Project.java

        /**
         * Deletes files and directories.
         * <p>
         * This will not follow symlinks. If you need to follow symlinks too use {@link #delete(Action)}.
         *
         * @param paths Any type of object accepted by {@link org.gradle.api.Project#files(Object...)}
         * @return true if anything got deleted, false otherwise
         */
        boolean delete(Object... paths);
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 30 04:56:22 UTC 2024
    - 74.3K bytes
    - Viewed (0)
  6. pkg/proxy/winkernel/proxier.go

    	// in last iteration
    	proxier.cleanupStaleLoadbalancers()
    }
    
    // deleteExistingLoadBalancer checks whether loadbalancer delete is needed or not.
    // If it is needed, the function will delete the existing loadbalancer and return true, else false.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

        }
    
        @Override
        public ActionFuture<DeleteResponse> delete(final DeleteRequest request) {
            return client.delete(request);
        }
    
        @Override
        public void delete(final DeleteRequest request, final ActionListener<DeleteResponse> listener) {
            client.delete(request, listener);
        }
    
        @Override
        public DeleteRequestBuilder prepareDelete() {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 84.1K bytes
    - Viewed (0)
  8. pkg/controller/disruption/disruption_test.go

    			t.Fatalf("Eviction (PDB update) failed: %v", err)
    		}
    		for _, name := range podNames {
    			if err := dc.coreClient.Tracker().Delete(podsResource, "default", name); err != nil {
    				t.Fatalf("Eviction (pod delete) failed: %v", err)
    			}
    		}
    	}
    
    	// The fake kube client does not update ResourceVersion or check for conflicts.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
  9. pkg/controller/podautoscaler/horizontal.go

    		delete(a.recommendations, key)
    		a.recommendationsLock.Unlock()
    
    		a.scaleUpEventsLock.Lock()
    		delete(a.scaleUpEvents, key)
    		a.scaleUpEventsLock.Unlock()
    
    		a.scaleDownEventsLock.Lock()
    		delete(a.scaleDownEvents, key)
    		a.scaleDownEventsLock.Unlock()
    
    		return true, nil
    	}
    	if err != nil {
    		return false, err
    	}
    
    	return false, a.reconcileAutoscaler(ctx, hpa, key)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/installer.go

    				return nil, nil, err
    			}
    			addParams(route, action.Params)
    			routes = append(routes, route)
    		case "DELETE": // Delete a resource.
    			article := GetArticleForNoun(kind, " ")
    			doc := "delete" + article + kind
    			if isSubresource {
    				doc = "delete " + subresource + " of" + article + kind
    			}
    			deleteReturnType := versionedStatus
    			if deleteReturnsDeletedObject {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 18:15:22 UTC 2024
    - 51.5K bytes
    - Viewed (0)
Back to top