EndpointManager

Defined in: packages/webhook/src/registry/endpoint.manager.ts:20

Extends

• EventEmitter

Constructors

Constructor

new EndpointManager(config?): EndpointManager

Defined in: packages/webhook/src/registry/endpoint.manager.ts:32

Parameters

config?

Partial<StorageConfig> = {}

Returns

EndpointManager

Overrides

EventEmitter.constructor

Methods

addEndpoint()

addEndpoint(endpoint): Promise<void>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:48

엔드포인트 추가

Parameters

endpoint

active

boolean = ...

createdAt

Date = ...

description?

string = ...

events

WebhookEventType[] = ...

filters?

{ channelId?: string[]; providerId?: string[]; templateId?: string[]; } = ...

filters.channelId?

string[] = ...

filters.providerId?

string[] = ...

filters.templateId?

string[] = ...

headers?

Record<string, string> = ...

id

string = ...

lastTriggeredAt?

Date = ...

name?

string = ...

retryConfig?

{ backoffMultiplier: number; maxRetries: number; retryDelayMs: number; } = ...

retryConfig.backoffMultiplier

number = ...

retryConfig.maxRetries

number = ...

retryConfig.retryDelayMs

number = ...

secret?

string = ...

status

"error" | "active" | "inactive" | "suspended" = ...

updatedAt

Date = ...

url

string = ...

Returns

Promise<void>

---

addListener()

