- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ServiceInstanceToTarget (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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)