Interface ITransportOperator

interface ITransportOperator {
    Discard(
        subscription: SubscriptionBinding,
        deliveryID: string,
        reason: string,
        actorUserID: string | null,
    ): Promise<OperatorResult>;
    GetStats(subscription: SubscriptionBinding): Promise<SubscriptionStats>;
    ListDeadLetters(
        subscription: SubscriptionBinding,
        cursor: string | null,
        pageSize: number,
    ): Promise<Page<DeadLetterRecord> | null>;
    ListPartitions(
        subscription: SubscriptionBinding,
        condition: PartitionCondition | null,
        cursor: string | null,
        pageSize: number,
    ): Promise<Page<PartitionStateRecord> | null>;
    Replay(
        subscription: SubscriptionBinding,
        deliveryID: string,
        actorUserID: string | null,
        note: string | null,
    ): Promise<OperatorResult>;
}

Implemented by

Index

Methods

Discard GetStats ListDeadLetters ListPartitions Replay

Methods

Discard

Discard(
    subscription: SubscriptionBinding,
    deliveryID: string,
    reason: string,
    actorUserID: string | null,
): Promise<OperatorResult>
Pending (requires CancelPending) or DeadLettered → Discarded immediately. InFlight (requires CancelInFlight) → CancelRequestedAt set, CancelRequested: true (spec 03 §7).
Parameters
- subscription: SubscriptionBinding
- deliveryID: string
- reason: string
- actorUserID: string | null
Returns Promise<OperatorResult>
- Defined in packages/WorkQueue/core/src/operator.ts:65

GetStats

GetStats(subscription: SubscriptionBinding): Promise<SubscriptionStats>
Parameters
- subscription: SubscriptionBinding
Returns Promise<SubscriptionStats>
- Defined in packages/WorkQueue/core/src/operator.ts:53

ListDeadLetters

ListDeadLetters(
    subscription: SubscriptionBinding,
    cursor: string | null,
    pageSize: number,
): Promise<Page<DeadLetterRecord> | null>
Parameters
- subscription: SubscriptionBinding
- cursor: string | null
- pageSize: number
Returns Promise<Page<DeadLetterRecord> | null>
- Defined in packages/WorkQueue/core/src/operator.ts:54

ListPartitions

ListPartitions(
    subscription: SubscriptionBinding,
    condition: PartitionCondition | null,
    cursor: string | null,
    pageSize: number,
): Promise<Page<PartitionStateRecord> | null>
condition null = all non-Idle keys. Returns null when !ListPartitions.
Parameters
- subscription: SubscriptionBinding
- condition: PartitionCondition | null
- cursor: string | null
- pageSize: number
Returns Promise<Page<PartitionStateRecord> | null>
- Defined in packages/WorkQueue/core/src/operator.ts:56

Replay

Replay(
    subscription: SubscriptionBinding,
    deliveryID: string,
    actorUserID: string | null,
    note: string | null,
): Promise<OperatorResult>
Parameters
- subscription: SubscriptionBinding
- deliveryID: string
- actorUserID: string | null
- note: string | null
Returns Promise<OperatorResult>
- Defined in packages/WorkQueue/core/src/operator.ts:62