Documentation
¶
Index ¶
- func GetQueuePrefix() string
- func Long(v int) *int64
- func String(v string) *string
- type AmazonSQS
- type Message
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AmazonSQS ¶
type AmazonSQS struct {
// contains filtered or unexported fields
}
func (*AmazonSQS) CreateQueue ¶
func (svc *AmazonSQS) CreateQueue(in *SDK.CreateQueueInput) error
Create new SQS Queue
func (*AmazonSQS) CreateQueueWithName ¶
CreateQueueWithName creates new SQS Queue by the name
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
SQS Message wrapper struct
func NewMessage ¶
func (Message) GetMessageID ¶
func (Message) GetReceiptHandle ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
SQS Queue wrapper struct
func (*Queue) AddDeleteList ¶
func (q *Queue) AddDeleteList(msg interface{})
Add a message to the delete spool
func (*Queue) AddMessageMap ¶
Add message spool from map data
func (*Queue) CountMessage ¶
Count left messages on the Queue
func (*Queue) DeleteListItems ¶
Execute delete operation in the delete spool
func (*Queue) DeleteMessage ¶
Delete a message from server
func (*Queue) FetchBody ¶
Get only the body of messages ** cannot handle deletion manually as lack of MessageId and ReceiptHandle **
func (*Queue) FetchBodyOne ¶
Get the body of a single message ** cannot handle deletion manually as lack of MessageId and ReceiptHandle **
type SQSError ¶
type SQSError struct {
// contains filtered or unexported fields
}
func NewErrorList ¶
func (*SQSError) AddMessage ¶
Source Files
Click to show internal directories.
Click to hide internal directories.