Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for pushContext (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top