Class ProjectionHttpService<T>

Manages subscription to provided projection$ observable by implementing RunnableModule.

Implements HttpService.healthCheck() by considering itself health only when local node tip is equal to the projected tip.

Type Parameters

Hierarchy

Constructors

constructor

Properties

#dryRun? #health #healthTimeout #projection$ #projectionSubscription? logger name openApiPath provider router slug state

Methods

apiVersionPath attachProviderRoutes healthCheck initialize initializeAfter initializeBefore initializeImpl shutdown shutdownAfter shutdownBefore shutdownImpl start startAfter startBefore startImpl routeHandler

Constructors

constructor

Properties

Private Optional #dryRun

#dryRun?: boolean

Private #health

#health: HealthCheckResponse = ...

Private #healthTimeout

#healthTimeout: Milliseconds

Private #projection$

#projection$: Observable<T>

Private Optional #projectionSubscription

#projectionSubscription?: Subscription

logger

logger: Logger

name

name: string

openApiPath

openApiPath: string

provider

provider: Provider

router

router: Router

slug

slug: string

state

state: RunnableModuleState

Methods

apiVersionPath

attachProviderRoutes

healthCheck

initialize

  • Returns Promise<void>

initializeAfter

  • Returns void

initializeBefore

  • Returns void

Protected initializeImpl

shutdown

  • Returns Promise<void>

shutdownAfter

  • Returns void

shutdownBefore

  • Returns void

shutdownImpl

start

  • Returns Promise<void>

startAfter

  • Returns void

startBefore

  • Returns void

startImpl

Static routeHandler

Settings

Member Visibility

Theme

Generated using TypeDoc