- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for stacked (0.36 sec)
-
cni/pkg/nodeagent/server.go
} probeSet.Flush() return probeSet, nil } 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) }
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) -
cni/pkg/iptables/iptables.go
// via the nodeIP // - kubelet (node-local healthchecks, which we do not capture) // - kube-proxy (fowarded/proxied traffic from LoadBalancer-backed services, potentially with public IPs, which we must capture) func (cfg *IptablesConfigurator) CreateHostRulesForHealthChecks(hostSNATIP, hostSNATIPV6 *netip.Addr) error { // Append our rules here
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
"Possible values for <level>: none, error, warn, info, debug") logCmd.PersistentFlags().StringVar(&stackTraceLevel, "stack-trace-level", stackTraceLevel, "Comma-separated list of stack trace level for scopes in the format of <scope>:<stack-trace-level>[,<scope>:<stack-trace-level>,...]. "+ "Possible values for <stack-trace-level>: none, error, warn, info, debug") logCmd.PersistentFlags().StringVarP(&outputFormat, "output", "o",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
type CNIPluginAddEvent struct { Netns string PodName string PodNamespace string IPs []IPConfig } // IPConfig contains an interface/gateway/address combo defined for a newly-started pod by CNI. // This is "from the horse's mouth" so to speak and will be populated before Kube is informed of the // pod IP. type IPConfig struct { Interface *int Address net.IPNet Gateway net.IP }
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) -
istioctl/pkg/precheck/precheck.go
if len(outputMsgs) == 0 { fmt.Fprintf(cmd.ErrOrStderr(), color.New(color.FgGreen).Sprint("✔")+" No issues found when checking the cluster. Istio is safe to install or upgrade!\n"+ " To get started, check out https://istio.io/latest/docs/setup/getting-started/\n") } else { fmt.Fprintln(cmd.OutOrStdout(), output) } for _, m := range msgs { if m.Type.Level().IsWorseThanOrEqualTo(diag.Warning) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cni/pkg/cmd/root.go
}) 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) } installer := install.NewInstaller(&cfg.InstallConfig, installDaemonReady)
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)