Interface CountScheduler

A shared registry of persistent demand with adaptive per-relay admission

interface CountScheduler {
    scheduler: SchedulerLike;
    status$: Observable<CountSchedulerStatus>;
    count(
        pool: CountRelayPool,
        relays: readonly string[],
        filters: Filter[],
        options: CountScheduleOptions,
    ): Observable<ScheduledCount>;
    retain(relays: readonly string[]): () => void;
    stop(): void;
}

Index

Properties

scheduler status$

Methods

count retain stop

Properties

scheduler

scheduler: SchedulerLike

The clock shared by participating services

status$

status$: Observable<CountSchedulerStatus>

Emits current capacity, activity, and response measurements

Methods

count

count(
    pool: CountRelayPool,
    relays: readonly string[],
    filters: Filter[],
    options: CountScheduleOptions,
): Observable<ScheduledCount>
Keeps trying a subscribed request until one relay answers or the consumer cancels
Parameters
- pool: CountRelayPool
- relays: readonly string[]
- filters: Filter[]
- options: CountScheduleOptions
Returns Observable<ScheduledCount>
- Defined in loaders/count-scheduler.ts:112

retain

retain(relays: readonly string[]): () => void
Retains a trusted relay set until the returned release function is called
Parameters
- relays: readonly string[]
Returns () => void

Throws
if a URL is invalid
- Defined in loaders/count-scheduler.ts:110

stop

stop(): void
Cancels all work and removes retained state without closing the pool

Returns void
- Defined in loaders/count-scheduler.ts:119