- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for SetForTest (0.25 sec)
-
pilot/pkg/networking/core/listener_test.go
test.SetForTest(t, &features.EnableSidecarServiceInboundListenerMerge, true) testInboundListenerConfigWithSidecarIngressPortMergeServicePort(t, getProxy(), buildServiceWithPort("test1.com", 80, protocol.HTTP, tnow.Add(1*time.Second))) }) t.Run("merge sidecar ingress and service ports, same port in both sidecar and service", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
Address: workloadEntry.Spec.(*networking.WorkloadEntry).Address, Port: 80, }} expectServiceEndpoints(t, fx, expectedSvc, 80, instances) }) istiotest.SetForTest(t, &features.EnableSidecarHBONEListening, true) istiotest.SetForTest(t, &features.EnableAmbient, true) for _, ambient := range []bool{false, true} { name := "disabled" if ambient { name = "enabled" } m := mesh.DefaultMeshConfig()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
kubernetes.io/service-name: headless endpoints: - addresses: - 1.2.3.4 ports: ` + ports, calls: calls, }, ) } func TestExternalNameServices(t *testing.T) { test.SetForTest(t, &features.EnableExternalNameAlias, true) ports := ` - name: http port: 80 - name: auto port: 81 - name: tcp port: 82 - name: tls port: 83 - name: https
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
}, }, } OptimizedConfigRebuildModes := []bool{true, false} for _, tt := range cases { for _, mode := range OptimizedConfigRebuildModes { t.Run(tt.name, func(t *testing.T) { test.SetForTest(t, &features.OptimizedConfigRebuild, mode) env := &Environment{} store := NewFakeStore() for _, cfg := range initialEnvoyFilters { _, _ = store.Create(cfg) } env.ConfigStore = store
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_tls_test.go
}, Sni: "some-sni.com", }, err: nil, }, }, } for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { test.SetForTest(t, &features.EnableAutoSni, tc.enableAutoSni) test.SetForTest(t, &features.VerifyCertAtClient, tc.enableVerifyCertAtClient) var proxy *model.Proxy if tc.router { proxy = newGatewayProxy() } else { proxy = newSidecarProxy()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 60.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
} sort.Strings(got) assert.Equal(t, want, got) } func TestExternalNameServiceInstances(t *testing.T) { t.Run("alias", func(t *testing.T) { test.SetForTest(t, &features.EnableExternalNameAlias, true) controller, fx := NewFakeControllerWithOptions(t, FakeControllerOptions{}) createExternalNameService(controller, "svc5", "nsA", []int32{1, 2, 3}, "foo.co", t, fx)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/security/authn/policy_applier_test.go
Hostname: "jwt-token-issuer.mesh.svc.cluster.local", } for _, c := range cases { t.Run(c.name, func(t *testing.T) { istiotest.SetForTest(t, &features.JwksFetchMode, c.jwksFetchMode) if got := newPolicyApplier("root-namespace", c.in, nil, push).JwtFilter(false, false); !reflect.DeepEqual(c.expected, got) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 01 07:32:22 UTC 2023 - 60.2K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute_test.go
out, _ := generateVirtualHostDomains(service, port, port, node) assert.Equal(t, out, want) } for _, c := range cases { c := c t.Run(c.name, func(t *testing.T) { test.SetForTest[bool](t, &features.EnableDualStack, c.enableDualStack) testFn(t, c.service, c.port, c.node, c.want) }) } } func TestSidecarOutboundHTTPRouteConfigWithDuplicateHosts(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 51.4K bytes - Viewed (0) -
pilot/pkg/model/sidecar_test.go
}, oldestWins: true, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { if tt.oldestWins { test.SetForTest(t, &features.PersistOldestWinsHeuristicForVirtualServiceHostMatching, true) } index := computeWildcardHostVirtualServiceIndex(tt.virtualServices, tt.services) if !reflect.DeepEqual(tt.expectedIndex, index) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 07 09:38:49 UTC 2024 - 74.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
} func TestDefaultAllowWaypointPolicy(t *testing.T) { // while the Waypoint is in testNS, the policies live in the Pods' namespaces policyName := "ns1/istio_allow_waypoint_" + testNS + "_" + "waypoint-ns" test.SetForTest(t, &features.DefaultAllowFromWaypoint, true) s := newAmbientTestServer(t, testC, testNW) setupPolicyTest(t, s) t.Run("policy with service accounts", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)