Class PgBossHttpService

Hierarchy

Constructors

constructor

Properties

#config #dataSource$ #db #health #subscription? logger name onUnrecoverableError$ openApiPath provider router slug state

Methods

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

Constructors

constructor

Properties

Private #config

#config: PgBossWorkerArgs

Private #dataSource$

#dataSource$: Observable<DataSource>

Private #db

#db: Pool

Private #health

#health: HealthCheckResponse = ...

Private Optional #subscription

#subscription?: Subscription

logger

logger: Logger

name

name: string

onUnrecoverableError$

onUnrecoverableError$: Subject<unknown> = ...

openApiPath

openApiPath: string

provider

provider: Provider

router

router: Router

slug

slug: string

state

state: RunnableModuleState

Methods

apiVersionPath

attachProviderRoutes

Private createQueue

  • Parameters

    • dataSource: DataSource
    • pgBoss: PgBoss
    • queue: "pool-metadata" | "pool-delist-schedule" | "pool-metrics" | "pool-rewards"
    • db: Pool

    Returns Observable<unknown>

Private createSchedule

healthCheck

initialize

  • Returns Promise<void>

initializeAfter

  • Returns void

initializeBefore

  • Returns void

Protected initializeImpl

shutdown

  • Returns Promise<void>

shutdownAfter

  • Returns void

shutdownBefore

  • Returns void

Protected shutdownImpl

start

  • Returns Promise<void>

startAfter

  • Returns void

startBefore

  • Returns void

Protected startImpl

Private work

Private workQueue

Static routeHandler

Settings

Member Visibility

Theme

Generated using TypeDoc