Functions — github.com/timgit/pg-boss

hub / github.com/timgit/pg-boss / functions

Functions934 in github.com/timgit/pg-boss

⨍ Functions 934◇ Types & classes 161

↓ 2 callersMethodnotifyQueue

(name: string)

src/manager.ts:799

↓ 2 callersMethodonCacheQueues

({ emit = false } = {})

src/manager.ts:537

↓ 2 callersMethodonCron

()

src/timekeeper.ts:151

↓ 2 callersMethodonError

(error: any)

src/manager.ts:700

↓ 2 callersFunctionopenConfirmDialog

(intent: string, title: string, description: string, confirmLabel: string)

packages/dashboard/app/routes/queues.$name.tsx:450

↓ 2 callersFunctionparseBoolean

(value: string | undefined, defaultValue: boolean)

packages/proxy/src/env.ts:49

↓ 2 callersFunctionparseNumber

(value: string | undefined, defaultValue: number)

packages/proxy/src/env.ts:54

↓ 2 callersFunctionparseString

(value: string | undefined, defaultValue: string)

packages/proxy/src/env.ts:60

↓ 2 callersFunctionparseStringArray

(value: string | undefined)

packages/proxy/src/env.ts:64

↓ 2 callersFunctionrenderEditor

( columns: JobColumn[] = DEFAULT_JOB_COLUMNS, onColumnsChange = vi.fn() )

packages/dashboard/tests/frontend/job-columns-editor.test.tsx:7

↓ 2 callersMethodretry

(name: string, id: string | string[], options?: types.ConnectionOptions)

src/index.ts:308

↓ 2 callersMethodschemaVersion

()

src/contractor.ts:35

↓ 2 callersMethodsendAfter

(name: string, data: object | null, options: types.SendOptions | null, after: Date | string | number)

src/index.ts:236

↓ 2 callersFunctionserializeJsonParam

(value: unknown)

src/plans.ts:2453

↓ 2 callersFunctionsetColorTheme

(newColorTheme: ColorTheme)

packages/dashboard/app/components/theme-provider.tsx:127

↓ 2 callersFunctionsetReadyHistory

(name: string, values: number[])

packages/dashboard/tests/server/queue-stats-history.test.ts:117

↓ 2 callersFunctionterminateListener

(db: any, channel: string)

test/dbListenTest.ts:11

↓ 2 callersFunctiontoLocalInput

(iso: string | null)

packages/dashboard/app/routes/queues.$name.metrics.tsx:120

↓ 2 callersFunctiontrySetQueueTimestamp

(schema: string, queues: string[], column: string, seconds: number)

src/plans.ts:751

↓ 2 callersFunctionunblockChildrenUpdate

(schema: string)

src/plans.ts:1490

↓ 2 callersFunctionunschedule

( dbUrl: string, schema: string, name: string, key?: string )

packages/dashboard/app/lib/boss.server.ts:72

↓ 2 callersFunctionupdatePair

(index: number, patch: Partial<JsonFilterPair>)

packages/dashboard/app/components/jobs-filter-bar.tsx:217

↓ 2 callersFunctionuseDbHref

(to: To)

packages/dashboard/app/components/db-link.tsx:34

↓ 2 callersFunctionvalidateDeletionConfig

(config: any)

src/attorney.ts:619

↓ 2 callersFunctionvalidateGroupConcurrencyValue

(value: any, optionName: string)

src/attorney.ts:301

↓ 2 callersFunctionvalidateGroupConfig

(config: any)

src/attorney.ts:194

↓ 2 callersFunctionvalidatePriorityRangeConfig

(config: any)

src/attorney.ts:317

↓ 2 callersFunctionwaitForBamCompletion

(boss: PgBoss, timeoutMs = 10000)

test/migrationTest.ts:676

↓ 2 callersFunctionx

(i: number)

packages/dashboard/app/components/ui/sparkline.tsx:41

↓ 2 callersFunctiony

(v: number)

packages/dashboard/app/components/ui/sparkline.tsx:42

↓ 1 callersMethod#completeWithOutputs

(name: string, items: { id: string, output: unknown }[])

