- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for gotAddresses (0.23 sec)
-
pilot/pkg/serviceregistry/kube/conversion_test.go
} gotAddresses := service.Attributes.ClusterExternalAddresses.GetAddressesFor(clusterID) if len(gotAddresses) == 0 { t.Fatalf("no load balancer addresses found") } for i, addr := range addresses { var want string if len(addr.IP) > 0 { want = addr.IP } else { want = addr.Hostname } got := gotAddresses[i] if got != want {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/model/addressmap.go
return len(m.Addresses) } func (m *AddressMap) DeepCopy() *AddressMap { if m == nil { return nil } return &AddressMap{ Addresses: m.GetAddresses(), } } // GetAddresses returns the mapping of clusters to addresses. func (m *AddressMap) GetAddresses() map[cluster.ID][]string { if m == nil { return nil } m.mutex.RLock() defer m.mutex.RUnlock() if m.Addresses == nil { return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 06 14:34:57 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
// or returns an error. func NewKubeletServerCertificateManager(kubeClient clientset.Interface, kubeCfg *kubeletconfig.KubeletConfiguration, nodeName types.NodeName, getAddresses func() []v1.NodeAddress, certDirectory string) (certificate.Manager, error) { var clientsetFn certificate.ClientsetFunc if kubeClient != nil { clientsetFn = func(current *tls.Certificate) (clientset.Interface, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/context.go
for port := range ports { instances := gc.ps.ServiceEndpointsByPort(svc, port, nil) if len(instances) > 0 { foundInternal.Insert(fmt.Sprintf("%s:%d", g, port)) foundInternalIP.InsertAll(svc.GetAddresses(&model.Proxy{Metadata: &model.NodeMetadata{ClusterID: gc.cluster}})...) if svc.Attributes.ClusterExternalAddresses.Len() > 0 { // Fetch external IPs from all clusters
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 18:33:02 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
} } svc := addr.GetService() if svc != nil { if !svcNames.Contains(svc.Name) { continue } for _, saddr := range svc.GetAddresses() { if saddr.GetNetwork() != network { return fmt.Errorf("no network service notify") } } } } return nil }, retry.Timeout(time.Second*5)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
pilot/pkg/model/service.go
return } hostname = host.Name(s) return } // GetAddresses returns a Service's addresses. // This method returns all the VIPs of a service if the ClusterID is explicitly set to "", otherwise only return the VIP // specific to the cluster where the node resides func (s *Service) GetAddresses(node *Proxy) []string { if node.Metadata != nil && node.Metadata.ClusterID == "" {
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/conversion.go
// ServiceEntry can represent multiple - but we are not using that. SE may be merged. // Will be 0.0.0.0 if not specified as ClusterIP or ClusterIP==None. In such case resolution is Passthrough. Addresses: svc.GetAddresses(proxy), // This is based on alpha.istio.io/canonical-serviceaccounts and // alpha.istio.io/kubernetes-serviceaccounts. SubjectAltNames: svc.ServiceAccounts, } if len(svc.Attributes.LabelSelectors) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
if x != nil { return x.Namespace } return "" } func (x *Service) GetHostname() string { if x != nil { return x.Hostname } return "" } func (x *Service) GetAddresses() []*NetworkAddress { if x != nil { return x.Addresses } return nil } func (x *Service) GetPorts() []*Port { if x != nil { return x.Ports } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K bytes - Viewed (0)