Member Junction
    Preparing search index...

    Interface WorkQueueOperatorEngine

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

    interface WorkQueueOperatorEngine {
        Subscriptions: MJWorkQueueSubscriptionEntity[];
        Topics: MJWorkQueueTopicEntity[];
        Transports: MJWorkQueueTransportEntity[];
        BuildSubscriptionBinding(
            subscription: MJWorkQueueSubscriptionEntity,
        ): SubscriptionBinding;
        BuildTopicBinding(topic: MJWorkQueueTopicEntity): TopicBinding;
        GetBacklog(
            subscriptionName: string,
        ): Promise<
            {
                Capped: boolean;
                Claimable: number;
                InFlight: number;
                Supported: boolean;
                Total: number;
            },
        >;
        GetDriver(transportID: string): Promise<ITransportDriver>;
        GetOperator(
            subscription: MJWorkQueueSubscriptionEntity,
        ): Promise<ITransportOperator>;
        GetSubscriptionByName(name: string): MJWorkQueueSubscriptionEntity;
        ValidateTopology(): Promise<BindingValidationIssue[]>;
    }
    Index

    Properties

    Subscriptions Topics Transports

    Methods

    BuildSubscriptionBinding BuildTopicBinding GetBacklog GetDriver GetOperator GetSubscriptionByName ValidateTopology

    Properties

    Subscriptions: MJWorkQueueSubscriptionEntity[]
    Topics: MJWorkQueueTopicEntity[]
    Transports: MJWorkQueueTransportEntity[]

    Methods

    • Autoscaler metric (03 §11): claimable pending + in flight, each capped at 1000.

      Parameters

      • subscriptionName: string

      Returns Promise<
          {
              Capped: boolean;
              Claimable: number;
              InFlight: number;
              Supported: boolean;
              Total: number;
          },
      >

    Settings

    Member Visibility

    On This Page

    Properties
    Methods