Functions — github.com/WebDevSimplified/job-queue

CodeHub MCPcopy Create free account

hub / github.com/WebDevSimplified/job-queue / functions

Functions17 in github.com/WebDevSimplified/job-queue

⨍ Functions 17 ◇ Types & classes 5

↓ 3 callersMethodexpiringJobIdList

(jobId: string)

src/job-queue/redis-adapter.ts:60

↓ 2 callersMethodaddActiveJob

src/job-queue/redis-adapter.ts:64

↓ 2 callersMethodmoveJobToActive

(jobId: string)

src/job-queue/redis-adapter.ts:72

↓ 1 callersMethodcheckForExpiredJobs

src/job-queue/redis-adapter.ts:98

↓ 1 callersMethodgetOrWaitForJob

src/job-queue/redis-adapter.ts:25

↓ 1 callersMethodlistenForExpiredJobs

src/job-queue/redis-adapter.ts:84

↓ 1 callersMethodpush

src/job-queue/redis-adapter.ts:30

↓ 1 callersFunctionsendEmail

(email: string, body: string)

src/index.ts:64

↓ 1 callersMethodstart

src/job-queue/worker.ts:20

MethodactiveJobsQueue

src/job-queue/redis-adapter.ts:45

( job: Omit<Job<T>, "id" | "options"> & { options?: OptionalJobOptions id?: string } )

src/job-queue/queue.ts:24

Functionconstructor

( queueName: string, options: QueueOptions = { retryAttempts: 10, retryDelay: 1000 } )

src/job-queue/queue.ts:16

Methodconstructor

(redisUrl: string, queueName: string, options?: QueueOptions)

src/job-queue/redis-adapter.ts:10

Methodconstructor

( queue: Queue<T>, processJob: (job: Job<T>) => Promise<void>, { concurrency = 1 } = {} )

src/job-queue/worker.ts:10

MethoddelayedJobIdsQueue

src/job-queue/redis-adapter.ts:55

MethoddelayedJobsList

src/job-queue/redis-adapter.ts:50

src/job-queue/redis-adapter.ts:21