Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetNetwork (0.13 sec)

  1. pkg/kubelet/kuberuntime/util/util.go

    		return true, sandboxStatus.Metadata.Attempt + 1, sandboxStatus.Id
    	}
    
    	// Needs to create a new sandbox when network namespace changed.
    	if sandboxStatus.GetLinux().GetNamespaces().GetOptions().GetNetwork() != NetworkNamespaceForPod(pod) {
    		klog.V(2).InfoS("Sandbox for pod has changed. Need to start a new one", "pod", klog.KObj(pod))
    		return true, sandboxStatus.Metadata.Attempt + 1, ""
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:14:48 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go

    		if waypointAddress == nil {
    			return nil
    		}
    
    		ip := waypointAddress.GetAddress()
    		netip, _ := netip.AddrFromSlice(ip)
    		netaddr := networkAddress{
    			network: waypointAddress.GetNetwork(),
    			ip:      netip.String(),
    		}
    		return append(make([]networkAddress, 1), netaddr)
    	})
    	WorkloadServices.RegisterBatch(krt.BatchedEventFilter(
    		func(a model.ServiceInfo) *workloadapi.Service {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 19 17:19:41 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  3. 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)
  4. pilot/pkg/config/kube/gateway/deploymentcontroller.go

    	network := d.injectConfig().Values.Struct().GetGlobal().GetNetwork()
    	if _, ok := gw.GetLabels()[label.TopologyNetwork.Name]; !ok && network != "" && isWaypointGateway {
    		input.InfrastructureLabels[label.TopologyNetwork.Name] = d.injectConfig().Values.Struct().GetGlobal().GetNetwork()
    	}
    }
    
    func extractInfrastructureLabels(gw gateway.Gateway) map[string]string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 21:43:20 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  5. pkg/kube/inject/inject.go

    	// TODO allow overriding the values.global network in injection with the system namespace label
    	network := params.valuesConfig.asStruct.GetGlobal().GetNetwork()
    	// params may be set from webhook URL, take priority over values yaml
    	if params.proxyEnvs["ISTIO_META_CLUSTER_ID"] != "" {
    		cluster = params.proxyEnvs["ISTIO_META_CLUSTER_ID"]
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  6. pkg/workloadapi/workload.pb.go

    	if x != nil {
    		return x.Addresses
    	}
    	return nil
    }
    
    func (x *Workload) GetHostname() string {
    	if x != nil {
    		return x.Hostname
    	}
    	return ""
    }
    
    func (x *Workload) GetNetwork() string {
    	if x != nil {
    		return x.Network
    	}
    	return ""
    }
    
    func (x *Workload) GetTunnelProtocol() TunnelProtocol {
    	if x != nil {
    		return x.TunnelProtocol
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:35 UTC 2024
    - 65.9K bytes
    - Viewed (0)
  7. operator/pkg/apis/istio/v1alpha1/values_types.pb.go

    	}
    	return nil
    }
    
    func (x *GlobalConfig) GetMultiCluster() *MultiClusterConfig {
    	if x != nil {
    		return x.MultiCluster
    	}
    	return nil
    }
    
    func (x *GlobalConfig) GetNetwork() string {
    	if x != nil {
    		return x.Network
    	}
    	return ""
    }
    
    func (x *GlobalConfig) GetPodDNSSearchNamespaces() []string {
    	if x != nil {
    		return x.PodDNSSearchNamespaces
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 01:55:05 UTC 2024
    - 329.6K bytes
    - Viewed (0)
Back to top