- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 30 for WorkloadSelector (0.36 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)