sqsutil

Documentation

Index

• type Config
• type SQSMessageResponseData
• type Service
  • func New(cfg Config) *Service
  • func (s *Service) DeleteMessageBatch(input *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)
  • func (s *Service) GetMessages(queueURL string) (*sqs.ReceiveMessageOutput, error)
  • func (s *Service) GetQueueURL(queue string) (*sqs.GetQueueUrlOutput, error)
  • func (s *Service) SendMessage(queueURL string, message string) (*sqs.SendMessageOutput, error)
  • func (s *Service) SendMessageBatch(input *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)
  • func (s *Service) SendMessageDelay(queueURL string, message map[string]interface{}, delaySeconds int64) (*sqs.SendMessageOutput, error)

Types

type Config

type Config struct {
	Region string
}

Config represents the configuration

type SQSMessageResponseData

type SQSMessageResponseData struct {
	Message          string `json:"Message"`
	MessageID        string `json:"MessageId"`
	Signature        string `json:"Signature"`
	SignatureVersion string `json:"SignatureVersion"`
	SigningCertURL   string `json:"SigningCertURL"`
	Timestamp        string `json:"Timestamp"`
	TopicArn         string `json:"TopicArn"`
	Type             string `json:"Type"`
	UnsubscribeURL   string `json:"UnsubscribeURL"`
}

SQSMessageResponseData model

type Service

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

Service represents the snsutil service

func New

func New(cfg Config) *Service

New initializes SNS service with default config

func (*Service) DeleteMessageBatch

func (s *Service) DeleteMessageBatch(input *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)

DeleteMessageBatch to delete SQS message

func (*Service) GetMessages

func (s *Service) GetMessages(queueURL string) (*sqs.ReceiveMessageOutput, error)

GetMessages to get SQS message

func (*Service) GetQueueURL

func (s *Service) GetQueueURL(queue string) (*sqs.GetQueueUrlOutput, error)

GetQueueURL represents URL of the queue we want to send a message to

func (*Service) SendMessage

func (s *Service) SendMessage(queueURL string, message string) (*sqs.SendMessageOutput, error)

SendMessage to send SQS message

func (*Service) SendMessageBatch

func (s *Service) SendMessageBatch(input *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

SendMessageBatch to send batch of message to SQS

func (*Service) SendMessageDelay

func (s *Service) SendMessageDelay(queueURL string, message map[string]interface{}, delaySeconds int64) (*sqs.SendMessageOutput, error)

SendMessageDelay to send message to SQS with delay seconds