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

↓ 3 callersFunctioncreateIndexJobPolicySingleton

(schema: string)

src/plans.ts:677

↓ 3 callersFunctioncreateIndexJobPolicyStately

(schema: string)

src/plans.ts:681

↓ 3 callersFunctioncreateIndexJobThrottle

(schema: string)

src/plans.ts:685

↓ 3 callersFunctioncreatePrimaryKeyJob

(schema: string)

src/plans.ts:659

↓ 3 callersFunctioncreateQueueForeignKeyJob

(schema: string, noPartitioning = false)

src/plans.ts:663

↓ 3 callersFunctioncreateQueueForeignKeyJobDeadLetter

(schema: string, noPartitioning = false)

src/plans.ts:668

↓ 3 callersFunctiondeleteOldWarnings

( dbUrl: string, schema: string, olderThanDays: number = 30 )

packages/dashboard/app/lib/queries.server.ts:630

↓ 3 callersFunctionemitAndPersistWarning

( ctx: WarningContext, type: string, message: string, data: object )

src/warning.ts:19

↓ 3 callersFunctionencodeBasicAuth

(username: string, password: string)

packages/dashboard/tests/server/auth.test.ts:5

↓ 3 callersFunctionerrorResponse

( context: Context, status: Status, message: string )

packages/proxy/src/index.ts:79

↓ 3 callersMethodexec

(query: string)

src/adapters/pglite.ts:9

↓ 3 callersFunctionexplain

(db: Db, _label: string, sql: string, values: unknown[], quiet = false)

examples/index-perf/index.ts:176

↓ 3 callersMethodfail

(name: string, id: string | string[], data?: any, options: types.ConnectionOptions = {})

src/manager.ts:1381

↓ 3 callersFunctionfailJobs

(schema: string, table: string, where: string, output: string)

src/plans.ts:1777

↓ 3 callersFunctionfailJobsBody

(schema: string, table: string, where: string, output: string, forceTerminal = false)

src/plans.ts:1791

↓ 3 callersFunctionflatten

(schema: string, commands: string[], version: number, noAdvisoryLocks?: boolean)

src/migrationStore.ts:63

↓ 3 callersFunctionformatDateWithSeconds

(date: Date)

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

↓ 3 callersFunctionformatDuration

(seconds: number | null | undefined)

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

↓ 3 callersFunctionformatTimestamp

(value: Date | null)

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

↓ 3 callersFunctionget

(v: string)

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

↓ 3 callersFunctiongetPartitionTables

(db: types.IDatabase, schema: string)

src/cli.ts:191

↓ 3 callersFunctiongetProblemQueues

( dbUrl: string, schema: string, limit: number = 10 )

packages/dashboard/app/lib/queries.server.ts:320

↓ 3 callersFunctiongetProblemQueuesCount

( dbUrl: string, schema: string )

packages/dashboard/app/lib/queries.server.ts:304

↓ 3 callersFunctiongetQueueNames

( dbUrl: string, schema: string )

packages/dashboard/app/lib/queries.server.ts:493

↓ 3 callersFunctiongetQueueStats

( dbUrl: string, schema: string )

packages/dashboard/app/lib/queries.server.ts:775

↓ 3 callersFunctiongetSchedule

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

packages/dashboard/app/lib/queries.server.ts:989

↓ 3 callersFunctiongetScheduleCount

(dbUrl: string, schema: string)

packages/dashboard/app/lib/queries.server.ts:981

↓ 3 callersFunctiongetSystemTheme

()

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

↓ 3 callersMethodgetWorkers

()

src/manager.ts:727

↓ 3 callersFunctionhandleSearch

(value: string)

packages/dashboard/app/routes/queues._index.tsx:110

↓ 3 callersMethodisInstalled

()

src/index.ts:429

↓ 3 callersFunctionloadConfigFile

(configPath?: string)

src/cli.ts:81

↓ 3 callersMethodnotify

()

