Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 111 for DR (0.04 sec)

  1. pilot/pkg/status/distribution/state.go

    		return
    	}
    	rptStr := cm.Data[dataField]
    	scope.Debugf("using report: %s", rptStr)
    	dr, err := ReportFromYaml([]byte(cm.Data[dataField]))
    	if err != nil {
    		scope.Warnf("received malformed distributionReport %s, discarding: %v", cm.Name, err)
    		return
    	}
    	drh.dc.handleReport(dr)
    }
    
    func (drh *DistroReportHandler) OnDelete(obj any) {
    	// TODO: what do we do here?  will these ever be deleted?
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. src/image/draw/draw_test.go

    				continue
    			}
    
    			const M = 1<<16 - 1
    			var dr, dg, db, da uint32
    			if op == Over {
    				dr, dg, db, da = dst.At(x, y).RGBA()
    			}
    			sr, sg, sb, sa := src.At(sx, sy).RGBA()
    			ma := uint32(M)
    			if mask != nil {
    				_, _, _, ma = mask.At(mx, my).RGBA()
    			}
    			a := M - (sa * ma / M)
    			golden.Set(x, y, color.RGBA64{
    				uint16((dr*a + sr*ma) / M),
    				uint16((dg*a + sg*ma) / M),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 20 18:07:05 UTC 2023
    - 26K bytes
    - Viewed (0)
  5. pilot/pkg/model/push_context_test.go

    			}
    			for i, dr := range drList {
    				if dr.rule.Name != tt.expectedDrName[i] {
    					t.Errorf("destinationRuleName expected %v got %v", tt.expectedDrName[i], dr.rule.Name)
    				}
    			}
    			testLocal := ps.destinationRuleIndex.namespaceLocal[tt.proxyNs]
    			if testLocal != nil {
    				destRules := testLocal.specificDestRules
    				for _, dr := range destRules[host.Name(testhost)] {
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 95.3K bytes
    - Viewed (0)
  6. pilot/pkg/xds/lds.go

    // Map of all configs that do not impact LDS
    var skippedLdsConfigs = map[model.NodeType]sets.Set[kind.Kind]{
    	model.Router: sets.New(
    		// for autopassthrough gateways, we build filterchains per-dr subset
    		kind.WorkloadGroup,
    		kind.WorkloadEntry,
    		kind.Secret,
    		kind.ProxyConfig,
    		kind.DNSName,
    	),
    	model.SidecarProxy: sets.New(
    		kind.Gateway,
    		kind.WorkloadGroup,
    		kind.WorkloadEntry,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 15:58:06 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  7. tests/integration/security/pass_through_filter_chain_test.go

    							param.Namespace.String(): apps.Ns1.Namespace,
    						})).
    						// It's not trivial to force mTLS to pass-through ports. To work around this, we will
    						// set up a SE and DR that forces it.
    						//
    						// Since our client will talk directly to pods via IP, we have to configure the ports
    						// in the SE as TCP, since only TCP does will match based in IP address rather than host.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  8. pilot/pkg/networking/grpcgen/grpcecho_test.go

      selector:
        app: echo
      ports:
      - name: grpc
        targetPort: grpc
        port: 7070
    `,
    		ConfigString: `
    apiVersion: networking.istio.io/v1alpha3
    kind: DestinationRule
    metadata:
      name: echo-dr
      namespace: default
    spec:
      host: echo-app.default.svc.cluster.local
      subsets:
        - name: v1
          labels:
            version: v1
        - name: v2
          labels:
            version: v2
    ---
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  9. tests/integration/security/egress_sidecar_tls_origination_test.go

      ports:
      - number: 80
        name: http-port
        protocol: HTTP
        targetPort: 443
      - number: 443
        name: https-port
        protocol: HTTPS
      resolution: DNS
    `
    	dr := `
    apiVersion: networking.istio.io/v1alpha3
    kind: DestinationRule
    metadata:
      name: originate-tls-for-server-sds-{{.WorkloadSelector}}
    spec:
      workloadSelector:
        matchLabels:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  10. pilot/pkg/networking/core/cluster_tls.go

    	}
    }
    
    // Set auto_sni if EnableAutoSni feature flag is enabled and if sni field is not explicitly set in DR.
    // Set auto_san_validation if VerifyCertAtClient feature flag is enabled and if there is no explicit SubjectAltNames specified  in DR.
    func (cb *ClusterBuilder) setAutoSniAndAutoSanValidation(mc *clusterWrapper, tls *networking.ClientTLSSettings) {
    	if mc == nil || !features.EnableAutoSni {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 18 19:09:43 UTC 2024
    - 19.2K bytes
    - Viewed (0)
Back to top