- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 33 for DR (0.04 sec)
-
pilot/pkg/xds/endpoints/mtls_checker.go
if drc == nil { return nil } dr, ok := drc.Spec.(*networkingapi.DestinationRule) if !ok || dr == nil { return nil } if subset == "" { return trafficPolicyTLSModeForPort(dr.GetTrafficPolicy(), port) } for _, ss := range dr.Subsets { if ss.Name != subset { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 01 07:32:22 UTC 2023 - 3.3K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_cache.go
h.WriteString(string(t.service.Hostname)) h.Write(Slash) h.WriteString(t.service.Attributes.Namespace) } h.Write(Separator) for _, dr := range t.destinationRule.GetFrom() { h.WriteString(dr.Name) h.Write(Slash) h.WriteString(dr.Namespace) } h.Write(Separator) for _, efk := range t.envoyFilterKeys { h.WriteString(efk) h.Write(Separator) } h.Write(Separator)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 6.1K bytes - Viewed (0) -
tests/integration/security/ca_custom_root/secure_naming_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.5K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_cache.go
configs = append(configs, r.DelegateVirtualServices...) for _, mergedDR := range r.DestinationRules { for _, dr := range mergedDR.GetFrom() { configs = append(configs, model.ConfigKey{Kind: kind.DestinationRule, Name: dr.Name, Namespace: dr.Namespace}.HashCode()) } } for _, efKey := range r.EnvoyFilterKeys { items := strings.Split(efKey, "/")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 5.8K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
} err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/config/analysis/analyzers/virtualservice/destinationrules.go
hostsAndSubsets := make(map[hostAndSubset]bool) ctx.ForEach(gvk.DestinationRule, func(r *resource.Instance) bool { dr := r.Message.(*v1alpha3.DestinationRule) drNamespace := r.Metadata.FullName.Namespace for _, ss := range dr.GetSubsets() { hs := hostAndSubset{ host: util.GetResourceNameFromHost(drNamespace, dr.GetHost()), subset: ss.GetName(), } hostsAndSubsets[hs] = true } return true })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 15:18:05 UTC 2023 - 4.1K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 4.8K bytes - Viewed (0) -
tests/integration/ambient/testdata/beta-mtls-automtls.yaml
# No DR is added for this test. enableAutoMtls is expected on by default. apiVersion: security.istio.io/v1beta1 kind: PeerAuthentication metadata: name: "default" annotations: test-suite: "beta-mtls-automtls" spec: mtls:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 247 bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
mappedResp := map[string]string{} w := new(tabwriter.Writer).Init(s.Writer, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tCLUSTER\tCDS\tLDS\tEDS\tRDS\tECDS\tISTIOD\tVERSION") for _, dr := range drs { for _, resource := range dr.Resources { clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.1K bytes - Viewed (0) -
src/net/http/httputil/dump.go
req.Body.Close() } select { case dr.c <- strings.NewReader("HTTP/1.1 204 No Content\r\nConnection: close\r\n\r\n"): case <-quitReadCh: // Ensure delegateReader.Read doesn't block forever if we get an error. close(dr.c) } }() _, err := t.RoundTrip(reqSend) req.Body = save if err != nil { pw.Close() dr.err = err close(quitReadCh) return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9.3K bytes - Viewed (0)