- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for Ambient (0.17 sec)
-
cni/pkg/nodeagent/server.go
} func (s *Server) Start() { log.Info("CNI ambient server starting") s.kubeClient.RunAndWait(s.ctx.Done()) log.Info("CNI ambient server kubeclient started") pods := s.handlers.GetAmbientPods() err := s.dataplane.ConstructInitialSnapshot(pods) if err != nil { log.Warnf("failed to construct initial snapshot: %v", err) } log.Info("CNI ambient server marking ready") s.Ready() s.dataplane.Start(s.ctx)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
istioctl/pkg/util/ambient/util.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package ambient import ( "context" "strings" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/api/label" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 1.7K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
"github.com/spf13/cobra" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/istioctl/pkg/clioptions" "istio.io/istio/istioctl/pkg/completion" "istio.io/istio/istioctl/pkg/multixds" "istio.io/istio/istioctl/pkg/util/ambient" "istio.io/istio/istioctl/pkg/writer/compare" "istio.io/istio/istioctl/pkg/writer/pilot" pilotxds "istio.io/istio/pilot/pkg/xds" "istio.io/istio/pkg/log" ) var configDumpFile string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
istiolog "istio.io/istio/pkg/log" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" dep "istio.io/istio/tools/istio-iptables/pkg/dependencies" ) var log = istiolog.RegisterScope("ambient", "ambient controller") // Adapts CNI to ztunnel server. decoupled from k8s for easier integration testing. type NetServer struct { ztunnelServer ZtunnelServer currentPodSnapshot *podNetnsCache
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/plugin/plugin_test.go
"gateway": "10.0.0.1", "interface": 0 } ], "routes": [] }, "log_level": "debug", "cni_event_address": "%s", "ambient_enabled": %t, "kubernetes": { "k8s_api_root": "APIRoot", "kubeconfig": "testK8sConfig", "intercept_type": "%s", "node_name": "testNodeName", "exclude_namespaces": ["testExcludeNS"],
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/cmd/root.go
EnableIPv6: cfg.InstallConfig.AmbientIPv6, }) if err != nil { return fmt.Errorf("failed to create ambient nodeagent service: %v", err) } ambientAgent.Start() defer ambientAgent.Stop() log.Info("Ambient node agent started, starting installer...") } else { // Ambient not enabled, so this readiness flag is no-op'd watchServerReady.Store(true) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list_test.go
nss := []runtime.Object{ createNamespace("default", nil), createNamespace("kube-system", nil), createNamespace("istio-system", nil), createNamespace("ambient", map[string]string{ constants.DataplaneModeLabel: constants.DataplaneModeAmbient, }), createNamespace("no-ambient", map[string]string{ constants.DataplaneModeLabel: constants.DataplaneModeAmbient, "istio-injection": "enabled", }), }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 2.9K bytes - Viewed (0) -
cni/pkg/util/podutil_test.go
} tests := []struct { name string args args want bool }{ { name: "ambient mode enabled for namespace", args: args{ namespace: namespaceWithAmbientEnabledLabel, pod: unlabelledPod, }, want: true, }, { name: "ambient mode enabled for pod", args: args{ namespace: unlabelledNamespace, pod: podWithAmbientEnabledLabel,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
return nil } } // Begin ambient plugin logic // For ambient pods, this is all the logic we need to run if conf.AmbientEnabled { log.Debugf("istio-cni ambient cmdAdd podName: %s - checking if ambient enabled", podName) podIsAmbient, err := isAmbientPod(kClient, podName, podNamespace) if err != nil { log.Errorf("istio-cni cmdAdd failed to check ambient: %s", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
maxStaleRetries := 10 msInterval := 10 retries := 0 var ambientPod *corev1.Pod var err error log.Debugf("Checking pod: %s in ns: %s is enabled for ambient", addCmd.PodName, addCmd.PodNamespace) // The plugin already consulted the k8s API - but on this end handler caches may be stale, so retry a few times if we get no pod.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0)