Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for MaxConcurrentStreams (0.28 sec)

  1. pilot/pkg/bootstrap/server.go

    		// it on the HTTP port. Does not impact the HTTPS gRPC or HTTPS.
    		log.Infof("multiplexing gRPC on http addr %v", args.ServerOptions.HTTPAddr)
    		multiplexGRPC = true
    	}
    	h2s := &http2.Server{
    		MaxConcurrentStreams: uint32(features.MaxConcurrentStreams),
    	}
    	multiplexHandler := h2c.NewHandler(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		// If we detect gRPC, serve using grpcServer
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  2. operator/cmd/mesh/testdata/manifest-generate/output/all_on.golden-show-in-gh-pull-request.yaml

                                      description: The idle timeout for upstream connection
                                        pool connections.
                                      type: string
                                    maxConcurrentStreams:
                                      format: int32
                                      type: integer
                                    maxRequestsPerConnection:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 10 05:10:03 UTC 2024
    - 506.8K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_waypoint.go

    		AllowConnect: true,
    		// TODO(https://github.com/istio/istio/issues/43443)
    		// All streams are bound to the same worker. Therefore, we need to limit for better fairness.
    		MaxConcurrentStreams: &wrappers.UInt32Value{Value: 100},
    		// well behaved clients should close connections.
    		// not all clients are well-behaved. This will prune
    		// connections when the client is not responding, to keep
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/cluster_builder_test.go

    							MaxRequestsPerConnection: 10,
    						},
    					},
    				},
    			},
    			expectedSubsetClusters: []*cluster.Cluster{},
    		},
    		{
    			name:        "destination rule with maxConcurrentStreams",
    			cluster:     &cluster.Cluster{Name: "foo", ClusterDiscoveryType: &cluster.Cluster_Type{Type: cluster.Cluster_EDS}},
    			clusterMode: DefaultClusterMode,
    			service:     http2Service,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
  5. pkg/config/validation/validation_test.go

    					Http1MaxPendingRequests:  2,
    					Http2MaxRequests:         11,
    					MaxRequestsPerConnection: 5,
    					MaxRetries:               4,
    					IdleTimeout:              &durationpb.Duration{Seconds: 30},
    					MaxConcurrentStreams:     5,
    				},
    			},
    			valid: true,
    		},
    
    		{
    			name: "valid connection pool, tcp only", in: &networking.ConnectionPoolSettings{
    				Tcp: &networking.ConnectionPoolSettings_TCPSettings{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 03:11:45 UTC 2024
    - 196K bytes
    - Viewed (0)
  6. operator/cmd/mesh/testdata/manifest-generate/data-snapshot.tar.gz

    connection. format: int32 type: integer http2MaxRequests: description: Maximum number of active requests to a destination. format: int32 type: integer idleTimeout: description: The idle timeout for upstream connection pool connections. type: string maxConcurrentStreams: format: int32 type: integer maxRequestsPerConnec: description: Maximum number of requests per connection to a backend. format: int32 type: integer maxRetries: description: Maximum number of retries that can be outstanding to all hosts in a...
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 10 05:10:03 UTC 2024
    - 198.1K bytes
    - Viewed (0)
  7. pkg/config/validation/validation.go

    			errs = appendErrors(errs, fmt.Errorf("use client protocol must not be true when H2UpgradePolicy is UPGRADE"))
    		}
    		if httpSettings.MaxConcurrentStreams < 0 {
    			errs = appendErrors(errs, fmt.Errorf("max concurrent streams must be non-negative"))
    		}
    	}
    
    	if tcp := settings.Tcp; tcp != nil {
    		if tcp.MaxConnections < 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:33 UTC 2024
    - 107.2K bytes
    - Viewed (0)
Back to top