QueueManager
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:15
Extends
섹션 제목: “Extends”EventEmitter
Constructors
섹션 제목: “Constructors”Constructor
섹션 제목: “Constructor”new QueueManager(
config?):QueueManager
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:32
Parameters
섹션 제목: “Parameters”config?
섹션 제목: “config?”Partial<QueueConfig> = {}
Returns
섹션 제목: “Returns”QueueManager
Overrides
섹션 제목: “Overrides”EventEmitter.constructor
Methods
섹션 제목: “Methods”addListener()
섹션 제목: “addListener()”addListener(
eventName,listener):this
Defined in: packages/webhook/src/shared/event-emitter.ts:16
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.addListener
cleanupExpiredJobs()
섹션 제목: “cleanupExpiredJobs()”cleanupExpiredJobs():
Promise<number>
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:253
만료된 작업 정리
Returns
섹션 제목: “Returns”Promise<number>
clear()
섹션 제목: “clear()”clear():
Promise<void>
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:227
큐 비우기
Returns
섹션 제목: “Returns”Promise<void>
dequeue()
섹션 제목: “dequeue()”dequeue():
Promise<DispatchJob|null>
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:102
우선순위에 따라 작업 추출
Returns
섹션 제목: “Returns”Promise<DispatchJob | null>
dequeueFromPriority()
섹션 제목: “dequeueFromPriority()”dequeueFromPriority(
priority):Promise<DispatchJob|null>
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:132
특정 우선순위 큐에서 작업 추출
Parameters
섹션 제목: “Parameters”priority
섹션 제목: “priority”number
Returns
섹션 제목: “Returns”Promise<DispatchJob | null>
emit()
섹션 제목: “emit()”emit(
eventName, …args):boolean
Defined in: packages/webhook/src/shared/event-emitter.ts:44
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
args
섹션 제목: “args”…unknown[]
Returns
섹션 제목: “Returns”boolean
Inherited from
섹션 제목: “Inherited from”EventEmitter.emit
enqueue()
섹션 제목: “enqueue()”enqueue(
job):Promise<boolean>
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:54
작업을 큐에 추가
Parameters
섹션 제목: “Parameters”job
섹션 제목: “job”Returns
섹션 제목: “Returns”Promise<boolean>
getStats()
섹션 제목: “getStats()”getStats():
object
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:206
큐 통계 조회
Returns
섹션 제목: “Returns”object
delayedJobs
섹션 제목: “delayedJobs”delayedJobs:
number
highPriorityJobs
섹션 제목: “highPriorityJobs”highPriorityJobs:
number
lowPriorityJobs
섹션 제목: “lowPriorityJobs”lowPriorityJobs:
number
mediumPriorityJobs
섹션 제목: “mediumPriorityJobs”mediumPriorityJobs:
number
queueUtilization
섹션 제목: “queueUtilization”queueUtilization:
number
totalJobs
섹션 제목: “totalJobs”totalJobs:
number
off()
섹션 제목: “off()”off(
eventName,listener):this
Defined in: packages/webhook/src/shared/event-emitter.ts:20
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.off
on()
섹션 제목: “on()”on(
eventName,listener):this
Defined in: packages/webhook/src/shared/event-emitter.ts:9
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.on
once()
섹션 제목: “once()”once(
eventName,listener):this
Defined in: packages/webhook/src/shared/event-emitter.ts:35
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.once
peek()
섹션 제목: “peek()”peek():
DispatchJob|null
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:155
작업 상태 확인
Returns
섹션 제목: “Returns”DispatchJob | null
removeAllListeners()
섹션 제목: “removeAllListeners()”removeAllListeners(
eventName?):this
Defined in: packages/webhook/src/shared/event-emitter.ts:57
Parameters
섹션 제목: “Parameters”eventName?
섹션 제목: “eventName?”string
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.removeAllListeners
removeJob()
섹션 제목: “removeJob()”removeJob(
jobId):Promise<boolean>
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:167
특정 작업 제거
Parameters
섹션 제목: “Parameters”jobId
섹션 제목: “jobId”string
Returns
섹션 제목: “Returns”Promise<boolean>
removeListener()
섹션 제목: “removeListener()”removeListener(
eventName,listener):this
Defined in: packages/webhook/src/shared/event-emitter.ts:31
Parameters
섹션 제목: “Parameters”eventName
섹션 제목: “eventName”string
listener
섹션 제목: “listener”Listener
Returns
섹션 제목: “Returns”this
Inherited from
섹션 제목: “Inherited from”EventEmitter.removeListener
shutdown()
섹션 제목: “shutdown()”shutdown():
Promise<void>
Defined in: packages/webhook/src/dispatcher/queue.manager.ts:441
큐 관리자 종료
Returns
섹션 제목: “Returns”Promise<void>