- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for pushContext (0.19 sec)
-
pilot/pkg/networking/core/cluster_builder_test.go
Services: []*model.Service{tt.service}, MeshConfig: tt.meshConfig, }) proxy := cg.SetupProxy(nil) cb := NewClusterBuilder(proxy, &model.PushRequest{Push: cg.PushContext()}, nil) tt.cluster.CommonLbConfig = &cluster.Cluster_CommonLbConfig{} ec := newClusterWrapper(tt.cluster) // Set cluster wrapping with HTTP2 options if port protocol is HTTP2
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway_test.go
tc.server: {SNIHosts: pilot_model.GetSNIHostsForServer(tc.server)}, }} ret := cgi.createGatewayHTTPFilterChainOpts(tc.node, tc.server.Port, tc.server, tc.routeName, tc.proxyConfig, tc.transportProtocol, cg.PushContext()) if diff := cmp.Diff(tc.result.tlsContext, ret.tlsContext, protocmp.Transform()); diff != "" { t.Errorf("got diff in tls context: %v", diff) } if !reflect.DeepEqual(tc.result.httpOpts, ret.httpOpts) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 144K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
} clusters := cg.Clusters(cg.SetupProxy(proxy)) xdstest.ValidateClusters(c.t, clusters) if len(cg.PushContext().ProxyStatus[model.DuplicatedClusters.Name()]) > 0 { c.t.Fatalf("duplicate clusters detected %#v", cg.PushContext().ProxyStatus[model.DuplicatedClusters.Name()]) } return clusters } func TestBuildGatewayClustersWithRingHashLb(t *testing.T) { cases := []struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0)