- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for NamespacedName (0.17 sec)
-
pkg/test/framework/components/echo/namespacedname.go
// providing more stable test names. func (n NamespacedName) PrefixString() string { if n.Namespace == nil { return n.Name } return n.Name + "." + n.Namespace.Prefix() } var _ sort.Interface = NamespacedNames{} // NamespacedNames is a list of NamespacedName. type NamespacedNames []NamespacedName func (n NamespacedNames) Less(i, j int) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 23:42:29 UTC 2022 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/types/namespacedname.go
type NamespacedName struct { Namespace string Name string } const ( Separator = '/' ) // String returns the general purpose string representation func (n NamespacedName) String() string { return n.Namespace + string(Separator) + n.Name } // MarshalLog emits a struct containing required key/value pair func (n NamespacedName) MarshalLog() interface{} { return struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 10:47:59 UTC 2023 - 1.6K bytes - Viewed (0) -
pkg/proxy/servicechangetracker.go
svc = previous } metrics.ServiceChangesTotal.Inc() namespacedName := types.NamespacedName{Namespace: svc.Namespace, Name: svc.Name} sct.lock.Lock() defer sct.lock.Unlock() change, exists := sct.items[namespacedName] if !exists { change = &serviceChange{} change.previous = sct.serviceToServiceMap(previous) sct.items[namespacedName] = change } change.current = sct.serviceToServiceMap(current)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/metrics/cache_test.go
c.UpdateEndpointPortCache(types.NamespacedName{Namespace: "ns1", Name: "svc1"}, spCacheInefficient) expectNumEndpointsAndSlices(t, c, 2, 13, 30) c.UpdateEndpointPortCache(types.NamespacedName{Namespace: "ns1", Name: "svc2"}, spCacheEfficient) expectNumEndpointsAndSlices(t, c, 4, 15, 110) c.UpdateEndpointPortCache(types.NamespacedName{Namespace: "ns1", Name: "svc3"}, spCacheInefficient)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/common/deployment/namespace.go
} n.Tproxy = match.ServiceName(echo.NamespacedName{Name: TproxySvc, Namespace: ns}).GetMatches(echos) n.Headless = match.ServiceName(echo.NamespacedName{Name: HeadlessSvc, Namespace: ns}).GetMatches(echos) n.StatefulSet = match.ServiceName(echo.NamespacedName{Name: StatefulSetSvc, Namespace: ns}).GetMatches(echos)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 20 16:01:31 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/proxy/healthcheck/service_health.go
// is the healthcheck-port to listen on. SyncServices(newServices map[types.NamespacedName]uint16) error // Make the new set of endpoints be active. Endpoints for services that do // not exist will be dropped. The value of the map is the number of // endpoints the service has on this node. SyncEndpoints(newEndpoints map[types.NamespacedName]int) error } type proxierHealthChecker interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K bytes - Viewed (0) -
pilot/pkg/model/destination_rule_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 07 03:52:19 UTC 2022 - 2.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/store.go
return s.instancesBySE[key] } func (s *serviceInstancesStore) updateServiceEntryInstances(key types.NamespacedName, instances map[configKey][]*model.ServiceInstance) { s.instancesBySE[key] = instances }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/store_test.go
} store.updateServices(httpDNSRR.NamespacedName(), expectedServices) got := store.getServices(httpDNSRR.NamespacedName()) if !reflect.DeepEqual(got, expectedServices) { t.Errorf("got unexpected services %v", got) } got = store.getAllServices() if !reflect.DeepEqual(got, expectedServices) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 8.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/util.go
func getWorkloadServiceEntries(ses []config.Config, wle *networking.WorkloadEntry) map[types.NamespacedName]*config.Config { out := make(map[types.NamespacedName]*config.Config) for i, cfg := range ses { se := cfg.Spec.(*networking.ServiceEntry) if se.WorkloadSelector != nil && labels.Instance(se.WorkloadSelector.Labels).Match(wle.Labels) { out[cfg.NamespacedName()] = &ses[i] } } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 1.9K bytes - Viewed (0)