Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for addServiceEntry (0.2 sec)

  1. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go

    	s := newAmbientTestServer(t, testC, testNW)
    
    	// test code path where service entry creates a workload entry via `ServiceEntry.endpoints`
    	// and the inlined WE has a port override
    	s.addServiceEntry(t, "se.istio.io", []string{"240.240.23.45"}, "name1", testNS, nil, []string{"127.0.0.1"})
    	s.assertEvent(t, s.seIPXdsName("name1", "127.0.0.1"), "ns1/se.istio.io")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 03:01:04 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go

    	s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "emptyaddr1")
    }
    
    func TestAmbientIndex_InlinedWorkloadEntries(t *testing.T) {
    	s := newAmbientTestServer(t, testC, testNW)
    
    	s.addServiceEntry(t, "se.istio.io", []string{"240.240.23.45"}, "se1", testNS, map[string]string{"app": "a"}, []string{"127.0.0.1", "127.0.0.2"})
    	s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "se1")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    		},
    	}
    }
    
    func (s *ambientTestServer) deleteWorkloadEntry(t *testing.T, name string) {
    	t.Helper()
    	s.we.Delete(name, "ns1")
    }
    
    func (s *ambientTestServer) addServiceEntry(t *testing.T,
    	hostStr string,
    	addresses []string,
    	name,
    	ns string,
    	labels map[string]string,
    	epAddresses []string,
    ) {
    	t.Helper()
    
    	se := &apiv1alpha3.ServiceEntry{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
Back to top