PubSubScheduler
Defined in: packages/pubsub/src/types.ts:269
Shared scheduler interface for delayed publish and retry across all transports.
Methods
Section titled “Methods”close()
Section titled “close()”close():
Promise<void>
Defined in: packages/pubsub/src/types.ts:273
Stop the scheduler and clear in-process timers.
Returns
Section titled “Returns”Promise<void>
publishLater()
Section titled “publishLater()”publishLater(
request):Promise<void>
Defined in: packages/pubsub/src/types.ts:275
Persist and schedule a delayed publish request.
Parameters
Section titled “Parameters”request
Section titled “request”Returns
Section titled “Returns”Promise<void>
retryLater()
Section titled “retryLater()”retryLater(
topic,event,delayMs,attempt):Promise<void>
Defined in: packages/pubsub/src/types.ts:277
Persist and schedule a retry for an already delivered CloudEvent.
Parameters
Section titled “Parameters”string
CloudEvent
delayMs
Section titled “delayMs”number
attempt
Section titled “attempt”number
Returns
Section titled “Returns”Promise<void>
start()
Section titled “start()”start():
Promise<void>
Defined in: packages/pubsub/src/types.ts:271
Start consuming durable schedule records.
Returns
Section titled “Returns”Promise<void>