Interface PublishOrderLocker

A driver that can take a batch's publish-order locks up front, in sorted key order (the Database driver, Task 9).

interface PublishOrderLocker {
    AcquirePublishOrderLocks(
        topic: TopicBinding,
        messages: WorkMessage<WorkJson>[],
        subscriptions: SubscriptionBinding[],
        executor: WorkQueueTransactionalExecutor,
    ): Promise<void>;
}

Index

Methods

AcquirePublishOrderLocks

Methods

AcquirePublishOrderLocks

AcquirePublishOrderLocks(
    topic: TopicBinding,
    messages: WorkMessage<WorkJson>[],
    subscriptions: SubscriptionBinding[],
    executor: WorkQueueTransactionalExecutor,
): Promise<void>
Parameters
- topic: TopicBinding
- messages: WorkMessage<WorkJson>[]
- subscriptions: SubscriptionBinding[]
- executor: WorkQueueTransactionalExecutor
Returns Promise<void>
- Defined in WorkQueue/engine/src/publish/WorkQueuePublishCoordinator.ts:37