Interface WorkQueuePublishEngine

The part of WorkQueueEngine the endpoint needs. WorkQueueEngine satisfies it structurally.

interface WorkQueuePublishEngine {
    GetTopicByName(name: string): WorkQueuePublishTopic;
    PublishAs<T extends WorkJson>(
        topic: string,
        requests: PublishRequest<T>[],
        options: WorkQueuePublishOptions,
    ): Promise<PublishResult[]>;
}

Index

Methods

GetTopicByName PublishAs

Methods

GetTopicByName

GetTopicByName(name: string): WorkQueuePublishTopic
Parameters
- name: string
Returns WorkQueuePublishTopic
- Defined in WorkQueue/server/src/publishHandler.ts:15

PublishAs

PublishAs<T extends WorkJson>(
    topic: string,
    requests: PublishRequest<T>[],
    options: WorkQueuePublishOptions,
): Promise<PublishResult[]>
Type Parameters
- T extends WorkJson
Parameters
- topic: string
- requests: PublishRequest<T>[]
- options: WorkQueuePublishOptions
Returns Promise<PublishResult[]>
- Defined in WorkQueue/server/src/publishHandler.ts:16