Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 75 for WorkloadSelector (0.26 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. pilot/pkg/xds/ads_test.go

    	notMatchedScc := config.Config{
    		Meta: config.Meta{
    			GroupVersionKind: gvk.Sidecar,
    			Name:             "notMatchedSc", Namespace: testConfigNamespace,
    		},
    		Spec: &networking.Sidecar{
    			WorkloadSelector: &networking.WorkloadSelector{
    				Labels: map[string]string{"notMatched": "notMatched"},
    			},
    		},
    	}
    	if _, err := s.Store().Create(scc); err != nil {
    		t.Fatal(err)
    	}
    	addService(testConfigNamespace, 1, 2, 3)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 30 17:25:17 UTC 2024
    - 30.3K bytes
    - Viewed (0)
  5. tests/integration/telemetry/api/wasmplugin_test.go

    			t.Fatalf("failed to install WasmPlugin: %v", err)
    		}
    		sendTraffic(t, check.ResponseHeader(injectedHeader, c.expectedVersion))
    	})
    }
    
    // TestTargetRef vs workloadSelector for gateways
    func TestGatewaySelection(t *testing.T) {
    	framework.NewTest(t).
    		Run(func(t framework.TestContext) {
    			crd.DeployGatewayAPIOrSkip(t)
    			args := map[string]any{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  6. pilot/test/mock/config.go

    				LbPolicy: new(networking.LoadBalancerSettings_Simple),
    			},
    		},
    	}
    
    	// ExampleAuthorizationPolicy is an example AuthorizationPolicy
    	ExampleAuthorizationPolicy = &authz.AuthorizationPolicy{
    		Selector: &api.WorkloadSelector{
    			MatchLabels: map[string]string{
    				"app":     "httpbin",
    				"version": "v1",
    			},
    		},
    	}
    
    	mockGvk = collections.Mock.GroupVersionKind()
    )
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top