Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 98 for Append (0.18 sec)

  1. cni/pkg/iptables/iptables.go

    	}
    
    	var delErrs []error
    
    	iptablesVariant := []dep.IptablesVersion{}
    	iptablesVariant = append(iptablesVariant, cfg.iptV)
    
    	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...))
    		}
    
    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)
  2. istioctl/pkg/completion/completion.go

    	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
    }
    
    func ValidPodsNameArgs(ctx cli.Context) func(_ *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) {
    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)
  3. istioctl/pkg/util/configdump/util.go

    }
    
    func (w *Wrapper) getSections(sectionTypeURL configTypeURL) ([]*anypb.Any, error) {
    	var dumpAny []*anypb.Any
    	for _, conf := range w.Configs {
    		if conf.TypeUrl == string(sectionTypeURL) {
    			dumpAny = append(dumpAny, conf)
    		}
    	}
    	if dumpAny == nil {
    		return nil, fmt.Errorf("config dump has no configuration type %s", sectionTypeURL)
    	}
    
    	return dumpAny, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Dec 24 08:16:26 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  4. operator/cmd/mesh/install.go

    			}
    			if enabled {
    				enabledComponents = append(enabledComponents, name.UserFacingComponentName(c))
    			}
    		}
    		for _, c := range iop.Spec.Components.IngressGateways {
    			if c.Enabled.GetValue() {
    				enabledComponents = append(enabledComponents, name.UserFacingComponentName(name.IngressComponentName))
    				break
    			}
    		}
    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)
  5. istioctl/pkg/writer/envoy/configdump/ecds.go

    		c := &core.TypedExtensionConfig{}
    		err := config.GetEcdsFilter().UnmarshalTo(c)
    		if err != nil {
    			return nil, fmt.Errorf("failed to retrieve TypedExtensionConfig: %v", err)
    		}
    
    		ecds = append(ecds, c)
    	}
    
    	sort.Slice(ecds, func(i, j int) bool {
    		if ecds[i].GetTypedConfig().GetTypeUrl() == ecds[j].GetTypedConfig().GetTypeUrl() {
    			return ecds[i].GetName() < ecds[j].GetName()
    		}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Jan 14 02:41:27 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  6. istioctl/pkg/util/configdump/listener.go

    		// If a listener was reloaded, it would contain both the active and draining state
    		// delete the draining state for proper comparison
    		l.DrainingState = nil
    		if l.ActiveState != nil {
    			dal = append(dal, l)
    		}
    	}
    
    	// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    	for i := range dal {
    		dal[i].ActiveState.Listener.TypeUrl = v3.ListenerType
    	}
    	sort.Slice(dal, func(i, j int) bool {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 2.5K bytes
    - Viewed (1)
  7. istioctl/pkg/waypoint/waypoint.go

    			})
    			filteredGws := make([]gateway.Gateway, 0)
    			for _, gw := range gws.Items {
    				if gw.Spec.GatewayClassName != constants.WaypointGatewayClassName {
    					continue
    				}
    				filteredGws = append(filteredGws, gw)
    			}
    			if allNamespaces {
    				fmt.Fprintln(w, "NAMESPACE\tNAME\tREVISION\tPROGRAMMED")
    			} else {
    				fmt.Fprintln(w, "NAME\tREVISION\tPROGRAMMED")
    			}
    			for _, gw := range filteredGws {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  8. cni/pkg/repair/repaircontroller.go

    		repairedPods: map[types.NamespacedName]types.UID{},
    	}
    	fieldSelectors := []string{}
    	if cfg.FieldSelectors != "" {
    		fieldSelectors = append(fieldSelectors, cfg.FieldSelectors)
    	}
    	// filter out pod events from different nodes
    	fieldSelectors = append(fieldSelectors, fmt.Sprintf("spec.nodeName=%v", cfg.NodeName))
    	c.pods = kclient.NewFiltered[*corev1.Pod](client, kclient.Filter{
    		LabelSelector: cfg.LabelSelectors,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  9. cni/pkg/plugin/sidecar_redirect.go

    }
    
    func dedupPorts(ports []string) []string {
    	dedup := make(map[string]bool)
    	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 {
    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)
  10. istioctl/pkg/authz/analyzer.go

    		l.ActiveState.Listener.TypeUrl = v3.ListenerType
    		err := l.ActiveState.Listener.UnmarshalTo(listenerTyped)
    		if err != nil {
    			return
    		}
    		listeners = append(listeners, listenerTyped)
    	}
    	Print(writer, listeners)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jul 13 01:59:17 GMT 2022
    - 2.1K bytes
    - Viewed (0)
Back to top