Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 60 for setIws (0.32 sec)

  1. pkg/kube/namespace/filter.go

    			if f.namespaceCreatedLocked(ns.ObjectMeta) {
    				f.notifyHandlersLocked(sets.New(ns.Name), nil)
    			}
    		},
    		UpdateFunc: func(old, new *corev1.Namespace) {
    			f.lock.Lock()
    			defer f.lock.Unlock()
    			membershipChanged, namespaceAdded := f.namespaceUpdatedLocked(old.ObjectMeta, new.ObjectMeta)
    			if membershipChanged {
    				added := sets.New(new.Name)
    				var removed sets.String
    				if !namespaceAdded {
    					removed = added
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 17:12:52 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/listenertest/match.go

    		}
    	} else {
    		if missing := sets.SortedList(sets.New(want.NetworkFilters...).Difference(sets.New(haveNetwork...))); len(missing) > 0 {
    			t.Fatalf("%v/%v: missing network filters: %v, have %v", have.Name, haveType, missing, haveNetwork)
    		}
    		if missing := sets.SortedList(sets.New(want.HTTPFilters...).Difference(sets.New(haveHTTP...))); len(missing) > 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  3. pkg/revisions/tag_watcher.go

    	"istio.io/istio/pkg/util/sets"
    )
    
    // TagWatcher keeps track of the current tags and can notify watchers
    // when the tags change.
    type TagWatcher interface {
    	Run(stopCh <-chan struct{})
    	HasSynced() bool
    	AddHandler(handler TagHandler)
    	GetMyTags() sets.String
    }
    
    // TagHandler is a callback for when the tags revision change.
    type TagHandler func(sets.String)
    
    type tagWatcher struct {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. pilot/pkg/model/gateway.go

    	AutoPassthroughSNIHosts         sets.Set[string]
    }
    
    func (g *PrevMergedGateway) HasAutoPassthroughGateway() bool {
    	if g != nil {
    		return g.ContainsAutoPassthroughGateways
    	}
    	return false
    }
    
    func (g *PrevMergedGateway) GetAutoPassthroughSNIHosts() sets.Set[string] {
    	if g != nil {
    		return g.AutoPassthroughSNIHosts
    	}
    	return sets.Set[string]{}
    }
    
    var (
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  5. subprojects/core-api/src/main/java/org/gradle/StartParameter.java

            return excludedTaskNames;
        }
    
        /**
         * Sets the tasks to exclude from this build.
         *
         * @param excludedTaskNames The task names.
         */
        public void setExcludedTaskNames(Iterable<String> excludedTaskNames) {
            this.excludedTaskNames = Sets.newLinkedHashSet(excludedTaskNames);
        }
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 06:24:50 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  6. pilot/pkg/model/envoyfilter.go

    // Returns the keys of all the wrapped envoyfilters.
    func (efw *EnvoyFilterWrapper) Keys() []string {
    	if efw == nil {
    		return nil
    	}
    	keys := sets.String{}
    	for _, patches := range efw.Patches {
    		for _, patch := range patches {
    			keys.Insert(patch.Key())
    		}
    	}
    	return sets.SortedList(keys)
    }
    
    // Returns the keys of all the wrapped envoyfilters.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 13:57:28 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. pilot/pkg/model/destination_rule.go

    	networking "istio.io/api/networking/v1alpha3"
    	"istio.io/istio/pkg/config"
    	"istio.io/istio/pkg/config/host"
    	"istio.io/istio/pkg/config/labels"
    	"istio.io/istio/pkg/config/visibility"
    	"istio.io/istio/pkg/util/sets"
    )
    
    // This function merges one or more destination rules for a given host string
    // into a single destination rule. Note that it does not perform inheritance style merging.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 07:22:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/types.go

    	// It's registered only when the Pod is rejected in PreFilter, Filter, Reserve, PreBind or Permit (WaitOnPermit).
    	UnschedulablePlugins sets.Set[string]
    	// PendingPlugins records the plugin names that the Pod failed with Pending status.
    	PendingPlugins sets.Set[string]
    	// Whether the Pod is scheduling gated (by PreEnqueuePlugins) or not.
    	Gated bool
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  9. pilot/pkg/model/endpointshards.go

    import (
    	"sort"
    	"sync"
    
    	"istio.io/istio/pilot/pkg/features"
    	"istio.io/istio/pilot/pkg/serviceregistry/provider"
    	"istio.io/istio/pkg/cluster"
    	"istio.io/istio/pkg/config/schema/kind"
    	"istio.io/istio/pkg/util/sets"
    )
    
    // shardRegistry is a simplified interface for registries that can produce a shard key
    type shardRegistry interface {
    	Cluster() cluster.ID
    	Provider() provider.ID
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. subprojects/diagnostics/src/main/java/org/gradle/api/tasks/diagnostics/AbstractDependencyReportTask.java

            return configurations;
        }
    
        /**
         * Sets the configurations to generate the report for.
         *
         * @param configurations The configuration. Must not be null.
         */
        public void setConfigurations(Set<Configuration> configurations) {
            this.configurations = configurations;
        }
    
        /**
         * Sets the single configuration (by name) to generate the report for.
         *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 13:33:20 UTC 2024
    - 5.4K bytes
    - Viewed (0)
Back to top