awsutil

Documentation

Index

• func DeleteQueue(ctx context.Context, sqsClient *sqs.Client, queueURL string) error
• func EnsureQueue(ctx context.Context, sqsClient *sqs.Client, queueName string, ...) (string, error)
• func RetrieveQueueARN(ctx context.Context, sqsClient *sqs.Client, queueURL string) (string, error)
• func RetrieveQueueURL(ctx context.Context, sqsClient *sqs.Client, queueName string) (string, error)
• func SQSClientFromConfig(ctx context.Context, cfg *mqs.AWSSQSConfig) (*sqs.Client, error)
• type CreateQueueFn
  • func MakeCreateQueue(attributes map[string]string) CreateQueueFn

Functions

func DeleteQueue

func DeleteQueue(ctx context.Context, sqsClient *sqs.Client, queueURL string) error

func EnsureQueue

func EnsureQueue(ctx context.Context, sqsClient *sqs.Client, queueName string, createQueue CreateQueueFn) (string, error)

func RetrieveQueueARN

func RetrieveQueueARN(ctx context.Context, sqsClient *sqs.Client, queueURL string) (string, error)

func RetrieveQueueURL

func RetrieveQueueURL(ctx context.Context, sqsClient *sqs.Client, queueName string) (string, error)

func SQSClientFromConfig

func SQSClientFromConfig(ctx context.Context, cfg *mqs.AWSSQSConfig) (*sqs.Client, error)

Types

type CreateQueueFn

type CreateQueueFn func(ctx context.Context, sqsClient *sqs.Client, queueName string) (*sqs.CreateQueueOutput, error)

func MakeCreateQueue

func MakeCreateQueue(attributes map[string]string) CreateQueueFn