addListener(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:16

Parameters

eventName

string

listener

Listener

Returns

this

Inherited from

EventEmitter.addListener

---

cleanupExpiredEndpoints()

cleanupExpiredEndpoints(): Promise<number>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:292

만료된 엔드포인트 정리

Returns

Promise<number>

---

emit()

emit(eventName, …args): boolean

Defined in: packages/webhook/src/shared/event-emitter.ts:44

Parameters

eventName

string

args

…unknown[]

Returns

boolean

Inherited from

EventEmitter.emit

---

getActiveEndpointsForEvent()

getActiveEndpointsForEvent(eventType): Promise<object[]>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:244

특정 이벤트 타입을 구독하는 활성 엔드포인트 조회

Parameters

eventType

WebhookEventType

Returns

Promise<object[]>

---

getEndpoint()

getEndpoint(endpointId): Promise<{ active: boolean; createdAt: Date; description?: string; events: WebhookEventType[]; filters?: { channelId?: string[]; providerId?: string[]; templateId?: string[]; }; headers?: Record<string, string>; id: string; lastTriggeredAt?: Date; name?: string; retryConfig?: { backoffMultiplier: number; maxRetries: number; retryDelayMs: number; }; secret?: string; status: "error" | "active" | "inactive" | "suspended"; updatedAt: Date; url: string; } | null>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:152

엔드포인트 조회

Parameters

endpointId

string

Returns

Promise<{ active: boolean; createdAt: Date; description?: string; events: WebhookEventType[]; filters?: { channelId?: string[]; providerId?: string[]; templateId?: string[]; }; headers?: Record<string, string>; id: string; lastTriggeredAt?: Date; name?: string; retryConfig?: { backoffMultiplier: number; maxRetries: number; retryDelayMs: number; }; secret?: string; status: "error" | "active" | "inactive" | "suspended"; updatedAt: Date; url: string; } | null>

---

getEndpointByUrl()

getEndpointByUrl(url): Promise<{ active: boolean; createdAt: Date; description?: string; events: WebhookEventType[]; filters?: { channelId?: string[]; providerId?: string[]; templateId?: string[]; }; headers?: Record<string, string>; id: string; lastTriggeredAt?: Date; name?: string; retryConfig?: { backoffMultiplier: number; maxRetries: number; retryDelayMs: number; }; secret?: string; status: "error" | "active" | "inactive" | "suspended"; updatedAt: Date; url: string; } | null>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:159

URL로 엔드포인트 조회

Parameters

url

string

Returns

Promise<{ active: boolean; createdAt: Date; description?: string; events: WebhookEventType[]; filters?: { channelId?: string[]; providerId?: string[]; templateId?: string[]; }; headers?: Record<string, string>; id: string; lastTriggeredAt?: Date; name?: string; retryConfig?: { backoffMultiplier: number; maxRetries: number; retryDelayMs: number; }; secret?: string; status: "error" | "active" | "inactive" | "suspended"; updatedAt: Date; url: string; } | null>

---

getStats()

getStats(): object

Defined in: packages/webhook/src/registry/endpoint.manager.ts:260

엔드포인트 통계 조회

Returns

object

activeEndpoints

activeEndpoints: number

errorEndpoints

errorEndpoints: number

eventSubscriptions

eventSubscriptions: Record<WebhookEventType, number>

inactiveEndpoints

inactiveEndpoints: number

suspendedEndpoints

suspendedEndpoints: number

totalEndpoints

totalEndpoints: number

---

off()

off(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:20

Parameters

eventName

string

listener

Listener

Returns

this

Inherited from

EventEmitter.off

---

on()

on(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:9

Parameters

eventName

string

listener

Listener

Returns

this

Inherited from

EventEmitter.on

---

once()

once(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:35

Parameters

eventName

string

listener

Listener

Returns

this

Inherited from

EventEmitter.once

---

removeAllListeners()

removeAllListeners(eventName?): this

Defined in: packages/webhook/src/shared/event-emitter.ts:57

Parameters

eventName?

string

Returns

this

Inherited from

EventEmitter.removeAllListeners

---

removeEndpoint()

removeEndpoint(endpointId): Promise<boolean>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:130

엔드포인트 제거

Parameters

endpointId

string

Returns

Promise<boolean>

---

removeListener()

removeListener(eventName, listener): this

Defined in: packages/webhook/src/shared/event-emitter.ts:31

Parameters

eventName

string

listener

Listener

Returns

this

Inherited from

EventEmitter.removeListener

---

searchEndpoints()

searchEndpoints(filter?, pagination?): Promise<SearchResult<{ active: boolean; createdAt: Date; description?: string; events: WebhookEventType[]; filters?: { channelId?: string[]; providerId?: string[]; templateId?: string[]; }; headers?: Record<string, string>; id: string; lastTriggeredAt?: Date; name?: string; retryConfig?: { backoffMultiplier: number; maxRetries: number; retryDelayMs: number; }; secret?: string; status: "error" | "active" | "inactive" | "suspended"; updatedAt: Date; url: string; }>>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:167

필터 조건에 맞는 엔드포인트 검색

Parameters

filter?

EndpointFilter = {}

pagination?

PaginationOptions = ...

Returns

Promise<SearchResult<{ active: boolean; createdAt: Date; description?: string; events: WebhookEventType[]; filters?: { channelId?: string[]; providerId?: string[]; templateId?: string[]; }; headers?: Record<string, string>; id: string; lastTriggeredAt?: Date; name?: string; retryConfig?: { backoffMultiplier: number; maxRetries: number; retryDelayMs: number; }; secret?: string; status: "error" | "active" | "inactive" | "suspended"; updatedAt: Date; url: string; }>>

---

shutdown()

shutdown(): Promise<void>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:511

엔드포인트 관리자 종료

Returns

Promise<void>

---

updateEndpoint()

updateEndpoint(endpointId, updates): Promise<{ active: boolean; createdAt: Date; description?: string; events: WebhookEventType[]; filters?: { channelId?: string[]; providerId?: string[]; templateId?: string[]; }; headers?: Record<string, string>; id: string; lastTriggeredAt?: Date; name?: string; retryConfig?: { backoffMultiplier: number; maxRetries: number; retryDelayMs: number; }; secret?: string; status: "error" | "active" | "inactive" | "suspended"; updatedAt: Date; url: string; }>

Defined in: packages/webhook/src/registry/endpoint.manager.ts:80

엔드포인트 업데이트

Parameters

endpointId

string

updates

Partial<WebhookEndpoint>

Returns

Promise<{ active: boolean; createdAt: Date; description?: string; events: WebhookEventType[]; filters?: { channelId?: string[]; providerId?: string[]; templateId?: string[]; }; headers?: Record<string, string>; id: string; lastTriggeredAt?: Date; name?: string; retryConfig?: { backoffMultiplier: number; maxRetries: number; retryDelayMs: number; }; secret?: string; status: "error" | "active" | "inactive" | "suspended"; updatedAt: Date; url: string; }>