sqs

Documentation

Index

• type IClient
  • func New(config *config.AWS) (IClient, error)
• type SQS
  • func (service *SQS) CreateQueue(name string) (*sqs.CreateQueueOutput, error)
  • func (service *SQS) DeleteQueue(url string) error
  • func (service *SQS) ListQueues() (*sqs.ListQueuesOutput, error)
  • func (service *SQS) SendMessage(url, message string) (*sqs.SendMessageOutput, error)

Types

type IClient

type IClient interface {
	CreateQueue(name string) (*sqs.CreateQueueOutput, error)
	DeleteQueue(url string) error
	ListQueues() (*sqs.ListQueuesOutput, error)
	SendMessage(url, message string) (*sqs.SendMessageOutput, error)
}

func New

func New(config *config.AWS) (IClient, error)

type SQS

type SQS struct {
	// contains filtered or unexported fields
}

func (*SQS) CreateQueue

func (service *SQS) CreateQueue(name string) (*sqs.CreateQueueOutput, error)

func (*SQS) DeleteQueue

func (service *SQS) DeleteQueue(url string) error

func (*SQS) ListQueues

func (service *SQS) ListQueues() (*sqs.ListQueuesOutput, error)

func (*SQS) SendMessage

func (service *SQS) SendMessage(url, message string) (*sqs.SendMessageOutput, error)