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)
• 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 *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)

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

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 *SDK.Message) error

Delete a message from server

func (*Queue) Fetch

func (q *Queue) Fetch(num int) (*SDK.ReceiveMessageOutput, error)

Get message from the queue with limit

func (*Queue) FetchBody

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

Get only the body of messages

func (*Queue) FetchBodyOne

func (q *Queue) FetchBodyOne() string

Get the body of a single message

func (*Queue) FetchOne

func (q *Queue) FetchOne() (*SDK.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