- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GetNetwork (0.13 sec)
-
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) -
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) -
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/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) -
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) -
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) -
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)