- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 76 for deleteRS (0.23 sec)
-
cmd/peer-rest-server.go
globalEventNotifier.RemoveNotification(bucketName) globalBucketConnStats.delete(bucketName) globalBucketHTTPStats.delete(bucketName) if localMetacacheMgr != nil { localMetacacheMgr.deleteBucketCache(bucketName) } return } // GetAllBucketStatsHandler - fetches bucket replication stats for all buckets from this peer.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 52.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
// have it in our informer cache yet. Let's try to delete, just to be // on the safe side. logger := klog.FromContext(ctx) err = pl.clientset.ResourceV1alpha2().PodSchedulingContexts(pod.Namespace).Delete(ctx, pod.Name, metav1.DeleteOptions{}) switch { case apierrors.IsNotFound(err): logger.V(5).Info("no PodSchedulingContext object to delete") case err != nil: logger.Error(err, "delete PodSchedulingContext") default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
staging/src/k8s.io/api/apps/v1/types.go
// deleted or scaled down. type PersistentVolumeClaimRetentionPolicyType string const ( // RetainPersistentVolumeClaimRetentionPolicyType is the default // PersistentVolumeClaimRetentionPolicy and specifies that // PersistentVolumeClaims associated with StatefulSet VolumeClaimTemplates // will not be deleted.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 49.1K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return objInfo, InsufficientWriteQuorum{} } return objInfo, err } // Delete marker already present we are not going to create new delete markers. if pinfo.ObjInfo.DeleteMarker && opts.VersionID == "" { pinfo.ObjInfo.Name = decodeDirObject(object) return pinfo.ObjInfo, nil } // Delete concurrently in all server pools with read quorum error for unversioned objects.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
name string batchPeriod time.Duration podsCount int deletes []podDelete finalDelay time.Duration wantRequestCount int }{ { name: "three deletes with no batching", batchPeriod: 0 * time.Second, podsCount: 10, deletes: []podDelete{ { // endpoints.Run needs ~100 ms to start processing updates.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
cmd/batch-handlers.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
} expectServiceEndpoints(t, fx, expectedSvc, 80, instances) _ = kube.CoreV1().Pods(pod.Namespace).Delete(context.TODO(), pod.Name, metav1.DeleteOptions{}) _ = kube.DiscoveryV1().EndpointSlices(pod.Namespace).Delete(context.TODO(), "service", metav1.DeleteOptions{}) _ = store.Delete(gvk.WorkloadEntry, workloadEntry.Name, workloadEntry.Namespace, nil) expectServiceEndpoints(t, fx, expectedSvc, 80, []EndpointResponse{})
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
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) -
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)