Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 48 for WorkloadSelector (0.36 sec)

  1. pilot/pkg/model/push_context.go

    					// if there is a workload selector, check for matching workload labels
    					if sidecar.GetWorkloadSelector() != nil {
    						workloadSelector := labels.Instance(sidecar.GetWorkloadSelector().GetLabels())
    						// exclude workload selector that not match
    						if !workloadSelector.SubsetOf(workloadLabels) {
    							continue
    						}
    					}
    
    					// it is guaranteed sidecars with selectors are put in front
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
  2. pilot/pkg/model/authorization_test.go

    							Methods: []string{"GET"},
    						},
    					},
    				},
    			},
    		},
    	}
    	policyWithSelector := proto.Clone(policy).(*authpb.AuthorizationPolicy)
    	policyWithSelector.Selector = &selectorpb.WorkloadSelector{
    		MatchLabels: labels.Instance{
    			"app":     "httpbin",
    			"version": "v1",
    		},
    	}
    	policyWithTargetRef := proto.Clone(policy).(*authpb.AuthorizationPolicy)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. pilot/pkg/features/pilot.go

    	EnableSelectorBasedK8sGatewayPolicy = env.Register("ENABLE_SELECTOR_BASED_K8S_GATEWAY_POLICY", true,
    		"If disabled, Gateway API gateways will ignore workloadSelector policies, only"+
    			"applying policies that select the gateway with a targetRef.").Get()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. pkg/kube/krt/collection_test.go

    	return krt.NewCollection(entries, func(ctx krt.HandlerContext, i *istioclient.ServiceEntry) *SimpleService {
    		l := i.Spec.WorkloadSelector.GetLabels()
    		if l == nil {
    			return nil
    		}
    		return &SimpleService{
    			Named:    NewNamed(i),
    			Selector: l,
    		}
    	})
    }
    
    type SimpleEndpoint struct {
    	Pod       string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  5. pilot/pkg/xds/workload_test.go

    		},
    		PortLevelMtls: map[uint32]*v1beta1.PeerAuthentication_MutualTLS{
    			9080: {
    				Mode: v1beta1.PeerAuthentication_MutualTLS_STRICT,
    			},
    		},
    		Selector: &metav1beta1.WorkloadSelector{
    			MatchLabels: map[string]string{
    				"app": "sa", // This patches the pod we will create
    			},
    		},
    	})
    	expect(ads.ExpectResponse(), "ns/converted_peer_authentication_policy2")
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 18 19:09:43 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  6. pilot/pkg/config/kube/gateway/deploymentcontroller_test.go

    		Meta: config.Meta{
    			GroupVersionKind: gvk.ProxyConfig,
    			Name:             "test",
    			Namespace:        "default",
    		},
    		Spec: &istioio_networking_v1beta1.ProxyConfig{
    			Selector: &istio_type_v1beta1.WorkloadSelector{
    				MatchLabels: map[string]string{
    					"gateway.networking.k8s.io/gateway-name": "default",
    				},
    			},
    			Image: &istioio_networking_v1beta1.ProxyImage{
    				ImageType: "distroless",
    			},
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 21:43:20 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  7. tests/integration/pilot/common/routing.go

            typed_config:
              '@type': type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager
              xff_num_trusted_hops: 1
              normalize_path: true
      workloadSelector:
        labels:
          istio: {{.GatewayIstioLabel | default "ingressgateway"}}
    ---
    ` + httpVirtualServiceTmpl,
    		opts: echo.CallOptions{
    			Count: 1,
    			Port: echo.Port{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 21:52:51 UTC 2024
    - 135.9K bytes
    - Viewed (0)
  8. tests/integration/ambient/baseline_test.go

    			}
    			t.ConfigIstio().Eval(apps.Namespace.Name(), map[string]string{
    				"Destination": "waypoint",
    			}, `apiVersion: networking.istio.io/v1alpha3
    kind: EnvoyFilter
    metadata:
      name: inbound
    spec:
      workloadSelector:
        labels:
          gateway.networking.k8s.io/gateway-name: "{{.Destination}}"
      configPatches:
      - applyTo: HTTP_FILTER
        match:
          context: SIDECAR_INBOUND
          listener:
            filterChain:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 00:07:28 UTC 2024
    - 78.4K bytes
    - Viewed (0)
  9. pilot/pkg/model/telemetry_logging_test.go

    				},
    				Providers: []*tpb.ProviderRef{
    					{
    						Name: "envoy",
    					},
    				},
    			},
    		},
    	}
    	sidecarClient := &tpb.Telemetry{
    		Selector: &v1beta1.WorkloadSelector{
    			MatchLabels: labels,
    		},
    		AccessLogging: []*tpb.AccessLogging{
    			{
    				Match: &tpb.AccessLogging_LogSelector{
    					Mode: tpb.WorkloadMode_CLIENT,
    				},
    				Providers: []*tpb.ProviderRef{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 54K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go

    		implicitEndpoints := len(eps) == 0 &&
    			(se.Spec.Resolution == networkingv1alpha3.ServiceEntry_DNS || se.Spec.Resolution == networkingv1alpha3.ServiceEntry_DNS_ROUND_ROBIN) &&
    			se.Spec.WorkloadSelector == nil
    		if len(eps) == 0 && !implicitEndpoints {
    			return nil
    		}
    		// here we don't care about the *service* waypoint (hence it is nil); we are only going to use a subset of the info in
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top