sqsway

README

sqsway

This is the AWS SQS way to handle the messages in []byte type.

Documentation

Index

• type QueueInfo
  • func New(q *string) *QueueInfo
  • func (q *QueueInfo) ReceiveMessage(h ReceiveHandle)
  • func (q *QueueInfo) SendMessage(msgString []byte)
• type ReceiveHandle

Types

type QueueInfo

type QueueInfo struct {
	Queue *string
}

func New

func New(q *string) *QueueInfo

func (*QueueInfo) ReceiveMessage

func (q *QueueInfo) ReceiveMessage(h ReceiveHandle)

func (*QueueInfo) SendMessage

func (q *QueueInfo) SendMessage(msgString []byte)

type ReceiveHandle

type ReceiveHandle func(*sync.WaitGroup, []byte, *set.Set, int)