- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 150 for RANGE (0.12 sec)
-
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. // A very similar mechanism is used for sidecar TPROXY.
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) -
manifests/charts/istio-control/istio-discovery/files/grpc-agent.yaml
value: | {{ protoToJSON .ProxyConfig }} - name: ISTIO_META_POD_PORTS value: |- [ {{- $first := true }} {{- range $index1, $c := .Spec.Containers }} {{- range $index2, $p := $c.Ports }} {{- if (structToJSON $p) }} {{if not $first}},{{end}}{{ structToJSON $p }} {{- $first = false }} {{- end }}
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 26 16:51:17 GMT 2024 - 12.1K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
for _, rm := range ip.GetRangeMatchers() { for _, r := range rm.Ranges { cidr := r.AddressPrefix pl := r.PrefixLen.GetValue() if pl != 32 && pl != 128 { cidr += fmt.Sprintf("/%d", pl) } m[cidr] = rm.OnMatch } } default: panic("unhandled") } } outputs := []string{} for k, v := range m { switch v := v.GetOnMatch().(type) {
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) -
istioctl/pkg/writer/envoy/configdump/configdump_test.go
inputFile string wantErr bool }{ { name: "errors if unable to unmarshal bytes", inputFile: "", wantConfigs: 0, wantErr: true, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { cw := &ConfigWriter{} cd, _ := os.ReadFile(tt.inputFile) err := cw.Prime(cd) if cw.configDump == nil { if tt.wantConfigs != 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 03 23:08:06 GMT 2024 - 3.5K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
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) -
istioctl/pkg/waypoint/waypoint.go
defer ticker.Stop() for range ticker.C { programmed := false gwc, err := kubeClient.GatewayAPI().GatewayV1().Gateways(ctx.NamespaceOrDefault(ctx.Namespace())).Get(context.TODO(), gw.Name, metav1.GetOptions{}) if err == nil { // Check if gateway has Programmed condition set to true for _, cond := range gwc.Status.Conditions {
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) -
istioctl/pkg/workload/workload_test.go
}, "ipv6": { "internalIP": "fd00:10:96::1", "ingressIP": "fd00:10:96::2", }, } for _, dir := range files { if !dir.IsDir() { continue } testdir := path.Join("testdata/vmconfig", dir.Name()) t.Cleanup(func() { for k := range generated { os.Remove(path.Join(testdir, k)) } }) t.Run(dir.Name(), func(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
istioctl/pkg/util/configdump/util.go
) // getSection takes a TypeURL and returns the types.Any from the config dump corresponding to that URL func (w *Wrapper) getSection(sectionTypeURL configTypeURL) (*anypb.Any, error) { var dumpAny *anypb.Any for _, conf := range w.Configs { if conf.TypeUrl == string(sectionTypeURL) { dumpAny = conf } } if dumpAny == nil { return nil, fmt.Errorf("config dump has no configuration type %s", sectionTypeURL) }
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) -
istioctl/pkg/tag/util.go
LabelSelector: fmt.Sprintf("%s=%s", label.IoIstioRev.Name, tag), }) if err != nil { return nil, err } nsNames := make([]string, len(namespaces.Items)) for i, ns := range namespaces.Items { nsNames[i] = ns.Name } return nsNames, nil } // GetWebhookTagName extracts tag name from webhook object. func GetWebhookTagName(wh admitv1.MutatingWebhookConfiguration) string {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:42 GMT 2024 - 5.4K bytes - Viewed (1) -
manifests/charts/gateways/istio-ingress/templates/deployment.yaml
{{- if not $gateway.runAsRoot }} - name: ISTIO_META_UNPRIVILEGED_POD value: "true" {{- end }} {{- range $key, $val := $gateway.env }} - name: {{ $key }} value: "{{ $val }}" {{- end }} {{- range $key, $value := .Values.meshConfig.defaultConfig.proxyMetadata }} - name: {{ $key }} value: "{{ $value }}" {{- end }}
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 12.1K bytes - Viewed (1)