- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for NamespacedName (0.56 sec)
-
tests/integration/ambient/main_test.go
echos = match.Not(match.ServiceName(echo.NamespacedName{Name: cdeployment.ExternalSvc, Namespace: apps.ExternalNamespace})).GetMatches(echos) apps.All = echos apps.WorkloadAddressedWaypoint = match.ServiceName(echo.NamespacedName{Name: WorkloadAddressedWaypoint, Namespace: apps.Namespace}).GetMatches(echos)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/model/destination_rule.go
p.exportTo[resolvedHost] = exportToSet } func ConvertConsolidatedDestRule(cfg *config.Config) *ConsolidatedDestRule { return &ConsolidatedDestRule{ rule: cfg, from: []types.NamespacedName{cfg.NamespacedName()}, } } // Equals compare l equals r consolidatedDestRule or not. func (l *ConsolidatedDestRule) Equals(r *ConsolidatedDestRule) bool { if l == r { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 07:22:29 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go
return nil, true } namespacedName := strings.Split(labelValue, "/") switch len(namespacedName) { case 1: return &krt.Named{ Name: namespacedName[0], Namespace: defaultNamespace, }, false case 2: return &krt.Named{ Name: namespacedName[1], Namespace: namespacedName[0], }, false default: // malformed label error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:28 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/test/framework/components/echo/match/matchers_test.go
func (f fakeInstance) Instances() echo.Instances { return echo.Instances{f} } func (f fakeInstance) ID() resource.ID { panic("implement me") } func (f fakeInstance) NamespacedName() echo.NamespacedName { return f.Config().NamespacedName() } func (f fakeInstance) PortForName(name string) echo.Port { return f.Config().Ports.MustForName(name) } func (f fakeInstance) Config() echo.Config {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.2K bytes - Viewed (0) -
tests/integration/ambient/cnirepair/main_test.go
} apps.All = echos apps.Uncaptured = match.ServiceName(echo.NamespacedName{Name: Uncaptured, Namespace: apps.Namespace}).GetMatches(echos) apps.Captured = match.ServiceName(echo.NamespacedName{Name: Captured, Namespace: apps.Namespace}).GetMatches(echos) apps.Sidecar = match.ServiceName(echo.NamespacedName{Name: Sidecar, Namespace: apps.Namespace}).GetMatches(echos) return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Jun 09 09:12:45 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/model/sidecar.go
sc.destinationRulesByNames = make(map[types.NamespacedName]*config.Config) for _, c := range configs { c := c sc.destinationRulesByNames[types.NamespacedName{Name: c.Name, Namespace: c.Namespace}] = &c } } func (sc *SidecarScope) DestinationRuleByName(name, namespace string) *config.Config { if sc == nil { return nil } return sc.destinationRulesByNames[types.NamespacedName{ Name: name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
func PodOnNodeFromDaemonset(node string, name, namespace string, client kube.Client) (types.NamespacedName, error) { ds, err := client.Kube().AppsV1().DaemonSets(namespace).Get(context.Background(), name, metav1.GetOptions{}) if err != nil { return types.NamespacedName{}, err } selector := ds.Spec.Selector if selector == nil { return types.NamespacedName{}, fmt.Errorf("selector is required") } sel := selector.MatchLabels
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
actual := getInterval(tc.input, tc.defaultVal) assert.Equal(t, tc.expected, actual) }) } } func Test_appendApplicableTelemetries(t *testing.T) { namespacedName := types.NamespacedName{ Name: "my-telemetry", Namespace: "my-namespace", } emptyStackDriverTracing := &tpb.Tracing{ Match: &tpb.Tracing_TracingSelector{ Mode: tpb.WorkloadMode_CLIENT, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
for key, watcher := range wm { delete(wm, key) done(watcher) } } type indexedWatchers struct { allWatchers map[namespacedName]watchersMap valueWatchers map[string]watchersMap } func (i *indexedWatchers) addWatcher(w *cacheWatcher, number int, scope namespacedName, value string, supported bool) { if supported { if _, ok := i.valueWatchers[value]; !ok { i.valueWatchers[value] = watchersMap{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
func (f fakeInstance) Instances() echo.Instances { return echo.Instances{f} } func (f fakeInstance) ID() resource.ID { panic("implement me") } func (f fakeInstance) NamespacedName() echo.NamespacedName { return f.Config().NamespacedName() } func (f fakeInstance) PortForName(name string) echo.Port { return f.Config().Ports.MustForName(name) } func (f fakeInstance) Config() echo.Config {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0)