- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for convertWorkloadEntryToWorkloadInstance (0.51 sec)
-
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) -
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) -
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)