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

↓ 544 callersMethodstart

()

src/bam.ts:36

↓ 466 callersMethodsend

(...args: any[])

src/index.ts:229

↓ 293 callersMethodfetch

(name: string, options: types.FetchOptions = {})

src/index.ts:270

↓ 291 callersFunctionassertTruthy

(value: T, message?: string)

test/testHelper.ts:77

↓ 206 callersMethodexecuteSql

(text: string, values?: unknown[])

src/types.ts:20

↓ 202 callersMethodcreateQueue

(name: string, options?: Omit<types.Queue, 'name'>)

src/index.ts:355

↓ 177 callersFunctiondelay

(ms: number, error?: string, abortController?: AbortController)

src/tools.ts:19

↓ 170 callersFunctionrender

()

scripts/sync-readme.js:63

↓ 159 callersMethodgetJobById

* @deprecated Use findJobs() instead

src/index.ts:347

↓ 151 callersMethodwork

(...args: any[])

src/index.ts:276

↓ 130 callersFunctioncreateTestQueue

( name: string, options: Parameters<PgBoss['createQueue']>[1] = {} )

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

↓ 124 callersFunctioncn

(...inputs: ClassValue[])

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

↓ 89 callersMethodclose

()

src/types.ts:32

↓ 82 callersMethodquery

(query: string, params?: unknown[])

src/adapters/pglite.ts:8

↓ 76 callersMethodwaitForJobWithId

( id: string, state: JobSpyState )

src/spy.ts:21

↓ 73 callersFunctioncreateProxyService

(options: ProxyOptions)

packages/proxy/src/index.ts:91

↓ 69 callersFunctioncreateBossMock

()

packages/proxy/test/apiCallsTest.ts:8

↓ 64 callersMethodgetDb

()

src/index.ts:461

↓ 63 callersMethodgetSpy

(name: string)

src/index.ts:421

↓ 56 callersFunctionsendTestJob

( queueName: string, data: object = {}, options: Parameters<PgBoss['send']>[2] = {} )

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

↓ 55 callersMethodstop

()

src/bam.ts:47

↓ 53 callersMethodcomplete

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

src/index.ts:332

↓ 48 callersMethodgetQueueStats

(name: string, options?: types.QueueStatsOptions)

src/index.ts:387

↓ 42 callersMethodfail

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

src/index.ts:336

↓ 42 callersMethodsupervise

(value?: string | types.QueueResult[])

src/boss.ts:162

↓ 34 callersMethodflow

(jobs: types.FlowJob[], options?: types.ConnectionOptions)

src/index.ts:264

↓ 32 callersMethodschemaVersion

()

src/index.ts:433

↓ 29 callersFunctionpostJson

(url: string, body?: unknown)

packages/proxy/test/apiCallsTest.ts:25

↓ 29 callersMethodschedule

(name: string, cron: string, data?: object | null, options?: types.ScheduleOptions)

src/index.ts:437

↓ 29 callersMethodupdate

(...args: any[])

src/index.ts:246

↓ 28 callersFunctionpost

