sqs

Documentation

Index

• type Client
  • func New(cfg aws.Config) (Client, error)

Types

type Client

type Client interface {
	GetQueueURL(ctx context.Context, queueName string) (string, error)
	ReadOneFromSQS(ctx context.Context, queueUrl string, timeout time.Duration) (types.Message, error)
	ExtractOutboxPayload(message types.Message) ([]byte, error)
}

func New

func New(cfg aws.Config) (Client, error)