Class AwsTransportOperator

Implements

ITransportOperator

Index

Constructors

Methods

Discard GetStats ListDeadLetters ListPartitions Replay

Constructors

constructor

new AwsTransportOperator(
sqs: SqsGateway,
options?: { Now?: () => number },
): AwsTransportOperator
Parameters
- sqs: SqsGateway
- options: { Now?: () => number } = {}
Returns AwsTransportOperator
- Defined in packages/WorkQueue/aws/src/operator/AwsTransportOperator.ts:21

Methods

Discard

Discard(
    subscription: SubscriptionBinding,
    deliveryID: string,
    _reason: string,
    _actorUserID: string,
): 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
Returns Promise<OperatorResult>
Implementation of ITransportOperator.Discard
- Defined in packages/WorkQueue/aws/src/operator/AwsTransportOperator.ts:82

GetStats

GetStats(subscription: SubscriptionBinding): Promise<SubscriptionStats>
Parameters
- subscription: SubscriptionBinding
Returns Promise<SubscriptionStats>
Implementation of ITransportOperator.GetStats
- Defined in packages/WorkQueue/aws/src/operator/AwsTransportOperator.ts:25

ListDeadLetters

ListDeadLetters(
    subscription: SubscriptionBinding,
    _cursor: string,
    pageSize: number,
): Promise<Page<DeadLetterRecord>>
Parameters
- subscription: SubscriptionBinding
- _cursor: string
- pageSize: number
Returns Promise<Page<DeadLetterRecord>>
Implementation of ITransportOperator.ListDeadLetters
- Defined in packages/WorkQueue/aws/src/operator/AwsTransportOperator.ts:44

ListPartitions

ListPartitions(
    _subscription: SubscriptionBinding,
    _condition: PartitionCondition,
    _cursor: string,
    _pageSize: number,
): Promise<Page<PartitionStateRecord>>
condition null = all non-Idle keys. Returns null when !ListPartitions.
Parameters
- _subscription: SubscriptionBinding
- _condition: PartitionCondition
- _cursor: string
- _pageSize: number
Returns Promise<Page<PartitionStateRecord>>
Implementation of ITransportOperator.ListPartitions
- Defined in packages/WorkQueue/aws/src/operator/AwsTransportOperator.ts:51

Replay

Replay(
    subscription: SubscriptionBinding,
    deliveryID: string,
    actorUserID: string,
    note: string,
): Promise<OperatorResult>
Parameters
- subscription: SubscriptionBinding
- deliveryID: string
- actorUserID: string
- note: string
Returns Promise<OperatorResult>
Implementation of ITransportOperator.Replay
- Defined in packages/WorkQueue/aws/src/operator/AwsTransportOperator.ts:55