Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 1,468 for removeIf (0.09 sec)

  1. internal/config/lambda/event/targetlist.go

    }
    
    // TargetIDResult returns result of Remove/Send operation, sets err if
    // any for the associated TargetID
    type TargetIDResult struct {
    	// ID where the remove or send were initiated.
    	ID TargetID
    	// Stores any error while removing a target or while sending an event.
    	Err error
    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. cni/pkg/install/install.go

    			if err := os.Remove(in.cniConfigFilepath); err != nil {
    				return fmt.Errorf("failed to remove CNI config file %s: %w", in.cniConfigFilepath, err)
    			}
    		}
    	}
    
    	if len(in.kubeconfigFilepath) > 0 && file.Exists(in.kubeconfigFilepath) {
    		installLog.Infof("removing Istio CNI kubeconfig file: %s", in.kubeconfigFilepath)
    		if err := os.Remove(in.kubeconfigFilepath); err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. internal/event/rulesmap.go

    func (rulesMap RulesMap) Add(rulesMap2 RulesMap) {
    	for eventName, rules := range rulesMap2 {
    		rulesMap[eventName] = rules.Union(rulesMap[eventName])
    	}
    }
    
    // Remove - removes given rules map.
    func (rulesMap RulesMap) Remove(rulesMap2 RulesMap) {
    	for eventName, rules := range rulesMap {
    		if nr := rules.Difference(rulesMap2[eventName]); len(nr) != 0 {
    			rulesMap[eventName] = nr
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  4. cmd/event-notification.go

    		evnot.bucketRulesMap[bucketName] = rulesMap
    	}
    }
    
    // RemoveNotification - removes all notification configuration for bucket name.
    func (evnot *EventNotifier) RemoveNotification(bucketName string) {
    	evnot.Lock()
    	defer evnot.Unlock()
    
    	delete(evnot.bucketRulesMap, bucketName)
    }
    
    // RemoveAllBucketTargets - closes and removes all notification targets.
    func (evnot *EventNotifier) RemoveAllBucketTargets() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
      fun <T : ConnectionEvent> removeUpToEvent(eventClass: Class<T>): T {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/RangeMap.java

      /** Removes all associations from this range map (optional operation). */
      void clear();
    
      /**
       * Removes all associations from this range map in the specified range (optional operation).
       *
       * <p>If {@code !range.contains(k)}, {@link #get(Comparable) get(k)} will return the same result
       * before and after a call to {@code remove(range)}. If {@code range.contains(k)}, then after a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/server.go

    	var errs []error
    
    	// Remove the hostside ipset entry first, and unconditionally - if later failures happen, we never
    	// want to leave stale entries
    	if err := removePodFromHostNSIpset(pod, &s.hostsideProbeIPSet); err != nil {
    		log.Errorf("failed to remove pod %s from host ipset, error was: %v", pod.Name, err)
    		errs = append(errs, err)
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

            } finally {
              unlock();
            }
          }
        }
    
        /**
         * Removes an entry from within a table. All entries following the removed node can stay, but
         * all preceding ones need to be cloned.
         *
         * <p>This method does not decrement count for the removed entry, but does decrement count for
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Request.kt

         */
        open fun addHeader(
          name: String,
          value: String,
        ) = commonAddHeader(name, value)
    
        /** Removes all headers named [name] on this builder. */
        open fun removeHeader(name: String) = commonRemoveHeader(name)
    
        /** Removes all headers on this builder and adds [headers]. */
        open fun headers(headers: Headers) = commonHeaders(headers)
    
        /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:17:44 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/FluentIterable.java

       * Returns a fluent iterable whose {@code Iterator} cycles indefinitely over the elements of this
       * fluent iterable.
       *
       * <p>That iterator supports {@code remove()} if {@code iterable.iterator()} does. After {@code
       * remove()} is called, subsequent cycles omit the removed element, which is no longer in this
       * fluent iterable. The iterator's {@code hasNext()} method returns {@code true} until this fluent
       * iterable is empty.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Sep 24 13:42:31 UTC 2024
    - 35.7K bytes
    - Viewed (0)
Back to top