- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 69 for index (0.04 sec)
-
pkg/kube/krt/index.go
import ( "sync" "istio.io/istio/pkg/ptr" "istio.io/istio/pkg/util/sets" ) // Index maintains a simple index over an informer type Index[I any, K comparable] struct { mu sync.RWMutex objects map[K]sets.Set[Key[I]] c Collection[I] extract func(o I) []K } // Lookup finds all objects matching a given key func (i *Index[I, K]) Lookup(k K) []I { i.mu.RLock() defer i.mu.RUnlock() var res []I
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 04:53:45 UTC 2024 - 2.8K bytes - Viewed (0) -
samples/bookinfo/src/productpage/templates/index.html
Peter Jausovec <******@****.***> 1716907681 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 14:48:01 UTC 2024 - 1.5K bytes - Viewed (0) -
manifests/charts/istiod-remote/files/gateway-injection-template.yaml
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 01:55:05 UTC 2024 - 8.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/index_test.go
Address: "2.2.2.2", Labels: map[string]string{"app": "wle"}, }, } index := NewIndex() // test update index.Insert(wi1) index.Insert(wi2) index.Insert(wi3) index.Insert(wi4) // test search by service selector actual := FindAllInIndex(index, ByServiceSelector(selector.Namespace, labels.Instance{"app": "wle"})) want := []*model.WorkloadInstance{wi1, wi2}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K bytes - Viewed (0) -
pkg/config/analysis/incluster/controller.go
if err != nil { log.Errorf("In-cluster analysis has failed: %s", err) return } // reorganize messages to map index := map[status.Resource]diag.Messages{} for _, m := range res.Messages { key := status.ResourceFromMetadata(m.Resource.Metadata) index[key] = append(index[key], m) } // if we previously had a message that has been removed, ensure it is removed
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 4.7K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/files/gateway-injection-template.yaml
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 01:55:05 UTC 2024 - 8.7K bytes - Viewed (0) -
operator/pkg/util/path.go
} return "", fmt.Errorf("%s is not a valid value path element", pe) } // PathN returns the index part of the entire value path element. // It returns an error if pe is not an index path element. func PathN(pe string) (int, error) { if !IsNPathElement(pe) { return -1, fmt.Errorf("%s is not a valid index path element", pe) } v, _ := RemoveBrackets(pe) return strconv.Atoi(v) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 12 17:12:54 UTC 2023 - 5.5K bytes - Viewed (0) -
pkg/test/loadbalancersim/timer/queue.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/config/analysis/analyzers/envoyfilter/envoyfilter.go
} if line, ok := util.ErrorLine(r, fmt.Sprintf(util.EnvoyFilterConfigPath, index)); ok { message.Line = line } c.Report(gvk.EnvoyFilter, message) } } func (*EnvoyPatchAnalyzer) analyzeEnvoyFilterPatch(r *resource.Instance, c analysis.Context, patchFilterNames []string) []string { ef := r.Message.(*network.EnvoyFilter) for index, patch := range ef.ConfigPatches {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go
func (a *index) generatePodUID(p *v1.Pod) string { return a.ClusterID.String() + "//" + "Pod/" + p.Namespace + "/" + p.Name } // name format: <cluster>/<group>/<kind>/<namespace>/<name></section-name> // if the WorkloadEntry is inlined in the ServiceEntry, we may need section name. caller should use generateServiceEntryUID
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 22 20:35:23 UTC 2024 - 7.2K bytes - Viewed (0)