Options
All
  • Public
  • Public/Protected
  • All
Menu

Class Service

Hierarchy

  • Service

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

Private _codec

_codec: Codec

Private _healthChecks

_healthChecks: Dependency[]

Private _httpPort

_httpPort: number

Private _httpServer

_httpServer: Server

Private _noHealthChecks

_noHealthChecks: boolean

Private _stopHealthCheck

_stopHealthCheck: function

Type declaration

    • (): void

    • Returns void

Private _transport

_transport: Transport

id

id: string = generateId()

logger

logger: Logger

name

name: string

Protected options

options: Options

Methods

Private _call

Private _checkResponse

  • _checkResponse(res: any): boolean

Private _getCallTimeout

  • _getCallTimeout(path: string, timeout: number): number

Private _handle

Private _serializeRequest

call

close

  • close(): Promise<void>

emit

  • emit(topic: string, message: any): void

handle

handleWithoutLogging

listen

  • listen(callback: Function): Promise<any>

  • Parameters

    • Optional callback: Function

    Returns Promise<any>

    returns promise if called with no callback.

Private loopOverHealthChecks

  • loopOverHealthChecks(): void

on

  • on(topic: string, callback: Function, disableGroup?: boolean): any

  • Parameters

    • topic: string
    • callback: Function
    • Default value disableGroup: boolean = false

    Returns any

onAsync

  • onAsync<T>(topic: string, disableGroup?: boolean): AsyncArray<T>

  • Type parameters

    • T

    Parameters

    • topic: string
    • Default value disableGroup: boolean = false

    Returns AsyncArray<T>

    An async array following the producer/consumer pattern.

onClose

  • onClose(callback: any): void

registerHealthCheck

toString

  • toString(): string

Generated using TypeDoc