Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for SetAddresses (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top