sqs

Documentation

Index

• func GetQueuePrefix() string
• func Long(v int) *int64
• func String(v string) *string
• type AmazonSQS
  • func NewClient() *AmazonSQS
  • func (svc *AmazonSQS) CreateQueue(in *SDK.CreateQueueInput) error
  • func (svc *AmazonSQS) CreateQueueWithName(name string) error
  • func (svc *AmazonSQS) GetQueue(queue string) (*Queue, error)
  • func (svc *AmazonSQS) IsExistQueue(name string) (bool, error)
• type Message
  • func NewMessage(msg *SDK.Message) *Message
  • func (m Message) Body() string
  • func (m Message) GetMessageID() *string
  • func (m Message) GetReceiptHandle() *string
  • func (m Message) String() string
• type Queue
  • func NewQueue(name string, url *string, cli *SDK.SQS) *Queue
  • func (q *Queue) AddDeleteList(msg interface{})
  • func (q *Queue) AddMessage(message string)
  • func (q *Queue) AddMessageMap(message map[string]interface{}) error
  • func (q *Queue) AutoDelete(b bool)
  • func (q *Queue) CountMessage() (int, int, error)
  • func (q *Queue) DeleteListItems() error
  • func (q *Queue) DeleteMessage(msg *Message) error
  • func (q *Queue) Fetch(num int) ([]*Message, error)
  • func (q *Queue) FetchBody(num int) []string
  • func (q *Queue) FetchBodyOne() string
  • func (q *Queue) FetchOne() (*Message, error)
  • func (q *Queue) Purge() error
  • func (q *Queue) Send() error
  • func (q *Queue) SetExpire(sec int)
• type SQSError
  • func NewError(msg string) *SQSError
  • func NewErrorList(msgList []string) *SQSError
  • func (e *SQSError) AddMessage(msg string)
  • func (e SQSError) Error() string
  • func (e *SQSError) HasError() bool

Functions

func GetQueuePrefix

func GetQueuePrefix() string

Get the prefix for DynamoDB table

func Long

func Long(v int) *int64

func String

func String(v string) *string

Types

type AmazonSQS

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

func NewClient

func NewClient() *AmazonSQS

Create new AmazonSQS struct

func (*AmazonSQS) CreateQueue

func (svc *AmazonSQS) CreateQueue(in *SDK.CreateQueueInput) error

Create new SQS Queue

func (*AmazonSQS) CreateQueueWithName

func (svc *AmazonSQS) CreateQueueWithName(name string) error

CreateQueueWithName creates new SQS Queue by the name

func (*AmazonSQS) GetQueue

func (svc *AmazonSQS) GetQueue(queue string) (*Queue, error)

Get a queue

func (*AmazonSQS) IsExistQueue

func (svc *AmazonSQS) IsExistQueue(name string) (bool, error)

Create new SQS Queue

type Message

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

SQS Message wrapper struct

func NewMessage

func NewMessage(msg *SDK.Message) *Message

func (Message) Body

func (m Message) Body() string

func (Message) GetMessageID

func (m Message) GetMessageID() *string

func (Message) GetReceiptHandle

func (m Message) GetReceiptHandle() *string

func (Message) String

func (m Message) String() string

type Queue

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

SQS Queue wrapper struct

func NewQueue

func NewQueue(name string, url *string, cli *SDK.SQS) *Queue

func (*Queue) AddDeleteList

func (q *Queue) AddDeleteList(msg interface{})

Add a message to the delete spool

func (*Queue) AddMessage

func (q *Queue) AddMessage(message string)

Add message to the send spool

func (*Queue) AddMessageMap

func (q *Queue) AddMessageMap(message map[string]interface{}) error

Add message spool from map data

func (*Queue) AutoDelete

func (q *Queue) AutoDelete(b bool)

Set auto delete flag to this queue

func (*Queue) CountMessage

func (q *Queue) CountMessage() (int, int, error)

Count left messages on the Queue

func (*Queue) DeleteListItems

func (q *Queue) DeleteListItems() error

Execute delete operation in the delete spool

func (*Queue) DeleteMessage

func (q *Queue) DeleteMessage(msg *Message) error

Delete a message from server

func (*Queue) Fetch

func (q *Queue) Fetch(num int) ([]*Message, error)

Get message from the queue with limit

func (*Queue) FetchBody

func (q *Queue) FetchBody(num int) []string

Get only the body of messages ** cannot handle deletion manually as lack of MessageId and ReceiptHandle **

func (*Queue) FetchBodyOne

func (q *Queue) FetchBodyOne() string

Get the body of a single message ** cannot handle deletion manually as lack of MessageId and ReceiptHandle **

func (*Queue) FetchOne

func (q *Queue) FetchOne() (*Message, error)

Get a single message

func (*Queue) Purge

func (q *Queue) Purge() error

Delete all messages on the Queue

func (*Queue) Send

func (q *Queue) Send() error

Send messages in the send spool

func (*Queue) SetExpire

func (q *Queue) SetExpire(sec int)

Set visibility timeout for message

type SQSError

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

func NewError

func NewError(msg string) *SQSError

func NewErrorList

func NewErrorList(msgList []string) *SQSError

func (*SQSError) AddMessage

func (e *SQSError) AddMessage(msg string)

func (SQSError) Error

func (e SQSError) Error() string

func (*SQSError) HasError

func (e *SQSError) HasError() bool