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

↓ 8 callersFunctiontriggerBamPoll

(schema: string)

test/bamTest.ts:22

↓ 8 callersFunctionwaitForBamEvent

(boss: any, name: string, status: string, timeoutMs = 5000)

test/bamTest.ts:29

↓ 7 callersMethod#promoteEvents

(emitter: types.EventsMixin)

src/index.ts:103

↓ 7 callersFunctionappendJobColumns

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

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

↓ 7 callersFunctionbuildParams

( filters: JobsFilters, jobColumns: JobColumn[] = DEFAULT_JOB_COLUMNS )

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

↓ 7 callersMethoddeleteQueue

(name: string)

src/index.ts:375

↓ 7 callersFunctionfakeDb

(over: Partial<IDatabase>)

test/notifierTest.ts:12

↓ 7 callersFunctionformatTimeUntil

(date: Date)

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

↓ 7 callersFunctionfromDrizzle

(tx: DrizzleTransactionLike, sql: DrizzleSqlTagLike)

src/adapters/drizzle.ts:31

↓ 7 callersFunctiongetBamEntries

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

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

↓ 7 callersFunctiongetQueueCount

( dbUrl: string, schema: string, options: { filter?: 'all' | 'attention' | 'partitioned'; search

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

↓ 7 callersFunctionisValidBamStatus

(value: string | null)

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

↓ 7 callersFunctionisValidWarningType

(value: string | null)

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

↓ 7 callersFunctionparseFiltersFromUrl

(searchParams: URLSearchParams)

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

↓ 7 callersFunctionrenderWithRouter

(initialRoute = '/')

packages/dashboard/tests/frontend/sidebar.test.tsx:8

↓ 7 callersFunctionresolveAggregate

(aggregate?: string | null)

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

↓ 7 callersMethodsendDebounced

(name: string, data: object | null, options: types.SendOptions | null, seconds: number, key?: string)

src/index.ts:256

↓ 6 callersMethodabort

()

src/worker.ts:141

↓ 6 callersFunctionbuildSearchParams

( filters: JobsFilters )

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

↓ 6 callersFunctioncreateDb

(config: types.DatabaseOptions)

src/cli.ts:169

↓ 6 callersMethoddeleteAllJobs

(name?: string)

src/index.ts:328

↓ 6 callersFunctiongetQueryTimeoutMs

()

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

↓ 6 callersFunctiongetSchedules

( dbUrl: string, schema: string, options: { limit?: number; offset?: number; } & SortOptions =

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

↓ 6 callersFunctioninsertBamCommand

(schema: string, name: string, command: string)

test/bamTest.ts:13

↓ 6 callersFunctionjobColumnPathToSql

(path: string)

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

↓ 6 callersFunctionmetricsHref

(series: string)

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

↓ 6 callersFunctionmigrate

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

src/migrationStore.ts:130

↓ 6 callersMethodredrive

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

src/index.ts:316

↓ 6 callersFunctionseedStats

(q: string, rows: Array<{ ago: number, queued?: number, total?: number }>)

test/queueStatsHistoryTest.ts:174

↓ 6 callersFunctionsetParam

(updates: Record<string, string | null>)

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

↓ 6 callersFunctionsetTheme

(newTheme: Theme)

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

↓ 6 callersFunctionunwrapSQLResult

* When sql contains multiple queries, result is an array of objects with rows property * This function unwraps the result into a single object with r

src/tools.ts:7

↓ 6 callersMethodwithTransaction

(fn: (db: types.IDatabase) => Promise<T>)

src/db.ts:142

↓ 5 callersMethod#notifyEnabled

(queueNotify: boolean | undefined)

src/manager.ts:793

↓ 5 callersFunctioncreateFakePglite

()

test/pgliteAdapterTest.ts:5

↓ 5 callersFunctiondeleteJob

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

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

↓ 5 callersMethoddeleteJob

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

src/index.ts:312

↓ 5 callersMethodensureTransaction

(db: types.IDatabase, fn: (tx: types.IDatabase) => Promise<T>)

src/manager.ts:1365

↓ 5 callersMethodexecute

(query: unknown)

src/adapters/drizzle.ts:6

↓ 5 callersFunctionformatTimeAgo

(date: Date)

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

↓ 5 callersFunctionfromKnex

(trx: KnexTransactionLike)

src/adapters/knex.ts:9

↓ 5 callersMethodgetBamEntries

()

src/index.ts:455

↓ 5 callersMethodgetBlockedKeys

(name: string)

src/index.ts:359

↓ 5 callersFunctiongetConnectionConfig

(args: ReturnType<typeof parseCliArgs>)

src/cli.ts:107

↓ 5 callersFunctiongetCount

()

test/queueTest.ts:153

↓ 5 callersFunctiongetMigrationPlans

(schema?: string, version?: number, options?: { partitionTables?: string[] })

src/index.ts:31

↓ 5 callersFunctiongetQueueStatsCollectionStatus

( dbUrl: string, schema: string )

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

↓ 5 callersMethodgetQueues

(names?: string[])

src/index.ts:379

↓ 5 callersFunctiongetRecentJobsCount

( dbUrl: string, schema: string, options: RecentJobsFilterOptions = {} )

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

↓ 5 callersFunctiongetWarningCount

( dbUrl: string, schema: string, type?: string | null )

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

↓ 5 callersFunctioninsertQueueStatsHistory

( schema: string, queueName: string, rows: Array<{ capturedOn: Date; deferredCount?: number;

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

↓ 5 callersMethodlisten

* Optional capability for LISTEN/NOTIFY support. When present, pg-boss can hold a * dedicated session-pinned connection to receive notifications. T

src/types.ts:28

↓ 5 callersMethodmapCompletionDataArg

(data?: unknown)

src/manager.ts:1325

↓ 5 callersFunctionnext

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

src/migrationStore.ts:80

↓ 5 callersFunctionrenderHeader

(initial = '')

packages/dashboard/tests/frontend/sortable-header.test.tsx:6

↓ 5 callersFunctionresumeJob

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

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

↓ 5 callersMethodsubscribe

(event: string, name: string)

src/index.ts:288

↓ 5 callersFunctionuseSidebar

()

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

↓ 5 callersFunctionwithOptionalDataOptions

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

packages/proxy/src/routes.ts:72

↓ 5 callersFunctionwithOptionalOptions

(args: unknown[], options?: unknown)

packages/proxy/src/routes.ts:90

↓ 4 callersFunctionassertObjectName

(value: string, name: string = 'Name')

src/attorney.ts:62

↓ 4 callersFunctionbuildOrderBy

( { sort, dir }: SortOptions, columns: Record<string, string>, defaultOrderBy: string, tiebreak?: stri

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

↓ 4 callersMethodcreateJob

(request: types.Request)

src/manager.ts:924

↓ 4 callersFunctioncreateJobColumn

(path: string, name = '')

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

↓ 4 callersFunctioncreateProxyServerNode

(options: ProxyNodeOptions = {})

packages/proxy/src/node.ts:25

↓ 4 callersFunctiondefaultJobColumnName

(path: string)

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

↓ 4 callersFunctionfromKysely

(trx: KyselyTransactionLike)

src/adapters/kysely.ts:12

↓ 4 callersFunctionfromPrisma

(tx: PrismaTransactionLike)

src/adapters/prisma.ts:7

↓ 4 callersFunctiongetBamCount

( dbUrl: string, schema: string, status?: string | null )

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

↓ 4 callersFunctiongetBamStatusSummary

( dbUrl: string, schema: string )

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

↓ 4 callersFunctiongetConfig

(options: Partial<ConstructorOptions> & { testKey?: string } = {})

test/testHelper.ts:94

↓ 4 callersFunctiongetSchemaVersion

(db: types.IDatabase, schema: string)

src/cli.ts:200

↓ 4 callersFunctiongetTopQueues

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

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

↓ 4 callersMethodnext

(version: number)

src/contractor.ts:91

↓ 4 callersMethodopen

()

src/db.ts:29

↓ 4 callersFunctionpairsEqual

(a: JsonFilterPair[], b: JsonFilterPair[])

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

↓ 4 callersFunctionresolveBasePath

(raw: string | undefined)

packages/dashboard/app/lib/base-path.ts:14

↓ 4 callersMethodresume

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

src/index.ts:304

↓ 4 callersFunctionretryJob

( dbUrl: string, schema: string, queueName: string, jobId: string )

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

↓ 4 callersFunctionseedThree

()

test/updateTest.ts:103

↓ 4 callersMethodsendThrottled

(name: string, data: object | null, options: types.SendOptions | null, seconds: number, key?: string)

src/index.ts:240

↓ 4 callersFunctionsetQueryParams

(params: URLSearchParams)

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

↓ 4 callersFunctionshutdown

(signal: string)

packages/dashboard/scripts/worker.ts:68

↓ 4 callersFunctionstartBoss

(extra: Record<string, any> = {})

test/pgliteTest.ts:17

↓ 4 callersMethodstop

(options: types.StopOptions = {})

src/index.ts:181

↓ 4 callersFunctionstopBamWorker

()

packages/dashboard/tests/server/queries.test.ts:1094

↓ 4 callersFunctionsubmitAction

(intent: string)

packages/dashboard/app/routes/queues.$name.jobs.$jobId.tsx:102

↓ 4 callersFunctiontrueFlags

(config: any)

test/configTest.ts:13

↓ 4 callersMethodunsubscribe

(event: string, name: string)

src/index.ts:292

↓ 3 callersMethod#evictQueueCache

(name: string)

src/manager.ts:567

↓ 3 callersFunctioncloseAllPools

()

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

↓ 3 callersMethodconnect

()

src/db.ts:84

↓ 3 callersMethodconstructionPlans

(schema = plans.DEFAULT_SCHEMA, options = { createSchema: true })

src/contractor.ts:10

↓ 3 callersFunctioncreateCheckConstraintKeyStrictFifo

(schema: string)

src/plans.ts:706

↓ 3 callersFunctioncreateIndexJobBlocking

(schema: string)

src/plans.ts:718

↓ 3 callersFunctioncreateIndexJobFetch

(schema: string, noCoveringIndex = false)

src/plans.ts:689

↓ 3 callersFunctioncreateIndexJobGroupConcurrency

(schema: string)

src/plans.ts:710

↓ 3 callersFunctioncreateIndexJobPolicyExclusive

(schema: string)

src/plans.ts:698

↓ 3 callersFunctioncreateIndexJobPolicyKeyStrictFifo

(schema: string)

src/plans.ts:702

↓ 3 callersFunctioncreateIndexJobPolicyShort

(schema: string)

src/plans.ts:673

← previous next →101–200 of 934, ranked by callers