aws

Documentation

Index

• func CreateSNSAPI(region, endpoint string) (*sns.Client, error)
• func CreateSNSTopic(api SNSAPI, topic string) (string, error)
• func CreateSQSAPI(region, endpoint string) (*sqs.Client, error)
• func CreateSQSQueue(api SQSAPI, queueName string) (string, error)
• type SNSAPI
• type SQSAPI

Functions

func CreateSNSAPI

func CreateSNSAPI(region, endpoint string) (*sns.Client, error)

CreateSNSAPI helper function.

func CreateSNSTopic

func CreateSNSTopic(api SNSAPI, topic string) (string, error)

CreateSNSTopic helper function.

func CreateSQSAPI

func CreateSQSAPI(region, endpoint string) (*sqs.Client, error)

CreateSQSAPI helper function.

func CreateSQSQueue

func CreateSQSQueue(api SQSAPI, queueName string) (string, error)

CreateSQSQueue helper function.

Types

type SNSAPI

type SNSAPI interface {
	CreateTopic(ctx context.Context, params *sns.CreateTopicInput, optFns ...func(*sns.Options)) (*sns.CreateTopicOutput, error)
}

type SQSAPI

type SQSAPI interface {
	CreateQueue(ctx context.Context, params *sqs.CreateQueueInput, optFns ...func(*sqs.Options)) (*sqs.CreateQueueOutput, error)
	ReceiveMessage(ctx context.Context, params *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
}