Class ThriftClientProvider

constructor

• new ThriftClientProvider(log, connectionProvider, config): ThriftClientProvider

• Parameters

  • log: ILogger

  • connectionProvider: IConnectionProvider

  • config: IConfig<any>

  Returns ThriftClientProvider

pools

createConnection

• createConnection(serviceProfile, connectionOpts?): Promise<Connection>

• Parameters

  • serviceProfile: string | IThriftServiceProfile

  • Optional connectionOpts: {
        protocol: any;
        transport: any;
    }

    • protocol: any

    • transport: any

  Returns Promise<Connection>

getClient

• getClient<TClient>(serviceProfile, clientConstructor, thriftOpts?): TClient

• Get thrift client from pool or create new client

  Type Parameters

  • TClient

  Parameters

  • serviceProfile: string | IThriftServiceProfile

  • clientConstructor: TClientConstructor<TClient>

  • thriftOpts: TThriftOpts = {}

  Returns TClient

getPool

• getPool<TClient>(serviceProfile, clientConstructor, opts): TThriftPool<TClient>

• Type Parameters

  • TClient

  Parameters

  • serviceProfile: string | IThriftServiceProfile

  • clientConstructor: TClientConstructor<TClient>

  • opts: TThriftOpts

  Returns TThriftPool<TClient>

getServiceProfile

• getServiceProfile(ref): IThriftServiceProfile

• Parameters

  • ref: string | IThriftServiceProfile

  Returns IThriftServiceProfile

onModuleDestroy

• onModuleDestroy(): Promise<void[]>

• Returns Promise<void[]>