Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for convertWorkloadEntryToWorkloadInstance (0.47 sec)

  1. pilot/pkg/serviceregistry/serviceentry/conversion.go

    // port names) and the namespace - k8s will consume this workload instance when selecting workload entries
    func (s *Controller) convertWorkloadEntryToWorkloadInstance(cfg config.Config, clusterID cluster.ID) *model.WorkloadInstance {
    	we := ConvertWorkloadEntry(cfg)
    	addr := we.GetAddress()
    	dnsServiceEntryOnly := false
    	if strings.HasPrefix(addr, model.UnixAddressPrefix) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/controller.go

    	// This ensures we do not track unhealthy endpoints
    	if features.WorkloadEntryHealthChecks && !isHealthy(curr) {
    		event = model.EventDelete
    	}
    
    	wi := s.convertWorkloadEntryToWorkloadInstance(curr, s.Cluster())
    	if wi != nil && !wi.DNSServiceEntryOnly {
    		// fire off the k8s handlers
    		s.NotifyWorkloadInstanceHandlers(wi, event)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/conversion_test.go

    		t.Run(tt.name, func(t *testing.T) {
    			s := &Controller{networkIDCallback: tt.getNetworkIDCb, meshWatcher: mesh.NewFixedWatcher(mesh.DefaultMeshConfig())}
    			instance := s.convertWorkloadEntryToWorkloadInstance(tt.wle, cluster.ID(clusterID))
    			if err := compare(t, instance, tt.out); err != nil {
    				t.Fatal(err)
    			}
    		})
    	}
    }
    
    func compare[T any](t testing.TB, actual, expected T) error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 39K bytes
    - Viewed (0)
Back to top