Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ServiceInstanceToTarget (0.2 sec)

  1. tests/fuzz/pilot_model_fuzzer.go

    	env := &model.Environment{}
    	store := model.NewFakeStore()
    
    	env.ConfigStore = store
    	sd := memory.NewServiceDiscovery(services...)
    	sd.WantGetProxyServiceTargets = slices.Map(serviceInstances, model.ServiceInstanceToTarget)
    	env.ServiceDiscovery = sd
    
    	env.Watcher = mesh.NewFixedWatcher(m)
    	env.EndpointIndex = model.NewEndpointIndex(model.DisabledCache{})
    	env.Init()
    	pc := model.NewPushContext()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 08 18:13:06 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/memory/discovery.go

    	}
    	out := make([]model.ServiceTarget, 0)
    	for _, ip := range node.IPAddresses {
    		si, found := sd.ip2instance[ip]
    		if found {
    			out = append(out, slices.Map(si, model.ServiceInstanceToTarget)...)
    		}
    	}
    	return out
    }
    
    func (sd *ServiceDiscovery) GetProxyWorkloadLabels(proxy *model.Proxy) labels.Instance {
    	sd.mutex.Lock()
    	defer sd.mutex.Unlock()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 23:10:01 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/controller.go

    			// control.
    			if node.Metadata.Namespace == "" || i.Service.Attributes.Namespace == node.Metadata.Namespace {
    				out = append(out, model.ServiceInstanceToTarget(i))
    			}
    		}
    	}
    	return out
    }
    
    func (s *Controller) GetProxyWorkloadLabels(proxy *model.Proxy) labels.Instance {
    	s.mutex.RLock()
    	defer s.mutex.RUnlock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/controller.go

    					targetPort.num = servicePort.Port
    				}
    
    				instance := serviceInstanceFromWorkloadInstance(service, servicePort, targetPort, si)
    				if instance != nil {
    					out = append(out, model.ServiceInstanceToTarget(instance))
    				}
    			}
    		}
    	}
    	return out
    }
    
    // WorkloadInstanceHandler defines the handler for service instances generated by other registries
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  5. pilot/pkg/model/service.go

    	ServiceInstancePort struct {
    		ServicePort
    		TargetPort uint32
    	}
    )
    
    func ServiceInstanceToTarget(e *ServiceInstance) ServiceTarget {
    	return ServiceTarget{
    		Service: e.Service,
    		Port: ServiceInstancePort{
    			ServicePort: e.ServicePort,
    			TargetPort:  e.Endpoint.EndpointPort,
    		},
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    			}
    		})
    	}
    }
    
    func expectProxyInstances(t testing.TB, sd *Controller, expected []*model.ServiceInstance, ip string) {
    	t.Helper()
    	expectProxyTargets(t, sd, slices.Map(expected, model.ServiceInstanceToTarget), ip)
    }
    
    func expectProxyTargets(t testing.TB, sd *Controller, expected []model.ServiceTarget, ip string) {
    	t.Helper()
    	// The system is eventually consistent, so add some retries
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
Back to top