- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 163 for NamespacedName (0.18 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/endpointschangetracker.go
if removeSlice { delete(ect.lastChangeTriggerTimes, namespacedName) } else if t := getLastChangeTriggerTime(endpointSlice.Annotations); !t.IsZero() && t.After(ect.trackerStartTime) { ect.lastChangeTriggerTimes[namespacedName] = append(ect.lastChangeTriggerTimes[namespacedName], t) } } return changeNeeded }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0) -
pkg/proxy/config/config_test.go
h.lock.Lock() defer h.lock.Unlock() namespacedName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name} h.state[namespacedName] = service h.sendServices() } func (h *ServiceHandlerMock) OnServiceUpdate(oldService, service *v1.Service) { h.lock.Lock() defer h.lock.Unlock() namespacedName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K 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) -
pkg/kube/util_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:49 UTC 2024 - 10.8K 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)