Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 30 for WorkloadSelector (0.36 sec)

  1. 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)
  2. 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)
  3. 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)
  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. 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)
  8. pilot/pkg/xds/bench_test.go

    				Name:              "selector",
    				Namespace:         "default",
    				CreationTimestamp: time.Now(),
    			},
    			Spec: &security.PeerAuthentication{
    				Selector: &v1beta1.WorkloadSelector{MatchLabels: map[string]string{"type": "eds-benchmark"}},
    				Mtls:     &security.PeerAuthentication_MutualTLS{Mode: security.PeerAuthentication_MutualTLS_DISABLE},
    			},
    		})
    	return result
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 22 18:13:40 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  9. pilot/pkg/xds/mesh_network_test.go

      name: remote-we-svc
      namespace: test
    spec:
      hosts:
      - remote-we-svc
      ports:
        - number: 80
          name: http
          protocol: HTTP
      resolution: STATIC
      location: MESH_INTERNAL
      workloadSelector:
        labels:
          app: remote-we-svc
    `,
    		},
    	}
    	workloadCases := []struct {
    		name         string
    		entries      []entry
    		expectations map[string][]xdstest.LocLbEpInfo
    	}{
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  10. pilot/pkg/networking/core/cluster.go

    	meshExternal    bool
    	serviceMTLSMode model.MutualTLSMode
    	// Indicates the service registry of the cluster being built.
    	serviceRegistry provider.ID
    	// Indicates if the destinationRule has a workloadSelector
    	isDrWithSelector bool
    }
    
    func applyTCPKeepalive(mesh *meshconfig.MeshConfig, c *cluster.Cluster, tcp *networking.ConnectionPoolSettings_TCPSettings) {
    	// Apply mesh wide TCP keepalive if available.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
Back to top