src/manager.ts:331

↓ 1 callersMethod#decrementLocalGroupCount

(queueName: string, groupId: string)

src/manager.ts:181

↓ 1 callersMethod#ensureQueueStatsPartitions

()

src/boss.ts:146

↓ 1 callersMethod#getGroupsAtLocalCapacity

(queueName: string)

src/manager.ts:147

↓ 1 callersMethod#getJobResultKey

(id: string, state: JobSpyState)

src/spy.ts:84

↓ 1 callersMethod#getLocalGroupLimit

(queueName: string, groupTier?: string | null)

src/manager.ts:138

↓ 1 callersMethod#getNextCommand

()

src/bam.ts:135

↓ 1 callersMethod#incrementLocalGroupCount

(queueName: string, groupId: string)

src/manager.ts:171

↓ 1 callersMethod#maintain

(table: string, names: string[])

src/boss.ts:277

↓ 1 callersMethod#maintainQueueStats

()

src/boss.ts:151

↓ 1 callersMethod#maintainWarnings

()

src/boss.ts:137

↓ 1 callersMethod#markCompleted

(id: string)

src/bam.ts:141

↓ 1 callersMethod#markFailed

(id: string, error: unknown)

src/bam.ts:146

↓ 1 callersMethod#monitor

(table: string, names: string[], heartbeatQueueNames: Set<string>)

src/boss.ts:215

↓ 1 callersMethod#onSupervise

()

src/boss.ts:115

↓ 1 callersMethod#processCommands

()

src/bam.ts:89

↓ 1 callersMethod#registerPromise

( selector: JobSelector<T>, awaitedState: JobSpyState )

src/spy.ts:69

↓ 1 callersMethod#resolveStandard

(table: string, names: string[])

src/navigator.ts:165

↓ 1 callersMethod#settlePerJob

(name: string, jobs: types.Job<T>[], result: unknown)

src/manager.ts:276

↓ 1 callersMethod#storeLocalGroupConfig

(name: string, localGroupConcurrency: number | types.GroupConcurrencyConfig)

src/manager.ts:383

↓ 1 callersMethod#toJobPayload

(name: string, data: object | null, options: types.SendOptions)

src/manager.ts:882

↓ 1 callersMethod#trackJobsActive

(name: string, jobs: types.Job<T>[])

src/manager.ts:192

↓ 1 callersMethod#trackJobsCompleted

(name: string, jobs: types.Job<T>[], result: unknown, affected: number)

src/manager.ts:201

↓ 1 callersMethod#trackJobsSettled

