Member Junction
    Preparing search index...
    interface ITransportDriver {
        Capabilities: TransportCapabilities;
        Name: string;
        OpenConsumer<TPayload extends WorkJson>(
            subscription: SubscriptionBinding,
        ): ITransportConsumer<TPayload>;
        Operator(): ITransportOperator;
        Publish(
            topic: TopicBinding,
            messages: WorkMessage<WorkJson>[],
            subscriptions: SubscriptionBinding[],
            opts?: DatabasePublishOptions,
        ): Promise<PublishResult[]>;
        ValidateBindings(
            topic: TopicBinding,
            subscriptions: SubscriptionBinding[],
        ): Promise<BindingValidationIssue[]>;
    }

    Implemented by

    Index

    Properties

    Capabilities: TransportCapabilities
    Name: string

    Methods