- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for post (0.61 sec)
-
istioctl/pkg/multixds/gather.go
return nil, fmt.Errorf("parsing webhook URL: %w", err) } if isMCPAddr(u) { return parseMCPAddr(u) } port := u.Port() if port == "" { port = "443" // default from Kubernetes } return &xdsAddr{host: net.JoinHostPort(u.Hostname(), port)}, nil } } } return nil, errors.New("xds address not found") } // nolint: lll
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
go s.ztunnelServer.Run(ctx) } func (s *NetServer) Stop() { log.Debug("removing host iptables rules") s.iptablesConfigurator.DeleteHostRules() log.Debug("destroying host ipset") s.hostsideProbeIPSet.Flush() if err := s.hostsideProbeIPSet.DestroySet(); err != nil { log.Warnf("could not destroy host ipset on shutdown") } log.Debug("stopping ztunnel server") s.ztunnelServer.Close() }
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) -
istioctl/pkg/writer/envoy/configdump/listener.go
} descrs = append(descrs, fmt.Sprintf("Addr: %s%s", strings.Join(pf, ","), port)) } else if port != "" { descrs = append(descrs, fmt.Sprintf("Addr: *%s", port)) } if len(descrs) == 0 { descrs = []string{"ALL"} } return strings.Join(descrs, "; ") } func getFilterType(filters []*listener.Filter) string { for _, filter := range filters {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_redirect.go
keys := []string{} for _, port := range ports { if !dedup[port] { dedup[port] = true keys = append(keys, port) } } return keys } func parsePort(portStr string) (uint16, error) { port, err := strconv.ParseUint(strings.TrimSpace(portStr), 10, 16) if err != nil { return 0, fmt.Errorf("failed parsing port %q: %v", portStr, err) } return uint16(port), nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// within all pods as we do on the host. // // This should be fine, as the host binaries are all we have to work with here anyway, // as we are running within a privileged container - and we don't want to take the time to // redetect for each pod anyway. // // Extreme corner case: // If for some reason your host had both binaries, and you were injecting out-of-band
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/kubeinject/kubeinject.go
} address = fmt.Sprintf("https://%s:%d%s", e.injectorAddress, *cc.Service.Port, *cc.Service.Path) } else { pod, err := GetFirstPod(e.client.Kube().CoreV1(), namespace, selector.String()) if err != nil { return nil, err } webhookPort := cc.Service.Port podPort := 15017 for _, v := range svc.Spec.Ports { if v.Port == *webhookPort { podPort = v.TargetPort.IntValue() break }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_SERVICE_HOST__", vars.k8sServiceHost) cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_SERVICE_PORT__", vars.k8sServicePort) cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_NODE_NAME__", vars.k8sNodeName) installLog.Infof("CNI config: %s", cniConfigStr)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
kiali.PersistentFlags().IntVar(&kialiPort, "ui-port", defaultKialiPort, "The component dashboard UI port.") dashboardCmd.AddCommand(kiali) prom := promDashCmd(cliContext) prom.PersistentFlags().IntVar(&promPort, "ui-port", defaultPrometheusPort, "The component dashboard UI port.") dashboardCmd.AddCommand(prom) graf := grafanaDashCmd(cliContext)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
operator/cmd/mesh/install.go
return fmt.Errorf("failed to setup verifier: %v", err) } if err := installationVerifier.Verify(); err != nil { return fmt.Errorf("verification failed with the following error: %v", err) } } // Post-install message if profile == "ambient" { p.Println("The ambient profile has been installed successfully, enjoy Istio without sidecars!") } return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
cni/pkg/nodeagent/informers_test.go
}, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), "", ).Return(nil)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0)