Class BaseNotificationChannel`Abstract`

Abstract base class for notification channels. Provides common functionality like state management and reconnection logic.

Hierarchy (View Summary)

EventEmitter
- BaseNotificationChannel
  - InMemoryNotificationChannel

Implements

NotificationChannel

Index

Constructors

Properties

_state config handlers reconnectAttempts reconnectTimeout?

Accessors

Methods

clearReconnect connect disconnect notifyHandlers publish scheduleReconnect setState subscribe

Constructors

constructor

new BaseNotificationChannel(
config?: NotificationChannelConfig,
): BaseNotificationChannel
Parameters
- config: NotificationChannelConfig = {}
Returns BaseNotificationChannel
Overrides EventEmitter.constructor
- Defined in notifications/BaseNotificationChannel.ts:35

Properties

`Protected`_state

_state: NotificationChannelState = 'disconnected'

`Protected` `Readonly`config

config: ResolvedNotificationChannelConfig

`Protected`handlers

handlers: Set<NotificationHandler> = ...

`Protected`reconnectAttempts

reconnectAttempts: number = 0

`Protected` `Optional`reconnectTimeout

reconnectTimeout?: Timeout

Accessors

state

get state(): NotificationChannelState
Current state of the channel

Returns NotificationChannelState
Implementation of NotificationChannel.state
- Defined in notifications/BaseNotificationChannel.ts:48

Methods

`Protected`clearReconnect

clearReconnect(): void
Returns void
- Defined in notifications/BaseNotificationChannel.ts:111

`Abstract`connect

connect(): Promise<void>
Connect to the notification backend

Returns Promise<void>
Implementation of NotificationChannel.connect
- Defined in notifications/BaseNotificationChannel.ts:59

`Abstract`disconnect

disconnect(): Promise<void>
Disconnect from the notification backend

Returns Promise<void>
Implementation of NotificationChannel.disconnect
- Defined in notifications/BaseNotificationChannel.ts:60

`Protected`notifyHandlers

notifyHandlers(notification: JobNotification): Promise<void>
Parameters
- notification: JobNotification
Returns Promise<void>
- Defined in notifications/BaseNotificationChannel.ts:70

`Abstract`publish

publish(notification: JobNotification): Promise<void>
Publish a job notification
Parameters
- notification: JobNotification
  The notification to publish
Returns Promise<void>
Implementation of NotificationChannel.publish
- Defined in notifications/BaseNotificationChannel.ts:61

`Protected`scheduleReconnect

scheduleReconnect(): void
Returns void
- Defined in notifications/BaseNotificationChannel.ts:85

`Protected`setState

setState(newState: NotificationChannelState): void
Parameters
- newState: NotificationChannelState
Returns void
- Defined in notifications/BaseNotificationChannel.ts:52

subscribe(handler: NotificationHandler): () => void
Subscribe to job notifications
Parameters
- handler: NotificationHandler
  Function to call when a notification is received
Returns () => void
Unsubscribe function
Implementation of NotificationChannel.subscribe
- Defined in notifications/BaseNotificationChannel.ts:63