- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for Franke (0.14 sec)
-
cni/pkg/iptables/iptables_test.go
cfg.RedirectDNS = true }, }, } probeSNATipv4 := netip.MustParseAddr("169.254.7.127") probeSNATipv6 := netip.MustParseAddr("e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164") for _, tt := range cases { for _, ipv6 := range []bool{false, true} { t.Run(tt.name+"_"+ipstr(ipv6), func(t *testing.T) { cfg := constructTestConfig() cfg.EnableIPv6 = ipv6 tt.config(cfg) ext := &dep.DependenciesStub{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.7K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
mappedResp := map[string]string{} w := new(tabwriter.Writer).Init(s.Writer, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tCLUSTER\tCDS\tLDS\tEDS\tRDS\tECDS\tISTIOD\tVERSION") for _, dr := range drs { for _, resource := range dr.Resources { clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
podList, err := client.Kube().CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions{}) if err != nil { return nil, err } var podsName []string for _, pod := range podList.Items { if toComplete == "" || strings.HasPrefix(pod.Name, toComplete) { podsName = append(podsName, pod.Name) } } return podsName, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate.go
mgArgs.Force, mgArgs.Filter, kubeClient, l) if err != nil { return err } if len(mgArgs.Components) != 0 { filteredManifests := name.ManifestMap{} for _, cArg := range mgArgs.Components { componentName := name.ComponentName(cArg) if cManifests, ok := manifests[componentName]; ok { filteredManifests[componentName] = cManifests } else {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
if cfg.cfg.EnableIPv6 { iptablesVariant = append(iptablesVariant, cfg.ipt6V) } for _, iptVer := range iptablesVariant { for _, cmd := range deleteCmds { delErrs = append(delErrs, cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...)) } for _, cmd := range optionalDeleteCmds { err := cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...) if err != nil {
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) -
operator/cmd/mesh/profile-list.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 1.9K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
if r := cmp.Compare(a.Namespace, b.Namespace); r != 0 { return r } return cmp.Compare(a.Name, b.Name) }) fmt.Fprintln(w, "NAMESPACE\tPOLICY NAME\tACTION\tSCOPE") for _, pol := range pols { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", pol.Namespace, pol.Name, pol.Action, pol.Scope) } return w.Flush() } // PrintPolicyDump prints the relevant services in the config dump to the ConfigWriter stdout
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
if err != nil { return err } log.Debugf("sending delete pod to ztunnel: %s %v", uid, r) var delErr []error z.conns.mu.Lock() defer z.conns.mu.Unlock() for conn := range z.conns.connectionSet { _, err := conn.send(ctx, data, nil) if err != nil { delErr = append(delErr, err) } } return errors.Join(delErr...) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
// if the namespace in the CR is provided, consider creating it too. if istioNamespace != "" { namespaces = append(namespaces, istioNamespace) } for _, ns := range namespaces { if err := operatorutil.CreateNamespace(kubeClient.Kube(), ns, "", opts.DryRun); err != nil { l.LogAndFatal(err) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
var portPrefs []int if listenPort != 0 { portPrefs = []int{listenPort} } else { portPrefs = []int{remotePort, 0} } var err error for _, localPort := range portPrefs { var fw kube.PortForwarder fw, err = client.NewPortForwarder(podName, namespace, localAddress, localPort, remotePort) if err != nil {
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)