Documentation
¶
Index ¶
- func GetQueuePrefix() string
- func Long(v int) *int64
- func String(v string) *string
- type AmazonSQS
- 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 *SDK.Message) error
- func (q *Queue) Fetch(num int) (*SDK.ReceiveMessageOutput, error)
- func (q *Queue) FetchBody(num int) []string
- func (q *Queue) FetchBodyOne() string
- func (q *Queue) FetchOne() (*SDK.Message, error)
- func (q *Queue) Purge() error
- func (q *Queue) Send() error
- func (q *Queue) SetExpire(sec int)
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 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
Source Files
Click to show internal directories.
Click to hide internal directories.