Interface PublishCoordinatorDeps

interface PublishCoordinatorDeps {
    Executor: WorkQueueExecutorSource;
    Log: WorkLogger;
    CreateLedger(executor: WorkQueueSqlExecutor): LedgerOperations;
    GetDriver(transportID: string): Promise<ITransportDriver>;
    NewID(): string;
    NotifyPublished(topicName: string): void;
    Now(): Date;
    ResolveTopic(topicName: string): ResolvedTopic;
}

Index

Properties

Methods

CreateLedger GetDriver NewID NotifyPublished Now ResolveTopic

Properties

Executor

Executor: WorkQueueExecutorSource

Log

Log: WorkLogger

Methods

CreateLedger

CreateLedger(executor: WorkQueueSqlExecutor): LedgerOperations
Parameters
- executor: WorkQueueSqlExecutor
Returns LedgerOperations
- Defined in WorkQueue/engine/src/publish/WorkQueuePublishCoordinator.ts:22

GetDriver

GetDriver(transportID: string): Promise<ITransportDriver>
Parameters
- transportID: string
Returns Promise<ITransportDriver>
- Defined in WorkQueue/engine/src/publish/WorkQueuePublishCoordinator.ts:20

NewID

NewID(): string
Returns string
- Defined in WorkQueue/engine/src/publish/WorkQueuePublishCoordinator.ts:23

NotifyPublished

NotifyPublished(topicName: string): void
Parameters
- topicName: string
Returns void
- Defined in WorkQueue/engine/src/publish/WorkQueuePublishCoordinator.ts:25

Now

Now(): Date
Returns Date
- Defined in WorkQueue/engine/src/publish/WorkQueuePublishCoordinator.ts:24

ResolveTopic

ResolveTopic(topicName: string): ResolvedTopic
Returns undefined for an unknown topic; throws WorkQueueConfigurationError for a misconfigured one.
Parameters
- topicName: string
Returns ResolvedTopic
- Defined in WorkQueue/engine/src/publish/WorkQueuePublishCoordinator.ts:19