- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for Dr (0.06 sec)
-
pkg/config/analysis/analyzers/destinationrule/ca-certificates.go
dr := r.Message.(*v1alpha3.DestinationRule) drNs := r.Metadata.FullName.Namespace drName := r.Metadata.FullName.String() mode := dr.GetTrafficPolicy().GetTls().GetMode() if mode == v1alpha3.ClientTLSSettings_SIMPLE || mode == v1alpha3.ClientTLSSettings_MUTUAL {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 07:22:31 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder_test.go
) func TestPopulateFailoverPriorityLabels(t *testing.T) { tests := []struct { name string dr *config.Config mesh *meshconfig.MeshConfig expectedLabels []byte }{ { name: "no dr", expectedLabels: nil, }, { name: "simple", dr: &config.Config{ Spec: &networking.DestinationRule{ TrafficPolicy: &networking.TrafficPolicy{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 5.9K 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) -
pilot/pkg/xds/endpoints/endpoint_builder.go
} } } func (b *EndpointBuilder) DestinationRule() *v1alpha3.DestinationRule { if dr := b.destinationRule.GetRule(); dr != nil { dr, _ := dr.Spec.(*v1alpha3.DestinationRule) return dr } return nil } func (b *EndpointBuilder) Type() string { return model.EDSType } func (b *EndpointBuilder) ServiceFound() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
tests/integration/security/reachability_test.go
}{ { name: "global mtls strict", configs: config.Sources{ config.File("testdata/reachability/global-peer-authn.yaml.tmpl"), config.File("testdata/reachability/global-dr.yaml.tmpl"), }.WithParams(param.Params{ mtlsModeParam: model.MTLSStrict.String(), tlsModeParam: "ISTIO_MUTUAL", param.Namespace.String(): systemNS, }),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 20.6K bytes - Viewed (0) -
pilot/pkg/xds/cds_test.go
Namespace: pod.Namespace, Name: pod.Name, }, }}, Ports: []discoveryv1.EndpointPort{{Name: ptr.Of("http"), Port: ptr.Of(int32(80))}}, } dr := config.Config{ Meta: config.Meta{ GroupVersionKind: gvk.DestinationRule, Name: "dr", Namespace: "test", }, Spec: &networking.DestinationRule{ Host: "example.default.svc.cluster.local",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/pkg/model/sidecar.go
// this config namespace) will see, identify all the destinationRules // that these services need for _, s := range out.services { if dr := ps.destinationRule(configNamespace, s); dr != nil { out.destinationRules[s.Hostname] = dr for _, cdr := range dr { for _, from := range cdr.from { out.destinationRulesByNames[from] = cdr.rule } } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
pkg/kube/client.go
} // namespaced resources should specify the namespace dr = c.dynamic.Resource(mapping.Resource).Namespace(ns) } else { // for cluster-wide resources dr = c.dynamic.Resource(mapping.Resource) } return obj, dr, nil } // IstioScheme returns a scheme will all known Istio-related types added var ( IstioScheme = istioScheme()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
return nil, nil } dr := prevCfg.Spec.(*networking.DestinationRule) services = append(services, proxy.SidecarScope.ServicesForHostname(host.Name(dr.Host))...) } else { dr := cfg.Spec.(*networking.DestinationRule) // Destinationrule was updated. Find matching services from updated destinationrule. services = append(services, proxy.SidecarScope.ServicesForHostname(host.Name(dr.Host))...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer_test.go
mesh *networking.LocalityLoadBalancerSetting dr *networking.LocalityLoadBalancerSetting expected *networking.LocalityLoadBalancerSetting }{ { "all disabled", nil, nil, nil, }, { "mesh only", &networking.LocalityLoadBalancerSetting{}, nil, &networking.LocalityLoadBalancerSetting{}, }, { "dr only", nil,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 39.1K bytes - Viewed (0)