Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for addEndpoint (0.57 sec)

  1. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    	}
    
    	// standard ordering
    	addService("svc")
    	addPod("pod1", "172.0.1.1")
    	addEndpoint("svc", []string{"172.0.1.1"}, []string{"pod1"})
    	assertEndpointsEvent([]string{"172.0.1.1"}, []string{"pod1"})
    	fx.Clear()
    
    	// Create the endpoint, then later add the pod. Should eventually get an update for the endpoint
    	addEndpoint("svc", []string{"172.0.1.1", "172.0.1.2"}, []string{"pod1", "pod2"})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  2. pkg/proxy/endpointschangetracker_test.go

    		expected map[types.NamespacedName][]time.Time
    	}{
    		{
    			name: "Single addEndpoints",
    			scenario: func(fp *FakeProxier) {
    				e := createEndpoints("ns", "ep1", t0)
    				fp.addEndpointSlice(e)
    			},
    			expected: map[types.NamespacedName][]time.Time{createName("ns", "ep1"): {t0}},
    		},
    		{
    			name: "addEndpoints then updatedEndpoints",
    			scenario: func(fp *FakeProxier) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 79.9K bytes
    - Viewed (0)
Back to top