- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 157 for deleteRS (0.27 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)