Class PgBossHttpService

Hierarchy

Constructors

constructor

Properties

#config #dataSource$ #db #health #subscription? logger name 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

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