Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 163 for NamespacedName (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/kube/util_test.go

    		jobName          string
    		wantTypeMetadata metav1.TypeMeta
    		wantName         types.NamespacedName
    	}{
    		{
    			name:    "cron-job-name-sec",
    			jobName: "sec-1234567890",
    			wantTypeMetadata: metav1.TypeMeta{
    				Kind:       "CronJob",
    				APIVersion: "batch/v1",
    			},
    			wantName: types.NamespacedName{
    				Name: "sec",
    			},
    		},
    		{
    			name:    "cron-job-name-min",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 15 04:16:49 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  10. pilot/pkg/model/destination_rule_test.go

    		},
    		{
    			name: "l is nil",
    			l:    nil,
    			r: &ConsolidatedDestRule{
    				from: []types.NamespacedName{
    					{
    						Namespace: "default",
    						Name:      "dr1",
    					},
    				},
    			},
    			expected: false,
    		},
    		{
    			name: "r is nil",
    			l: &ConsolidatedDestRule{
    				from: []types.NamespacedName{
    					{
    						Namespace: "default",
    						Name:      "dr1",
    					},
    				},
    			},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jul 07 03:52:19 UTC 2022
    - 2.8K bytes
    - Viewed (0)
Back to top