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

FunctioncompleteJobsDistributed

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

src/plans.ts:2055

FunctioncompleteJobsWithOutputs

(schema: string, table: string)

src/plans.ts:1516

FunctioncompleteJobsWithOutputsDistributed

(schema: string, table: string)

src/plans.ts:1539

Methodconstructor

(value: string | types.ConstructorOptions)

src/index.ts:56

Methodconstructor

(db: types.IDatabase, config: types.ResolvedConstructorOptions)

src/manager.ts:104

Methodconstructor

( db: types.IDatabase, manager: Manager, config: types.ResolvedConstructorOptions )

src/navigator.ts:33

Methodconstructor

(config: types.DatabaseOptions)

src/db.ts:13

Methodconstructor

( db: types.IDatabase, config: types.ResolvedConstructorOptions )

src/bam.ts:20

Methodconstructor

(db: types.IDatabase, manager: Manager, config: types.ResolvedConstructorOptions)

src/notifier.ts:25

Methodconstructor

(db: types.IDatabase, manager: Manager, config: types.ResolvedConstructorOptions)

src/timekeeper.ts:45

Methodconstructor

({ id, workId, name, options, resolveInterval, fetch, onFetch, onError }: WorkerOptions<T>)

src/worker.ts:48

Methodconstructor

( db: types.IDatabase, manager: Manager, config: types.ResolvedConstructorOptions )

src/boss.ts:37

Methodconstructor

(db: types.IDatabase, config: types.ResolvedConstructorOptions)

src/contractor.ts:29

FunctioncopyId

()

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

FunctioncountJobs

(schema: string, table: string, where: string, values?: any[])

test/testHelper.ts:213

Functioncreate

(schema: string, version: number, options?: CreateOptions)

src/plans.ts:59

FunctioncreateDenoShutdownAdapter

()

packages/proxy/src/shutdown.ts:22

FunctioncreateKnownJobColumn

(path: string)

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

FunctioncreateQueue

(schema: string, name: string, options: unknown, noAdvisoryLocks?: boolean)

src/plans.ts:627

MethodcreateQueue

(name: string, options: Omit<types.Queue, 'name'> & { name?: string } = {})

src/manager.ts:1647

FunctioncreateWarningTable

(schema: string)

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

MethodcreateWorker

(workerId: string, workId: string)

src/manager.ts:659

FunctiondeadLetterJobsByIdWithOutputs

(schema: string, table: string)

src/plans.ts:1993

FunctiondecrementDependents

(schema: string)

src/plans.ts:2066

FunctiondeleteAllJobs

(schema: string, table: string)

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

src/manager.ts:1566

FunctiondeleteJobsById

(schema: string, table: string)

src/plans.ts:829

FunctiondeleteJobsByIds

(schema: string, table: string)

src/plans.ts:2046

FunctiondeleteJobsToFail

(schema: string, table: string)

src/plans.ts:2014

FunctiondeleteOldQueueStats

(schema: string, days: number)

src/plans.ts:1069

FunctiondeleteOldWarnings

(schema: string, days: number)

src/plans.ts:949

FunctiondeleteQueue

(schema: string, name: string, noAdvisoryLocks?: boolean)

FunctiondeleteQueuedJobs

(schema: string, table: string)

src/plans.ts:841

MethoddeleteQueuedJobs

(name: string)

src/manager.ts:1751

FunctiondeleteStoredJobs

(schema: string, table: string)

src/plans.ts:845

MethoddeleteStoredJobs

(name: string)

src/manager.ts:1758

Functiondeletion

(schema: string, table: string, queues: string[], noAdvisoryLocks?: boolean)

src/plans.ts:2225

FunctiondropOldQueueStatsPartitions

(schema: string, days: number)

src/plans.ts:1039

Functionexec

(text: string)

test/pgliteAdapterTest.ts:13

(sql: string, values: any[])

test/cancelTest.ts:62

