Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for Tiller (0.16 sec)

  1. istioctl/pkg/writer/envoy/configdump/listener.go

    }
    
    func getFilterType(filters []*listener.Filter) string {
    	for _, filter := range filters {
    		if filter.Name == HTTPListener {
    			httpProxy := &hcm.HttpConnectionManager{}
    			// Allow Unmarshal to work even if Envoy and istioctl are different
    			filter.GetTypedConfig().TypeUrl = "type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager"
    			err := filter.GetTypedConfig().UnmarshalTo(httpProxy)
    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)
  2. istioctl/pkg/writer/ztunnel/configdump/workload.go

    	"fmt"
    	"sort"
    	"strings"
    
    	"sigs.k8s.io/yaml"
    )
    
    // WorkloadFilter is used to pass filter information into workload based config writer print functions
    type WorkloadFilter struct {
    	Address   string
    	Node      string
    	Verbose   bool
    	Namespace string
    }
    
    // Verify returns true if the passed workload matches the filter fields
    func (wf *WorkloadFilter) Verify(workload *ZtunnelWorkload) bool {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/net.go

    	// this can happen if the pod was dynamically added to the mesh after it was created.
    	// in that case, try finding the netns using procfs.
    	filter := map[types.UID]*corev1.Pod{
    		pod.UID: pod,
    	}
    	return s.scanProcForPodsAndCache(filter)
    }
    
    func (s *NetServer) getOrOpenNetns(pod *corev1.Pod, netNs string) (Netns, error) {
    	if netNs == "" {
    		return s.getNetns(pod)
    	}
    	return s.openNetns(pod, netNs)
    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)
  4. cni/pkg/repair/netns.go

    func getLinkWithDestinationOf(ip string) (netlink.Link, error) {
    	routes, err := netlink.RouteListFiltered(
    		netlink.FAMILY_V4,
    		&netlink.Route{Dst: &net.IPNet{IP: net.ParseIP(ip), Mask: net.CIDRMask(32, 32)}},
    		netlink.RT_FILTER_DST)
    	if err != nil {
    		return nil, err
    	}
    
    	if len(routes) == 0 {
    		return nil, fmt.Errorf("no routes found for %s", ip)
    	}
    
    	linkIndex := routes[0].LinkIndex
    	return netlink.LinkByIndex(linkIndex)
    }
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Dec 20 22:14:13 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  5. operator/cmd/mesh/manifest_shared_test.go

    		filters := []string{}
    		filters = append(filters, fileSelect...)
    		// Everything needs these
    		filters = append(filters, "templates/_affinity.tpl", "templates/_helpers.tpl", "templates/zzz_profile.yaml")
    		args += " --filter " + strings.Join(filters, ",")
    	}
    	args += " --set installPackagePath=" + string(chartSource)
    	return runCommand(args)
    }
    
    // runCommand runs the given command string.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Feb 20 22:39:28 GMT 2024
    - 11.7K bytes
    - Viewed (1)
  6. istioctl/pkg/writer/ztunnel/configdump/policies.go

    }
    
    // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintPolicySummary(filter PolicyFilter) error {
    	w := c.tabwriter()
    	zDump := c.ztunnelDump
    
    	pols := slices.Filter(maps.Values(zDump.Policies), filter.Verify)
    	slices.SortFunc(pols, func(a, b *ZtunnelPolicy) int {
    		if r := cmp.Compare(a.Namespace, b.Namespace); r != 0 {
    			return r
    		}
    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)
  7. operator/cmd/mesh/manifest-generate.go

    	cmd.PersistentFlags().StringSliceVar(&args.Components, "component", nil, ComponentFlagHelpStr)
    	cmd.PersistentFlags().StringSliceVar(&args.Filter, "filter", nil, "")
    	_ = cmd.PersistentFlags().MarkHidden("filter")
    
    	cmd.PersistentFlags().BoolVar(&args.EnableClusterSpecific, "cluster-specific", false,
    		"If enabled, the current cluster will be checked for cluster-specific setting detection.")
    }
    
    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)
  8. istioctl/pkg/writer/ztunnel/configdump/connections.go

    			return r
    		}
    		return cmp.Compare(a.Info.Namespace, b.Info.Namespace)
    	})
    	for _, wl := range workloads {
    		if filter.Namespace != "" && filter.Namespace != wl.Info.Namespace {
    			continue
    		}
    		name := fmt.Sprintf("%s.%s", wl.Info.Name, wl.Info.Namespace)
    		if filter.Direction != "outbound" {
    			for _, c := range wl.Connections.Inbound {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 15:39:28 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  9. istioctl/pkg/proxyconfig/proxyconfig.go

    	clusterConfigCmd.PersistentFlags().StringVar(&fqdn, "fqdn", "", "Filter clusters by substring of Service FQDN field")
    	clusterConfigCmd.PersistentFlags().StringVar(&direction, "direction", "", "Filter clusters by Direction field")
    	clusterConfigCmd.PersistentFlags().StringVar(&subset, "subset", "", "Filter clusters by substring of Subset field")
    	clusterConfigCmd.PersistentFlags().IntVar(&port, "port", 0, "Filter clusters by Port field")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 16 03:28:36 GMT 2024
    - 48K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/informers.go

    		controllers.WithGenericReconciler(s.reconcile),
    		controllers.WithMaxAttempts(5),
    	)
    	// We only need to handle pods on our node
    	s.pods = kclient.NewFiltered[*corev1.Pod](kubeClient, kclient.Filter{FieldSelector: "spec.nodeName=" + NodeName})
    	s.pods.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) {
    		s.queue.Add(o)
    	}))
    
    	// Namespaces could be anything though, so we watch all of those
    	//
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 9.6K bytes
    - Viewed (0)
Back to top