@coasys/ad4m / Exports / WakerSubscriptionManagerOptions
Interface: WakerSubscriptionManagerOptions
Table of contents
Properties
- QuerySubscriptionProxy
- debounceMs
- logger
- onPersist
- onWake
- perspectiveClient
- previousSeenMessages
- retryPendingMs
- subscribeTimeoutMs
Properties
QuerySubscriptionProxy
• Optional QuerySubscriptionProxy: any
Optional: provide QuerySubscriptionProxy class directly (avoids require("@coasys/ad4m") at runtime).
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:49 (opens in a new tab)
debounceMs
• Optional debounceMs: number
Debounce interval in ms before firing the wake callback (default 2000)
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:40 (opens in a new tab)
logger
• logger: WakerLogger
Logger instance
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:38 (opens in a new tab)
onPersist
• Optional onPersist: (subscriptions: WakerSubscription[], seenMessages: Record<string, string[]>) => void
Type declaration
▸ (subscriptions, seenMessages): void
Called when the active subscription list changes (for persistence).
Parameters
| Name | Type |
|---|---|
subscriptions | WakerSubscription[] |
seenMessages | Record<string, string[]> |
Returns
void
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:45 (opens in a new tab)
onWake
• onWake: (sub: WakerSubscription, result: any, mentions?: MentionMessage[]) => void
Type declaration
▸ (sub, result, mentions?): void
Called when a subscription fires (after debounce). Return value is ignored.
For mention subs, mentions contains per-message parent info.
Parameters
| Name | Type |
|---|---|
sub | WakerSubscription |
result | any |
mentions? | MentionMessage[] |
Returns
void
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:43 (opens in a new tab)
perspectiveClient
• perspectiveClient: any
PerspectiveClient from Ad4mClient (provides subscribeQuery etc.)
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:36 (opens in a new tab)
previousSeenMessages
• Optional previousSeenMessages: Record<string, string[]>
Previously persisted seen message IDs per subscription. Seeds seenMessages on resubscribe to avoid duplicate wakes.
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:47 (opens in a new tab)
retryPendingMs
• Optional retryPendingMs: number
How long to wait before re-attempting a subscription the executor rejected (default 30000). 0 disables re-attempts.
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:52 (opens in a new tab)
subscribeTimeoutMs
• Optional subscribeTimeoutMs: number
How long the executor gets to answer the subscribe handshake before the
attempt is abandoned and queued for re-attempt (default 15000). 0 removes
the bound. Covers both proxy.subscribe() and proxy.initialized: when
the executor accepts the socket but never answers, neither settles, and
without a deadline the subscription ended up neither active nor pending,
so the re-attempt cycle never saw it (#1016).
Defined in
core/src/perspectives/WakerSubscriptionManager.ts:61 (opens in a new tab)