FunctionexecuteSql

(sql, values)

test/failureTest.ts:159

FunctionexecuteSql

(sql, values)

test/fetchTest.ts:172

FunctionexecuteSql

(sql, values)

test/resumeTest.ts:48

(sql: string, values: any[])

test/completeTest.ts:106

FunctionexecuteSql

(sql: string, values: any[])

test/configTest.ts:90

FunctionexecuteSql

(sql, values)

test/insertTest.ts:92

FunctionexecuteSql

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

src/adapters/kysely.ts:14

FunctionexecuteSql

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

src/adapters/pglite.ts:41

FunctionexecuteSql

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

src/adapters/prisma.ts:9

FunctionexecuteSql

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

src/adapters/knex.ts:11

FunctionexecuteSql

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

src/adapters/drizzle.ts:33

MethodexecuteSql

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

src/db.ts:42

FunctionfailJobsByHeartbeat

(schema: string, table: string, queues: string[], noAdvisoryLocks?: boolean)

src/plans.ts:1752

FunctionfailJobsById

(schema: string, table: string)

src/plans.ts:1735

FunctionfailJobsByIdWithOutputs

(schema: string, table: string)

src/plans.ts:1975

FunctionfailJobsByTimeout

(schema: string, table: string, queues: string[], noAdvisoryLocks?: boolean)

(options: FetchJobOptions, noSkipLocked = false)

src/plans.ts:1324

FunctionfetchWithRetry

(boss: PgBoss, name: string, options?: FetchOptions, attempts = 20)

test/testHelper.ts:258

FunctionfindJobs

(schema: string, where: string, values?: any[])

test/testHelper.ts:206

FunctionfindJobs

(schema: string, table: string, options: { queued: boolean, byKey: boolean, byData: boolean, byId: boolean })

src/plans.ts:2485

MethodfindJobs

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

src/manager.ts:1917

Methodflow

(jobs: types.FlowJob[], options: types.ConnectionOptions = {})

src/manager.ts:1144

FunctionforceFetchLnWorkers

()

test/notifierTest.ts:10

FunctiongetBamEntries

FunctiongetBlockedKeys

(schema: string, table: string)

(value: string | types.ConstructorOptions)

src/attorney.ts:414

FunctiongetDependencies

(schema: string)

src/plans.ts:2545

MethodgetDependencies

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

src/manager.ts:1943

FunctiongetDependents

(schema: string)

src/plans.ts:2553

MethodgetDependents

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

src/manager.ts:1951

FunctiongetJobById

(schema: string, table: string)

src/plans.ts:2518

MethodgetJobById

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

src/manager.ts:1889

FunctiongetNextBamCommand

(schema: string)

src/plans.ts:2589

MethodgetQueueStats

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

src/manager.ts:1793

FunctiongetQueueStatsCache

(schema: string)

src/plans.ts:1090

FunctiongetQueueStatsHistory

(schema: string)

src/plans.ts:1107

FunctiongetQueueStatsHistoryBucketed

(schema: string, aggregate: 'max' | 'min' | 'avg', mode: 'bucket' | 'auto')

src/plans.ts:1149

FunctiongetQueues

(schema: string, names?: string[])

src/plans.ts:793

FunctiongetQueuesForEvent

FunctiongetSchedulesByQueue

(schema: string)

src/plans.ts:861

FunctiongetSchedulesByQueueAndKey

(schema: string)

src/plans.ts:865

FunctiongetShareUrl

(columns: JobColumn[])

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

MethodgetSpy

(name: string)

src/manager.ts:119

FunctiongetStoredColorTheme

()

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

FunctiongetTestConnectionString

()

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

FunctiongetTestSchema

()

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

FunctiongetWarningsCount

(schema: string)

src/plans.ts:941

FunctionhandleApplyColumns

()

packages/dashboard/app/components/job-columns-editor.tsx:49

← previous next →701–800 of 934, ranked by callers