( tag: string, method: string, request: Schema, response: z.ZodTypeAny, args: (body: z.infer<Schema>

packages/proxy/src/routes.ts:107

↓ 27 callersMethodfindJobs

(name: string, options?: types.FindJobsOptions)

src/index.ts:351

↓ 26 callersMethodgetQueueCache

(name: string)

src/manager.ts:547

↓ 25 callersFunctiononChange

()

packages/dashboard/app/components/ui/sidebar.tsx:67

↓ 25 callersFunctionresolve

()

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

↓ 24 callersFunctionmakeContext

(testCtx: TestContext)

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

↓ 24 callersFunctionvalidateIdentifier

(name: string)

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

↓ 23 callersFunctionassertKeysMatch

()

packages/proxy/test/typeDriftTest.ts:24

↓ 23 callersMethodcreate

()

src/contractor.ts:73

↓ 23 callersMethodrollback

(version: number)

src/contractor.ts:96

↓ 22 callersFunctiongetDb

({ database, debug }: { database?: string; debug?: boolean } = {})

test/testHelper.ts:186

↓ 20 callersFunctiongetPool

()

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

↓ 20 callersFunctiongetQueues

( dbUrl: string, schema: string, options: { limit?: number; offset?: number; filter?: 'all'

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

↓ 20 callersFunctionparsePageNumber

(value: string | null)

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

↓ 18 callersFunctiongetBoss

()

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

↓ 17 callersFunctioninsertTestBam

( schema: string, options: { name: string; version: number; status?: string; queue?: strin

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

↓ 17 callersMethodresolveFlow

()

src/index.ts:413

↓ 17 callersMethodupsert

(...args: any[])

src/index.ts:252

↓ 16 callersMethodassertDb

(options: types.ConnectionOptions)

src/manager.ts:1959

↓ 16 callersFunctiondropSchema

(schema: string)

test/testHelper.ts:200

↓ 16 callersFunctiongetRecentJobs

( dbUrl: string, schema: string, options: RecentJobsFilterOptions & { limit?: number; offset?: n

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

↓ 16 callersFunctionserializeArrayParam

(values: string[])

src/plans.ts:2447

↓ 15 callersFunctionformatDate

(date: Date)

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

↓ 15 callersMethodgetQueue

(name: string)

src/index.ts:383

↓ 15 callersFunctioninsertTestWarning

( schema: string, type: string, message: string, data: object = {} )

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

↓ 14 callersFunctionfetchTestJob

(queueName: string)

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

↓ 14 callersFunctiongetJobById

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

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

↓ 14 callersFunctiongetQueue

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

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

↓ 14 callersMethodgetSchedules

(name?: string, key?: string)

src/index.ts:445

↓ 13 callersMethodinsert

(name: string, jobs: types.JobInsert[], options?: types.InsertOptions)

src/index.ts:260

↓ 13 callersFunctionparseJobColumns

( params: URLSearchParams, defaultColumns: JobColumn[] = DEFAULT_JOB_COLUMNS )

packages/dashboard/app/lib/job-columns.ts:69

↓ 12 callersMethodclear

()

src/spy.ts:16

↓ 12 callersFunctiongetAll

(schema: string, noPartitioning = false, noCovering = false)

src/migrationStore.ts:794

↓ 12 callersFunctiongetRowCellValue

(row: object, prop: string)

packages/dashboard/app/lib/job-columns.ts:114

↓ 12 callersFunctiongetSchemaDefs

(schemas: string[])

test/testHelper.ts:269

↓ 12 callersMethodmigrate

(version: number)

src/contractor.ts:82

↓ 12 callersMethodstart

()

src/index.ts:109

↓ 11 callersMethod#executeQuery

(query: plans.SqlQuery | string)

src/boss.ts:90

↓ 11 callersMethodaddJob

( id: string, name: string, data: T, state: JobSpyState, output?: object )

src/spy.ts:98

↓ 11 callersFunctionget

( tag: string, method: string, response: z.ZodTypeAny, querySchema?: z.ZodTypeAny, args?: (query: Re

packages/proxy/src/routes.ts:122

↓ 11 callersFunctionisValidIntent

(intent: unknown)

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

↓ 11 callersFunctionminutesAgo

(m: number)

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

↓ 11 callersFunctionparsePlaceholders

(text: string, values?: readonly unknown[])

src/adapters/placeholders.ts:10

↓ 10 callersMethodcancel

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

src/index.ts:300

↓ 10 callersFunctionfetchIndexDefs

(suffix: string)

test/migrationTest.ts:517

↓ 10 callersFunctionformatWarningData

(data: unknown)

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

↓ 10 callersFunctionisValidJobState

(value: string | null)

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

↓ 10 callersMethodoffWork

(name: string, options?: types.OffWorkOptions)

src/index.ts:280

↓ 10 callersFunctionupdateQueueStats

( schema: string, queueName: string, stats: { queuedCount?: number; readyCount?: number; activeCount?: n

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

↓ 9 callersFunctionfromPglite

(pglite: PGliteLike)

src/adapters/pglite.ts:21

↓ 9 callersFunctiongetJobCountFromQueue

( queue: QueueResult, stateFilter: string | null )

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

↓ 9 callersFunctiongetQueueStatsHistory

( dbUrl: string, schema: string, name: string, options: QueueStatsHistoryOptions = {} )

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

↓ 9 callersFunctiongetWarnings

( dbUrl: string, schema: string, options: { type?: string | null; limit?: number; offset?: n

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

↓ 9 callersFunctionjsonFilterPairsToObject

(pairs: JsonFilterPair[])

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

↓ 9 callersFunctionlocked

(schema: string, query: string | string[], key?: string, noAdvisoryLocks?: boolean)

src/plans.ts:2469

↓ 9 callersMethodmapCommandResponse

(ids: string[], result: { rows: any[] } | null)

src/manager.ts:1335

↓ 9 callersFunctionquery

( connectionString: string, text: string, values?: unknown[] )

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

↓ 9 callersMethodupdateQueue

(name: string, options?: types.UpdateQueueOptions)

src/index.ts:371

↓ 8 callersFunctioncancelJob

( dbUrl: string, schema: string, name: string, id: string | string[] )

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

↓ 8 callersFunctioncompleteTestJob

(queueName: string, jobId: string, output?: object)

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

↓ 8 callersFunctionconfigureAuth

(app: Hono)

packages/dashboard/app/lib/auth.server.ts:4

↓ 8 callersFunctiongetInstance

(dbUrl: string, schema: string)

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

↓ 8 callersFunctiongetJobs

( dbUrl: string, schema: string, queueName: string, options: { state?: string | null; limit?:

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

↓ 8 callersFunctiongetTestSchema

(testName: string)

test/cliTest.ts:14

↓ 8 callersFunctionisQueryTimeoutError

(err: unknown)

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

↓ 8 callersMethodmapCompletionIdArg

(id: string | string[], funcName: string)

src/manager.ts:1313

↓ 8 callersFunctionnextCronOccurrence

(cron: string, timezone?: string | null)

packages/dashboard/app/lib/cron.server.ts:7

↓ 8 callersFunctionparseJsonFilterPairs

( searchParams: URLSearchParams, prefix: 'data' | 'output' )

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

↓ 8 callersMethodpublish

(event: string, data?: object, options?: types.SendOptions)

src/index.ts:296

↓ 8 callersFunctionrawListener

(schema: string)

test/listenNotifyTest.ts:12

next →1–100 of 934, ranked by callers