Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 88 for Append (0.15 sec)

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

    	}
    	if len(match.PrefixRanges) > 0 {
    		pf := []string{}
    		for _, p := range match.PrefixRanges {
    			pf = append(pf, fmt.Sprintf("%s/%d", p.AddressPrefix, p.GetPrefixLen().GetValue()))
    		}
    		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"}
    	}
    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/validate/validate.go

    				err := v.validateServicePortPrefix(istioNamespace, castItem)
    				if err != nil {
    					errs = multierror.Append(errs, err)
    				}
    			}
    			if castItem.GetKind() == name.DeploymentStr {
    				err := v.validateDeploymentLabel(istioNamespace, castItem, writer)
    				if err != nil {
    					errs = multierror.Append(errs, err)
    				}
    			}
    			return nil
    		})
    	}
    
    	if errs != nil {
    		return nil, errs
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Jan 22 17:58:52 GMT 2024
    - 15K bytes
    - Viewed (0)
  3. istioctl/pkg/checkinject/checkinject.go

    		row := table.Row{
    			Cells: make([]table.Cell, 0),
    		}
    		row.Cells = append(row.Cells, table.NewCell(wa.Name), table.NewCell(wa.Revision))
    		if wa.Injected {
    			row.Cells = append(row.Cells, table.NewCell("✔", color.FgGreen))
    		} else {
    			row.Cells = append(row.Cells, table.NewCell("✘", color.FgRed))
    		}
    		row.Cells = append(row.Cells, table.NewCell(wa.Reason))
    		return row
    	})
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  4. cni/pkg/iptables/iptables_linux.go

    }
    
    func forEachInpodMarkIPRule(cfg *Config, f func(*netlink.Rule) error) error {
    	var rules []*netlink.Rule
    	families := []int{unix.AF_INET}
    	if cfg.EnableIPv6 {
    		families = append(families, unix.AF_INET6)
    	}
    	for _, family := range families {
    		// Equiv:
    		// ip rule add fwmark 0x111/0xfff pref 32764 lookup 100
    		//
    		// Adds in-pod rules for marking packets with the istio-specific TPROXY mark.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  5. istioctl/pkg/authz/listener.go

    								} else {
    									parsedFC.rbacHTTP = append(parsedFC.rbacHTTP, rbacHTTP)
    								}
    							}
    						}
    					}
    				case wellknown.RoleBasedAccessControl:
    					rbacTCP := &rbactcp.RBAC{}
    					if err := getFilterConfig(filter, rbacTCP); err != nil {
    						log.Errorf("found RBAC network filter but failed to parse: %s", err)
    					} else {
    						parsedFC.rbacTCP = append(parsedFC.rbacTCP, rbacTCP)
    					}
    				}
    			}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Sep 11 15:29:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  6. operator/cmd/mesh/manifest_shared_test.go

    	}
    	for _, f := range filenames {
    		args += " -f " + f
    	}
    	if flags != "" {
    		args += " " + flags
    	}
    	if fileSelect != nil {
    		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, ",")
    	}
    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)
  7. cni/pkg/plugin/kubernetes.go

    func containers(pod *v1.Pod) []v1.Container {
    	res := make([]v1.Container, 0, len(pod.Spec.Containers)+len(pod.Spec.InitContainers))
    	res = append(res, pod.Spec.InitContainers...)
    	res = append(res, pod.Spec.Containers...)
    	return res
    }
    
    func (pi PodInfo) String() string {
    	var b strings.Builder
    	b.WriteString(fmt.Sprintf("  Containers: %v\n", sets.SortedList(pi.Containers)))
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  8. operator/cmd/mesh/profile-dump.go

    			if err != nil {
    				return accum, err
    			}
    			accum = append(accum, childwalk...)
    		}
    		return accum, nil
    	case []any:
    		accum := make([]string, 0)
    		for idx, vv := range v {
    			indexwalk, err := walk(fmt.Sprintf("%s[%d]", path, idx), ".", vv)
    			if err != nil {
    				return accum, err
    			}
    			accum = append(accum, indexwalk...)
    		}
    		return accum, nil
    	case string:
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  9. istioctl/pkg/admin/istiodconfig.go

    	)
    	allScopes, err := rs.client.GetScopes()
    	if err != nil {
    		return fmt.Errorf("could not get all scopes: %v", err)
    	}
    	var defaultScopes []*ScopeInfo
    	for _, scope := range allScopes {
    		defaultScopes = append(defaultScopes, &ScopeInfo{
    			Name:            scope.Name,
    			OutputLevel:     defaultOutputLevel,
    			StackTraceLevel: defaultStackTraceLevel,
    		})
    	}
    	err = rs.client.PutScopes(defaultScopes)
    	if err != nil {
    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)
  10. istioctl/pkg/waypoint/waypoint_test.go

    	conditions := make([]metav1.Condition, 0)
    	if programmed {
    		conditions = append(conditions, metav1.Condition{
    			Type:   string(gateway.GatewayConditionProgrammed),
    			Status: kstatus.StatusTrue,
    		})
    	} else {
    		conditions = append(conditions, metav1.Condition{
    			Type:   string(gateway.GatewayConditionProgrammed),
    			Status: kstatus.StatusFalse,
    		})
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 04 15:53:09 GMT 2024
    - 4.4K bytes
    - Viewed (0)
Back to top