- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 170 for deleteRS (0.31 sec)
-
pkg/controller/replicaset/replica_set_test.go
// as the controller deletes it. podExp, exists, err := manager.expectations.GetExpectations(rsKey) if !exists || err != nil { t.Errorf("No expectations found for ReplicaSet") } informers.Apps().V1().ReplicaSets().Informer().GetIndexer().Delete(rs) manager.deleteRS(logger, rs) manager.syncReplicaSet(ctx, GetKey(rs, t))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
// function in the delete strategy called in the delete method. While that is always ugly, it works // when making a single call. When making multiple calls via delete collection, the mutation applied to // pod/A can change the option ultimately used for pod/B.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
deleter, err := plugin.NewDeleter(logger, spec) if err != nil { // Cannot create deleter return pluginName, false, fmt.Errorf("failed to create deleter for volume %q: %w", volume.Name, err) } opComplete := util.OperationCompleteHook(pluginName, "volume_delete") err = deleter.Delete() opComplete(volumetypes.CompleteFuncParam{Err: &err}) if err != nil { // Deleter failed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
cmd/erasure-object.go
if versioned || suspended { // Bucket is versioned and no version was explicitly // mentioned for deletes, create a delete marker instead. vr.ModTime = UTCNow() vr.Deleted = true // Versioning suspended means that we add a `null` version // delete marker, if not add a new version for this delete // marker. if versioned { vr.VersionID = mustGetUUID() } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
if curPod.DeletionTimestamp != nil { // when a pod is deleted gracefully its deletion timestamp is first modified to reflect a grace period, // and after such time has passed, the kubelet actually deletes it from the store. We receive an update // for modification of the deletion timestamp and expect an ds to create more replicas asap, not wait // until the kubelet actually deletes the pod. dsc.deletePod(logger, curPod) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
} // second delete is immediate, resource is deleted out, wasDeleted, err := t.storage.(rest.GracefulDeleter).Delete(ctx, objectMeta.GetName(), rest.ValidateAllObjectFunc, metav1.NewDeleteOptions(0)) if err != nil { t.Errorf("unexpected error: %v", err) } if !wasDeleted { t.Errorf("unexpected, object %s should have been deleted immediately", objectMeta.GetName()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
cmd/iam-store.go
delete(cache.iamUsersMap, k) } } for k, u := range cache.iamSTSAccountsMap { if u.Credentials.ParentUser == accessKey { delete(cache.iamSTSAccountsMap, k) } } } // 3. Delete any mapped policy cache.iamUserPolicyMap.Delete(accessKey) return nil } if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
// Act dsw.DeletePod(types.UniquePodName(podName), generatedVolumeName, nodeName) volumeExists = dsw.VolumeExists(generatedVolumeName, nodeName) if volumeExists { t.Fatalf( "Deleted pod %q from volume %q/node %q. Volume should also be deleted but it still exists.", podName, generatedVolumeName, nodeName) } asw.SetVolumesMountedByNode(logger, []v1.UniqueVolumeName{generatedVolumeName}, nodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
total1 := 0 // Validate that empty namespace is deleted when all filters in that namespace are deleted. for ns, envoyFilters := range pc1.envoyFiltersByNamespace { total1 += len(envoyFilters) deleted := 0 for _, ef := range envoyFilters { key := ConfigKey{Kind: kind.EnvoyFilter, Namespace: ns, Name: ef.Name} if deletes.Contains(key) { deleted++ } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_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: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0)