Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ClientRedis

Hierarchy

Index

Constructors

constructor

Properties

Protected connection

connection: Promise<any>

Protected isExplicitlyTerminated

isExplicitlyTerminated: boolean = false

Protected logger

logger: any = new Logger(ClientProxy.name)

Protected options

options: any

Protected pubClient

pubClient: RedisClient

Protected routingMap

routingMap: any = new Map<string, Function>()

Protected subClient

subClient: RedisClient

Protected url

url: string

Methods

Protected assignPacketId

close

  • close(): void

connect

  • connect(): Promise<any>

Protected connect$

  • connect$(instance: any, errorEvent?: string, connectEvent?: string): Observable<any>

createClient

Protected createObserver

  • createObserver<T>(observer: Observer<T>): function

createResponseCallback

  • createResponseCallback(): function

createRetryStrategy

  • createRetryStrategy(options: RetryStrategyOptions, error$: Subject<Error>): undefined | number | Error

Protected dispatchEvent

emit

  • emit<TResult, TInput>(pattern: any, data: TInput): Observable<TResult>

getAckPatternName

  • getAckPatternName(pattern: string): string

getClientOptions

  • getClientOptions(error$: Subject<Error>): Partial<ClientOpts>

Protected getOptionsProp

  • getOptionsProp<T>(obj: any, prop: keyof T["options"], defaultValue?: any): any

getResPatternName

  • getResPatternName(pattern: string): string

handleError

Protected normalizePattern

  • normalizePattern<T>(pattern: T): string

Protected publish

  • publish(partialPacket: ReadPacket, callback: function): Function

send

  • send<TResult, TInput>(pattern: any, data: TInput): Observable<TResult>

Generated using TypeDoc