( name: string, completed: { job: types.Job<T>, output: unknown }[], failed: { job: types.Job<T>,

src/manager.ts:255

↓ 1 callersMethod#trackLocalGroupEnd

(name: string, groupedJobs: types.Job<T>[])

src/manager.ts:433

↓ 1 callersMethod#trackLocalGroupStart

( name: string, jobs: types.Job<T>[] )

src/manager.ts:403

↓ 1 callersMethod#warnIfDistributedMisconfigured

()

src/index.ts:163

↓ 1 callersMethod$queryRawUnsafe

(query: string, ...values: any[])

src/adapters/prisma.ts:4

↓ 1 callersMethodaddWorker

(worker: Worker<any>)

src/manager.ts:719

↓ 1 callersFunctionadvisoryLock

(schema: string, key?: string)

src/plans.ts:2474

↓ 1 callersFunctionapplyBamConfig

(config: any)

src/attorney.ts:641

↓ 1 callersFunctionapplyFlowConfig

(config: any)

src/attorney.ts:649

↓ 1 callersFunctionapplyOpsConfig

(config: any)

src/attorney.ts:576

↓ 1 callersFunctionapplyPollingInterval

(config: any)

src/attorney.ts:543

↓ 1 callersFunctionapplyRouteFilter

(routes: RouteEntry[])

packages/proxy/src/index.ts:198

↓ 1 callersFunctionapplyScheduleConfig

(config: any)

src/attorney.ts:624

↓ 1 callersFunctionapplySchemaConfig

(config: types.ConstructorOptions)

src/attorney.ts:440

↓ 1 callersFunctionassertDbReachable

()

test/testHelper.ts:159

↓ 1 callersFunctionassertPostgresObjectName

(name: string)

src/attorney.ts:492

↓ 1 callersFunctionbuildFetchParams

(options: FetchJobOptions)

src/plans.ts:1248

↓ 1 callersFunctionbuildHref

(path: string)

packages/dashboard/app/components/sidebar.tsx:235

↓ 1 callersFunctioncandidateSql

(limit: number)

examples/index-perf/index.ts:107

↓ 1 callersMethodcheck

()

src/contractor.ts:59

↓ 1 callersMethodclearSpies

()

src/index.ts:425

↓ 1 callersFunctioncmdCreate

(args: ReturnType<typeof parseCliArgs>)

src/cli.ts:236

↓ 1 callersFunctioncmdMigrate

(args: ReturnType<typeof parseCliArgs>)

src/cli.ts:265

↓ 1 callersFunctioncmdPlans

(args: ReturnType<typeof parseCliArgs>)

src/cli.ts:358

↓ 1 callersFunctioncmdRollback

(args: ReturnType<typeof parseCliArgs>)

src/cli.ts:323

↓ 1 callersFunctioncmdVersion

(args: ReturnType<typeof parseCliArgs>)

src/cli.ts:213

↓ 1 callersFunctioncoerceJsonScalar

(value: string)

packages/dashboard/app/lib/utils.ts:199

↓ 1 callersFunctioncommitId

()

packages/dashboard/app/components/jobs-filter-bar.tsx:67

↓ 1 callersFunctioncommitMinRetries

()

packages/dashboard/app/components/jobs-filter-bar.tsx:72

↓ 1 callersMethodcomplete

(name: string, id: string | string[], data?: object | null, options: types.CompleteOptions = {})

src/manager.ts:1343

↓ 1 callersMethodcompleteDistributed

(name: string, ids: string[], outputData: any, table: string, db: types.IDatabase, includeQueued?: boolean)

src/manager.ts:1373

↓ 1 callersFunctionconfigureAuth

(app: OpenAPIHono, auth: AuthConfig | undefined, prefix: string)

packages/proxy/src/env.ts:233

↓ 1 callersFunctionconfigureCors

(app: OpenAPIHono, corsConfig: CorsConfig | undefined, prefix: string)

packages/proxy/src/env.ts:250

↓ 1 callersFunctionconfigureFromEnv

(env: ProxyEnv)

packages/proxy/src/env.ts:102

↓ 1 callersFunctioncountByStatus

(summary: BamStatusSummary[])

packages/dashboard/app/routes/migrations.tsx:217

↓ 1 callersFunctioncreateDatabase

()

packages/dashboard/tests/server/helpers.ts:70

↓ 1 callersFunctioncreateEnumJobState

(schema: string)

src/plans.ts:110

↓ 1 callersFunctioncreateIndexJobDependencyParent

(schema: string)

src/plans.ts:248

↓ 1 callersFunctioncreateIndexQueueStats

(schema: string, noCoveringIndex = false)

src/plans.ts:995

↓ 1 callersFunctioncreateIndexWarning

(schema: string)

src/plans.ts:232

↓ 1 callersFunctioncreateQueue

( dbUrl: string, schema: string, queueName: string, options?: Record<string, any> )

packages/dashboard/app/lib/boss.server.ts:144

↓ 1 callersFunctioncreateQueueFunction

(schema: string, noPartitioning = false)

src/plans.ts:456

↓ 1 callersFunctioncreateSchema

(schema: string)

src/plans.ts:106

↓ 1 callersFunctioncreateTableBam

(schema: string)

src/plans.ts:199

↓ 1 callersFunctioncreateTableJob

(schema: string, noPartitioning = false)

src/plans.ts:345

↓ 1 callersFunctioncreateTableJobCommon

(schema: string)

src/plans.ts:416

↓ 1 callersFunctioncreateTableJobDependency

(schema: string)

src/plans.ts:236

← previous next →301–400 of 934, ranked by callers