File tree 3 files changed +8
-0
lines changed
3 files changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -70,6 +70,7 @@ Many channel arguments supported in `grpc` are not supported in `@grpc/grpc-js`.
70
70
- ` grpc-node.max_session_memory `
71
71
- ` grpc-node.tls_enable_trace `
72
72
- ` grpc-node.retry_max_attempts_limit `
73
+ - ` grpc-node.flow_control_window `
73
74
- ` channelOverride `
74
75
- ` channelFactoryOverride `
75
76
Original file line number Diff line number Diff line change @@ -64,6 +64,7 @@ export interface ChannelOptions {
64
64
'grpc-node.tls_enable_trace' ?: number ;
65
65
'grpc.lb.ring_hash.ring_size_cap' ?: number ;
66
66
'grpc-node.retry_max_attempts_limit' ?: number ;
67
+ 'grpc-node.flow_control_window' ?: number ;
67
68
// eslint-disable-next-line @typescript-eslint/no-explicit-any
68
69
[ key : string ] : any ;
69
70
}
@@ -101,6 +102,7 @@ export const recognizedOptions = {
101
102
'grpc-node.tls_enable_trace' : true ,
102
103
'grpc.lb.ring_hash.ring_size_cap' : true ,
103
104
'grpc-node.retry_max_attempts_limit' : true ,
105
+ 'grpc-node.flow_control_window' : true ,
104
106
} ;
105
107
106
108
export function channelOptionsEqual (
Original file line number Diff line number Diff line change @@ -673,6 +673,11 @@ export class Http2SubchannelConnector implements SubchannelConnector {
673
673
const session = http2 . connect ( `http://${ targetPath } ` , {
674
674
createConnection : ( authority , option ) => {
675
675
return underlyingConnection ;
676
+ } ,
677
+ settings : {
678
+ initialWindowSize :
679
+ options [ 'grpc-node.flow_control_window' ] ??
680
+ http2 . getDefaultSettings ( ) . initialWindowSize ,
676
681
}
677
682
} ) ;
678
683
this . session = session ;
You can’t perform that action at this time.
0 commit comments