- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for deleteArgs (0.19 sec)
-
tools/istio-iptables/pkg/capture/run.go
case AppendOps: f.iptables.AppendRuleV4(iptableslog.UndefinedCommand, f.chain, f.table, args...) case DeleteOps: deleteArgs := []string{"-t", f.table, opsToString[f.ops], f.chain} deleteArgs = append(deleteArgs, args...) f.ext.RunQuietlyAndIgnore(constants.IPTables, f.iptV, nil, deleteArgs...) } } func (f UDPRuleApplier) RunV6(args ...string) { switch f.ops { case AppendOps:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 03:53:23 UTC 2024 - 35.4K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
ResourceNames: req.Delta.Subscribed.UnsortedList(), } } var res model.Resources var deletedRes model.DeletedResources var logdata model.XdsLogDetails var usedDelta bool var err error switch g := gen.(type) { case model.XdsDeltaResourceGenerator: res, deletedRes, logdata, usedDelta, err = g.GenerateDeltas(con.proxy, req, w) if features.EnableUnsafeDeltaTest {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
AddFunc: func(obj interface{}) { rsc.addRS(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { rsc.updateRS(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { rsc.deleteRS(logger, obj) }, }) rsInformer.Informer().AddIndexers(cache.Indexers{ controllerUIDIndex: func(obj interface{}) ([]string, error) { rs, ok := obj.(*apps.ReplicaSet) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
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)) _, exists, err = manager.expectations.GetExpectations(rsKey) if err != nil { t.Errorf("Failed to get controllee expectations: %v", err) }
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
for item := range toProcess { accessor, err := meta.Accessor(item) if err != nil { errs <- err return } // DeepCopy the deletion options because individual graceful deleters communicate changes via a mutating // function in the delete strategy called in the delete method. While that is always ugly, it works
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
// This volume was dynamically provisioned for this claim. The // claim got bound elsewhere, and thus this volume is not // needed. Delete it. // Mark the volume as Released for external deleters and to let // the user know. Don't overwrite existing Failed status! if volume.Status.Phase != v1.VolumeReleased && volume.Status.Phase != v1.VolumeFailed { // Also, log this only once:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0)