amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'bugfix/grpc-options' of https://github.com/sjkummer/nest into sjkummer-bugfix/grpc-options

Browse Source
This commit is contained in:
Kamil Myśliwiec
2020-05-24 13:51:51 +02:00
parent 0d6ae6fe88 2dcff086b3
commit b397cec0fd
3 changed files with 25 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
packages/microservices/client/client-grpc.ts
View File

@@ -90,6 +90,7 @@ export class ClientGrpcProxy extends ClientProxy implements ClientGrpc {
const keepaliveOptions = this.getKeepaliveOptions();
const options: Record<string, string | number> = {
...this.options.channelOptions,
...maxMessageLengthOptions,
...keepaliveOptions,
};

22
packages/microservices/external/grpc-options.interface.ts vendored Normal file
View File

@@ -0,0 +1,22 @@
/// <reference types="node" />
/**
* An interface that contains options used when initializing a Channel instance.
* This listing is incomplete. Full reference: https://grpc.github.io/grpc/core/group__grpc__arg__keys.html
*/
export interface ChannelOptions {
'grpc.ssl_target_name_override'?: string;
'grpc.primary_user_agent'?: string;
'grpc.secondary_user_agent'?: string;
'grpc.default_authority'?: string;
'grpc.keepalive_time_ms'?: number;
'grpc.keepalive_timeout_ms'?: number;
'grpc.service_config'?: string;
'grpc.max_concurrent_streams'?: number;
'grpc.initial_reconnect_backoff_ms'?: number;
'grpc.max_reconnect_backoff_ms'?: number;
'grpc.use_local_subchannel_pool'?: number;
'grpc.max_send_message_length'?: number;
'grpc.max_receive_message_length'?: number;
[key: string]: string | number | undefined;
}

2
packages/microservices/interfaces/microservice-configuration.interface.ts
View File

@@ -10,6 +10,7 @@ import { Server } from '../server/server';
import { CustomTransportStrategy } from './custom-transport-strategy.interface';
import { Deserializer } from './deserializer.interface';
import { Serializer } from './serializer.interface';
import {ChannelOptions} from '../external/grpc-options.interface';
export type MicroserviceOptions =
| GrpcOptions
@@ -42,6 +43,7 @@ export interface GrpcOptions {
http2MinPingIntervalWithoutDataMs?: number;
http2MaxPingStrikes?: number;
};
channelOptions?: ChannelOptions;
credentials?: any;
protoPath: string | string[];
package: string | string[];