HyperdriveJobQueue
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:43
Type Parameters
섹션 제목: “Type Parameters”T
Implements
섹션 제목: “Implements”JobQueue<T>
Constructors
섹션 제목: “Constructors”Constructor
섹션 제목: “Constructor”new HyperdriveJobQueue<
T>(client,tableName?):HyperdriveJobQueue<T>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:46
Parameters
섹션 제목: “Parameters”client
섹션 제목: “client”tableName?
섹션 제목: “tableName?”string = "kmsg_jobs"
Returns
섹션 제목: “Returns”HyperdriveJobQueue<T>
Methods
섹션 제목: “Methods”cleanupTerminal()
섹션 제목: “cleanupTerminal()”cleanupTerminal(
statuses?):Promise<number>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:323
Parameters
섹션 제목: “Parameters”statuses?
섹션 제목: “statuses?”JobStatus[] = ...
Returns
섹션 제목: “Returns”Promise<number>
Implementation of
섹션 제목: “Implementation of”clear()
섹션 제목: “clear()”clear():
Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:318
Returns
섹션 제목: “Returns”Promise<void>
Implementation of
섹션 제목: “Implementation of”close()
섹션 제목: “close()”close():
Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:354
Returns
섹션 제목: “Returns”Promise<void>
complete()
섹션 제목: “complete()”complete(
jobId,_result?):Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:198
Parameters
섹션 제목: “Parameters”jobId
섹션 제목: “jobId”string
_result?
섹션 제목: “_result?”any
Returns
섹션 제목: “Returns”Promise<void>
Implementation of
섹션 제목: “Implementation of”dequeue()
섹션 제목: “dequeue()”dequeue():
Promise<Job<T> |undefined>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:136
Returns
섹션 제목: “Returns”Promise<Job<T> | undefined>
Implementation of
섹션 제목: “Implementation of”enqueue()
섹션 제목: “enqueue()”enqueue(
type,data,options?):Promise<Job<T>>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:67
Parameters
섹션 제목: “Parameters”type
섹션 제목: “type”string
data
섹션 제목: “data”T
options?
섹션 제목: “options?”{ delay?: number; maxAttempts?: number; metadata?: Record<string, any>; priority?: number; } | undefined
Returns
섹션 제목: “Returns”Promise<Job<T>>
Implementation of
섹션 제목: “Implementation of”fail()
섹션 제목: “fail()”fail(
jobId,error,retry?):Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:212
Parameters
섹션 제목: “Parameters”jobId
섹션 제목: “jobId”string
error
섹션 제목: “error”string | Error
retry?
섹션 제목: “retry?”JobRetryDirective = ...
Returns
섹션 제목: “Returns”Promise<void>
Implementation of
섹션 제목: “Implementation of”getJob()
섹션 제목: “getJob()”getJob(
jobId):Promise<Job<T> |undefined>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:288
Parameters
섹션 제목: “Parameters”jobId
섹션 제목: “jobId”string
Returns
섹션 제목: “Returns”Promise<Job<T> | undefined>
Implementation of
섹션 제목: “Implementation of”init()
섹션 제목: “init()”init():
Promise<void>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:51
Returns
섹션 제목: “Returns”Promise<void>
peek()
섹션 제목: “peek()”peek():
Promise<Job<T> |undefined>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:257
Returns
섹션 제목: “Returns”Promise<Job<T> | undefined>
Implementation of
섹션 제목: “Implementation of”remove()
섹션 제목: “remove()”remove(
jobId):Promise<boolean>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:302
Parameters
섹션 제목: “Parameters”jobId
섹션 제목: “jobId”string
Returns
섹션 제목: “Returns”Promise<boolean>
Implementation of
섹션 제목: “Implementation of”size()
섹션 제목: “size()”size():
Promise<number>
Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:274
Returns
섹션 제목: “Returns”Promise<number>