Class SdkSnsGateway

Implements

SnsGateway

Index

Constructors

Methods

GetSubscriptionAttributes GetTopicAttributes PublishBatch

Constructors

constructor

new SdkSnsGateway(client: SNSClient): SdkSnsGateway
Parameters
- client: SNSClient
Returns SdkSnsGateway
- Defined in packages/WorkQueue/aws/src/gateway/SdkSnsGateway.ts:14

Methods

GetSubscriptionAttributes

GetSubscriptionAttributes(
subscriptionArn: string,
): Promise<Record<string, string>>
Null when the subscription does not exist.
Parameters
- subscriptionArn: string
Returns Promise<Record<string, string>>
Implementation of SnsGateway.GetSubscriptionAttributes
- Defined in packages/WorkQueue/aws/src/gateway/SdkSnsGateway.ts:59

GetTopicAttributes

GetTopicAttributes(topicArn: string): Promise<Record<string, string>>
Null when the topic does not exist.
Parameters
- topicArn: string
Returns Promise<Record<string, string>>
Implementation of SnsGateway.GetTopicAttributes
- Defined in packages/WorkQueue/aws/src/gateway/SdkSnsGateway.ts:47

PublishBatch

PublishBatch(
topicArn: string,
entries: SnsPublishEntry[],
): Promise<SnsPublishEntryResult[]>
At most 10 entries. Throws AwsGatewayError when the whole call fails.
Parameters
- topicArn: string
- entries: SnsPublishEntry[]
Returns Promise<SnsPublishEntryResult[]>
Implementation of SnsGateway.PublishBatch
- Defined in packages/WorkQueue/aws/src/gateway/SdkSnsGateway.ts:16