Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for SetAddresses (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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