src/worker.ts:122

↓ 3 callersFunctionnotifyChannelSql

(schema: string)

src/plans.ts:644

↓ 3 callersMethodnotifyWorker

(workerId: string)

src/index.ts:284

↓ 3 callersFunctionparseBooleanOrUndefined

(value: string | undefined)

packages/proxy/src/env.ts:69

↓ 3 callersFunctionparseSearchParamPairs

( searchParams: URLSearchParams, paramName: string, separator = '|' )

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

↓ 3 callersFunctionreadHistory

()

test/readyHistoryTest.ts:15

↓ 3 callersFunctionreadyHistoryColumn

(dbUrl: string, schema: string)

packages/dashboard/app/lib/queries.server.ts:202

↓ 3 callersMethodreinsertFailedJobs

(tx: types.IDatabase, table: string, jobs: any[], outputData: any, outputById?: Map<string, any>, forceTermina

src/manager.ts:1489

↓ 3 callersFunctionrenderRow

(children: React.ReactNode)

packages/dashboard/tests/frontend/table.test.tsx:76

↓ 3 callersFunctionschedule

( dbUrl: string, schema: string, name: string, cron: string, data?: object, options?: ScheduleOpti

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

↓ 3 callersFunctionsubmitAction

(intent: string)

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

↓ 3 callersMethodtouch

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

src/index.ts:340

↓ 3 callersFunctiontrySetTimestamp

(schema: string, column: string, seconds: number)

src/plans.ts:742

↓ 3 callersMethodunschedule

(name: string, key?: string)

src/index.ts:441

↓ 3 callersFunctionuseTheme

()

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

↓ 3 callersFunctionvalidateExpirationConfig

(config: any)

src/attorney.ts:516

↓ 3 callersFunctionvalidateHeartbeatConfig

(config: any)

src/attorney.ts:531

↓ 3 callersFunctionvalidateRetentionConfig

(config: any)

src/attorney.ts:511

↓ 3 callersFunctionvalidateRetryConfig

(config: any)

src/attorney.ts:523

↓ 3 callersMethodwaitForJob

( selector: JobDataSelector<T>, state: JobSpyState )

src/spy.ts:17

↓ 3 callersFunctionwithFixedDataOptions

(args: unknown[], data?: unknown, options?: unknown, tail: unknown[] = [])

packages/proxy/src/routes.ts:82

↓ 2 callersMethod#cleanupLocalGroupTracking

(name: string)

src/manager.ts:393

↓ 2 callersMethod#cloneJob

(job: SpyJob<T>)

src/spy.ts:88

↓ 2 callersMethod#failWithOutputs

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

src/manager.ts:353

↓ 2 callersMethod#onPoll

()

src/navigator.ts:79

↓ 2 callersMethod#onPoll

()

src/bam.ts:59

↓ 2 callersMethod#processJobs

( name: string, jobs: types.Job<T>[], callback: types.WorkHandler<T>, worker?: Worker<T>,

src/manager.ts:441

↓ 2 callersMethod#resolve

()

src/navigator.ts:125

↓ 2 callersMethod#toUpdatePayload

(data: object | null | undefined, options: types.UpdateOptions)

src/manager.ts:979

↓ 2 callersMethod#trackJobsFailed

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

src/manager.ts:234

↓ 2 callersFunctionappendSearchParamPairs

( searchParams: URLSearchParams, paramName: string, pairs: SearchParamPair[], separator = '|' )

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

↓ 2 callersFunctionattachShutdownListeners

( signals: Signal[], adapter: ShutdownAdapter<Signal>, handler: ShutdownHandler )

packages/proxy/src/shutdown.ts:33

↓ 2 callersFunctionbuildJobColumnProjections

(columns: JobColumn[])

packages/dashboard/app/lib/queries.server.ts:141

↓ 2 callersFunctionbuildJobListSelect

(jobColumns: JobColumn[] = [])

packages/dashboard/app/lib/queries.server.ts:158

↓ 2 callersFunctionbuildRecentJobsWhere

( schema: string, options: RecentJobsFilterOptions )

packages/dashboard/app/lib/queries.server.ts:386

↓ 2 callersFunctionbuildViewParams

( jobColumns: JobColumn[] = DEFAULT_JOB_COLUMNS )

packages/dashboard/app/routes/jobs.tsx:202

↓ 2 callersMethodcacheClockSkew

()

src/timekeeper.ts:111

↓ 2 callersFunctioncleanup

()

packages/dashboard/app/lib/db.server.ts:93

↓ 2 callersFunctionclearReadyHistoryColumnCache

()

packages/dashboard/app/lib/queries.server.ts:179

↓ 2 callersFunctioncompleteJobsUpdate

(schema: string, table: string, includeQueued?: boolean)

src/plans.ts:1460

↓ 2 callersFunctionconfigureLogging

(logFormat: LogFormat | undefined)

packages/proxy/src/env.ts:216

↓ 2 callersFunctioncountJobs

(state: string)

test/completeTest.ts:29

↓ 2 callersFunctioncreateHonoApp

({ build, mode, serveStaticAssets = false }: CreateHonoAppOptions)

packages/dashboard/app/server.ts:46

↓ 2 callersFunctiondrainBam

()

test/migrationTest.ts:533

↓ 2 callersFunctiondropSchema

(schema: string)

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

↓ 2 callersMethodemitWip

(name: string)

src/manager.ts:731

↓ 2 callersMethodexpireJobsDistributed

(table: string, select: plans.SqlQuery, outputData: any)

src/manager.ts:1470

↓ 2 callersFunctionexplainPartitions

(pool, query)

scripts/seed-queue-stats.js:182

↓ 2 callersFunctionfailTestJob

(queueName: string, jobId: string, error?: Error)

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

↓ 2 callersFunctionfromLocalInput

(value: string)

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

↓ 2 callersMethodgetBamStatus

()

src/index.ts:449

↓ 2 callersFunctiongetPgliteInstance

()

test/testHelper.ts:37

↓ 2 callersFunctiongetQueueStats

(schema: string, table: string, queues: string[])

src/plans.ts:2325

↓ 2 callersMethodgetQueues

(names?: string | string[])

src/manager.ts:1684

↓ 2 callersFunctiongetRollbackPlans

(schema?: string, version?: number)

src/index.ts:35

↓ 2 callersMethodgetWipData

(options: { includeInternal?: boolean } = {})

src/manager.ts:742

↓ 2 callersFunctionhandleFilterChange

(newFilter: string)

packages/dashboard/app/routes/queues._index.tsx:121

↓ 2 callersFunctionhandlePageChange

(newPage: number)

packages/dashboard/app/routes/queues._index.tsx:104

↓ 2 callersFunctionhandler

()

packages/proxy/test/apiCallsTest.ts:1100

↓ 2 callersFunctionindexNames

()

test/cliTest.ts:328

↓ 2 callersFunctionindexNames

()

test/migrationTest.ts:805

↓ 2 callersFunctioninit

(config: (ConstructorOptions & { schema: string }) | (Partial<ConstructorOptions> & { testKey?: string; noDefa

test/queueStatsTest.ts:11

↓ 2 callersMethodisBamWorking

()

src/index.ts:395

↓ 2 callersMethodisCheckingSkew

()

src/index.ts:403

↓ 2 callersMethodisInstalled

()

src/contractor.ts:40

↓ 2 callersMethodisMaintaining

()

src/index.ts:391

↓ 2 callersFunctionlockedChildrenCte

(schema: string)

src/plans.ts:1478

↓ 2 callersFunctionmigrateCommands

(schema: string, version: number, migrations?: types.Migration[], noAdvisoryLocks?: boolean, options: MigrateO

src/migrationStore.ts:93

← previous next →201–300 of 934, ranked by callers