Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 81 for NamespacedName (0.17 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/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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top