Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for InsertAll (0.24 sec)

  1. pkg/config/analysis/analyzers/webhook/webhook.go

    				if ls.Key == label.IoIstioRev.Name {
    					revs.InsertAll(ls.Values...)
    				}
    			}
    		}
    		if webhook.ObjectSelector != nil {
    			if r, f := webhook.ObjectSelector.MatchLabels[label.IoIstioRev.Name]; f {
    				revs.Insert(r)
    			}
    
    			for _, ls := range webhook.ObjectSelector.MatchExpressions {
    				if ls.Key == label.IoIstioRev.Name {
    					revs.InsertAll(ls.Values...)
    				}
    			}
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsUrlFilterService.java

                esUrlFilter.setFilterType(INCLUDE);
                esUrlFilter.setUrl(url);
                urlFilterList.add(esUrlFilter);
                invalidateSet.add(sessionId);
            }
            insertAll(urlFilterList, OpType.INDEX);
            invalidateSet.forEach(s -> includeFilterCache.invalidate(s));
        }
    
        @Override
        public void addExcludeUrlFilter(final String sessionId, final String url) {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  3. pkg/util/sets/set.go

    func New[T comparable](items ...T) Set[T] {
    	s := NewWithLength[T](len(items))
    	return s.InsertAll(items...)
    }
    
    // Insert a single item to this Set.
    func (s Set[T]) Insert(item T) Set[T] {
    	s[item] = struct{}{}
    	return s
    }
    
    // InsertAll adds the items to this Set.
    func (s Set[T]) InsertAll(items ...T) Set[T] {
    	for _, item := range items {
    		s[item] = struct{}{}
    	}
    	return s
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 05:26:03 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. platforms/core-configuration/model-core/src/main/java/org/gradle/api/internal/provider/MapPropertyInternal.java

         * of the property to its current convention value, if set, or an empty map.
         * </p>
         *
         * @param entries a {@link Map} containing the entries to add
         */
        @Incubating
        void insertAll(Map<? extends K, ? extends V> entries);
    
        /**
         * Adds all entries from another {@link Map} to the property value.
         *
         * <p>The given provider will be queried when the value of this property is queried.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 18:32:13 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. pilot/pkg/config/kube/gateway/context.go

    				foundInternalIP.InsertAll(svc.GetAddresses(&model.Proxy{Metadata: &model.NodeMetadata{ClusterID: gc.cluster}})...)
    				if svc.Attributes.ClusterExternalAddresses.Len() > 0 {
    					// Fetch external IPs from all clusters
    					svc.Attributes.ClusterExternalAddresses.ForEach(func(c cluster.ID, externalIPs []string) {
    						foundExternal.InsertAll(externalIPs...)
    					})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 18:33:02 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  6. pkg/util/sets/set_test.go

    			items: []string{"a1"},
    			want:  New("a1", "a2"),
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			if got := tt.s.InsertAll(tt.items...); !reflect.DeepEqual(got, tt.want) {
    				t.Errorf("InsertAll() = %v, want %v", got, tt.want)
    			}
    		})
    	}
    }
    
    func TestInsertContains(t *testing.T) {
    	s := New[string]()
    	assert.Equal(t, s.InsertContains("k1"), false)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 05:26:03 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  7. pilot/pkg/xds/workload.go

    		// TODO(@hzxuzhonghu): calculate removed with aliases in `AddressInformation`
    		aliases := addr.Aliases()
    		removed.DeleteAll(aliases...)
    		n := addr.ResourceName()
    		have.Insert(n)
    		haveAliases.InsertAll(aliases...)
    		switch w.TypeUrl {
    		case v3.WorkloadType:
    			if addr.GetWorkload() != nil {
    				resources = append(resources, &discovery.Resource{
    					Name:     n,
    					Aliases:  aliases,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 14:14:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. pkg/config/analysis/analyzer.go

    	}
    	return result
    }
    
    func combineInputs(analyzers []Analyzer) []config.GroupVersionKind {
    	result := sets.NewWithLength[config.GroupVersionKind](len(analyzers))
    	for _, a := range analyzers {
    		result.InsertAll(a.Metadata().Inputs...)
    	}
    	return result.UnsortedList()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 21:06:13 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  9. pilot/pkg/xds/deltatest.go

    			// Resource is added. Delta doesn't distinguish add vs update, so just put it with changed
    			wantChanged.Insert(v.Name)
    		}
    	}
    
    	gotDeleted := sets.New[string]()
    	if usedDelta {
    		gotDeleted.InsertAll(deleted...)
    	}
    	gotChanged := sets.New[string]()
    	for _, v := range deltaRes {
    		gotChanged.Insert(v.Name)
    	}
    
    	// BUGS
    	extraDeletes := sets.SortedList(gotDeleted.Difference(wantDeleted))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  10. fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsDataService.java

        public void update(final EsAccessResult accessResult) {
            super.insert(accessResult, OpType.INDEX);
        }
    
        @Override
        public void update(final List<EsAccessResult> accessResultList) {
            insertAll(accessResultList, OpType.INDEX);
        }
    
        @Override
        public int getCount(final String sessionId) {
            return getCount(builder -> builder.setQuery(QueryBuilders.termQuery(SESSION_ID, sessionId)));
        }
    
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top