- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for NamespacedName (0.19 sec)
-
pkg/proxy/endpointschangetracker_test.go
if len(changes) != 0 { t.Errorf("Expected %s to have no changes", tc.namespacedName) } } else { if _, exists := changes[tc.namespacedName]; !exists { t.Fatalf("Expected %s to have changes", tc.namespacedName) } compareEndpointsMapsStr(t, changes[tc.namespacedName].current, tc.expectedCurrentChange) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 79.9K bytes - Viewed (0) -
tests/integration/security/authz_test.go
Apply() newTrafficTest(t, fromAndTo). FromMatch(fromMatch). ToMatch(toMatch). Run(func(t framework.TestContext, from echo.Instance, to echo.Target) { allow := allowValue(from.NamespacedName() == allowed.NamespacedName()) cases := []struct { ports []echo.Port path string allow allowValue }{ { ports: []echo.Port{ports.GRPC, ports.TCP}, allow: allow,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 23:36:51 UTC 2024 - 50.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/admission_test.go
type fakeCompiler struct { ValidateFuncs map[types.NamespacedName]validating.Validator lock sync.Mutex NumCompiles map[types.NamespacedName]int } func (f *fakeCompiler) getNumCompiles(p *validating.Policy) int { f.lock.Lock() defer f.lock.Unlock() return f.NumCompiles[types.NamespacedName{ Name: p.Name, Namespace: p.Namespace, }] }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 01:39:01 UTC 2024 - 63.8K 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) -
pilot/pkg/model/push_context_test.go
expectedNamespacedFrom: map[string][]types.NamespacedName{ app1DestinationRule.Meta.Name: {app1DestinationRule.NamespacedName(), namespaceDestinationRule.NamespacedName()}, app2DestinationRule.Meta.Name: {app2DestinationRule.NamespacedName(), app3DestinationRule.NamespacedName(), namespaceDestinationRule.NamespacedName()}, namespaceDestinationRule.Meta.Name: {namespaceDestinationRule.NamespacedName()}, }, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
type virtualServiceIndex struct { exportedToNamespaceByGateway map[types.NamespacedName][]config.Config // this contains all the virtual services with exportTo "." and current namespace. The keys are namespace,gateway. privateByNamespaceAndGateway map[types.NamespacedName][]config.Config // This contains all virtual services whose exportTo is "*", keyed by gateway
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_test.go
"goodbye.hello.example.org": exampleNestedWildcardService, } wildcardIndex := map[host.Name]types.NamespacedName{ "*.example.org": virtualServiceWithWildcardHost.NamespacedName(), "*.hello.example.org": virtualServiceWithNestedWildcardHost.NamespacedName(), } vhosts := route.BuildSidecarVirtualHostWrapper(nil, node(cg), cg.PushContext(), serviceRegistry, []config.Config{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 88.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
svcPort := &servicePortInfo{BaseServicePortInfo: bsvcPortInfo} // Store the following for performance reasons. svcName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name} svcPortName := proxy.ServicePortName{NamespacedName: svcName, Port: port.Name} svcPort.nameString = svcPortName.String() chainNameBase := servicePortChainNameBase(&svcPortName, strings.ToLower(string(svcPort.Protocol())))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
virtualServices []config.Config, listenPort int, mostSpecificWildcardVsIndex map[host.Name]types.NamespacedName, ) []VirtualHostWrapper { out := make([]VirtualHostWrapper, 0) // dependentDestinationRules includes all the destinationrules referenced by // the virtualservices, which have consistent hash policy.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
expectEvents(t, events, Event{Type: "eds", ID: "selector.com", Namespace: selector.Namespace, EndpointCount: 2}) key := instancesKey{namespace: selector.Namespace, hostname: "selector.com"} namespacedName := selector.NamespacedName() if len(sd.serviceInstances.ip2instance) != 1 { t.Fatalf("service instances store `ip2instance` memory leak, expect 1, got %d", len(sd.serviceInstances.ip2instance)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0)