- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 150 for Lange (0.13 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/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/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/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) -
cni/pkg/install/install_test.go
existingConfFiles: map[string]string{"istio-cni.conf": "istio-cni.conf"}, }, } for _, c := range cases { t.Run(c.name, func(t *testing.T) { // Create temp directory for files tempDir := t.TempDir() // Create existing config files if specified in test case for srcFilename, targetFilename := range c.existingConfFiles {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
}, Webhooks: []admitv1.ValidatingWebhook{ { Name: "random", }, { FailurePolicy: &fail, Name: "validation.istio.io", }, }, }) for _, tc := range tcs { t.Run(tc.name, func(t *testing.T) { webhookConfig, err := tagWebhookConfigFromCanonicalWebhook(tc.webhook, "default", tc.istioNamespace) if err != nil { t.Fatalf("webhook parsing failed with error: %v", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
cni/pkg/plugin/kubernetes.go
Annotations: pod.Annotations, ProxyEnvironments: make(map[string]string), } for _, c := range containers(pod) { pi.Containers.Insert(c.Name) if c.Name == ISTIOPROXY { // don't include ports from istio-proxy in the redirect ports // Get proxy container env variable, and extract out ProxyConfig from it. for _, e := range c.Env { pi.ProxyEnvironments[e.Name] = e.Value } if len(c.Args) >= 2 && c.Args[0] == "proxy" {
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) -
manifests/charts/istio-control/istio-discovery/templates/NOTES.txt
"global.meshExpansion.enabled" "Gateway and other Istio networking resources, such as in samples/multicluster/" "istiocoredns.enabled" "the in-proxy DNS capturing (ISTIO_META_DNS_CAPTURE)" }} {{- range $dep, $replace := $deps }} {{- /* Complex logic to turn the string above into a null-safe traversal like ((.Values.global).certificates */}}
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 16:38:47 GMT 2024 - 4.2K bytes - Viewed (0)