sqs

README

Amazon Simple Queue Service API Client Written in Golang.

Merged from https://github.com/Mistobaan/sqs

Installation

go get github.com/crowdmob/goamz/sqs

Testing

go test .

Documentation

Overview

gosqs - Go packages to interact with the Amazon SQS Web Services.

depends on https://wiki.ubuntu.com/goamz

Written by Prudhvi Krishna Surapaneni <me@prudhvi.net> Extended by Fabrizio Milo <mistobaan@gmail.com>

Index

• type Attribute
• type ChangeMessageVisibilityResponse
• type CreateQueueResponse
• type DeleteMessageBatchResponse
• type DeleteMessageResponse
• type DeleteQueueResponse
• type Error
  • func (err *Error) Error() string
  • func (err *Error) String() string
• type GetQueueAttributesResponse
• type GetQueueUrlResponse
• type ListQueuesResponse
• type Message
• type Queue
  • func (q *Queue) ChangeMessageVisibility(M *Message, VisibilityTimeout int) (resp *ChangeMessageVisibilityResponse, err error)
  • func (q *Queue) Delete() (resp *DeleteQueueResponse, err error)
  • func (q *Queue) DeleteMessage(M *Message) (resp *DeleteMessageResponse, err error)
  • func (q *Queue) DeleteMessageBatch(msgList []Message) (resp *DeleteMessageBatchResponse, err error)
  • func (q *Queue) GetQueueAttributes(A string) (resp *GetQueueAttributesResponse, err error)
  • func (q *Queue) ReceiveMessage(MaxNumberOfMessages int) (resp *ReceiveMessageResponse, err error)
  • func (q *Queue) ReceiveMessageWithVisibilityTimeout(MaxNumberOfMessages, VisibilityTimeoutSec int) (resp *ReceiveMessageResponse, err error)
  • func (q *Queue) SendMessage(MessageBody string) (resp *SendMessageResponse, err error)
  • func (q *Queue) SendMessageBatch(msgList []Message) (resp *SendMessageBatchResponse, err error)
  • func (q *Queue) SendMessageBatchString(msgList []string) (resp *SendMessageBatchResponse, err error)
• type ReceiveMessageResponse
• type ResponseMetadata
• type SQS
  • func New(auth aws.Auth, region aws.Region) *SQS
  • func NewFrom(accessKey, secretKey, region string) (*SQS, error)
  • func (s *SQS) CreateQueue(queueName string) (*Queue, error)
  • func (s *SQS) CreateQueueWithTimeout(queueName string, timeout int) (q *Queue, err error)
  • func (s *SQS) GetQueue(queueName string) (*Queue, error)
  • func (s *SQS) ListQueues(QueueNamePrefix string) (resp *ListQueuesResponse, err error)
  • func (s *SQS) QueueFromArn(queueUrl string) (q *Queue)
• type SendMessageBatchResponse
• type SendMessageBatchResultEntry
• type SendMessageResponse

Types

type Attribute

type Attribute struct {
	Name  string `xml:"Name"`
	Value string `xml:"Value"`
}

type ChangeMessageVisibilityResponse

type ChangeMessageVisibilityResponse struct {
	ResponseMetadata ResponseMetadata
}

type CreateQueueResponse

type CreateQueueResponse struct {
	QueueUrl         string `xml:"CreateQueueResult>QueueUrl"`
	ResponseMetadata ResponseMetadata
}

type DeleteMessageBatchResponse

type DeleteMessageBatchResponse struct {
	DeleteMessageBatchResult []struct {
		Id          string
		SenderFault bool
		Code        string
		Message     string
	} `xml:"DeleteMessageBatchResult>DeleteMessageBatchResultEntry"`
	ResponseMetadata ResponseMetadata
}

type DeleteMessageResponse

type DeleteMessageResponse struct {
	ResponseMetadata ResponseMetadata
}

type DeleteQueueResponse

type DeleteQueueResponse struct {
	ResponseMetadata ResponseMetadata
}

type Error

type Error struct {
	StatusCode int
	Code       string
	Message    string
	RequestId  string
}

func (*Error) Error

func (err *Error) Error() string

func (*Error) String

func (err *Error) String() string

type GetQueueAttributesResponse

type GetQueueAttributesResponse struct {
	Attributes       []Attribute `xml:"GetQueueAttributesResult>Attribute"`
	ResponseMetadata ResponseMetadata
}

type GetQueueUrlResponse

type GetQueueUrlResponse struct {
	QueueUrl         string `xml:"GetQueueUrlResult>QueueUrl"`
	ResponseMetadata ResponseMetadata
}

type ListQueuesResponse

type ListQueuesResponse struct {
	QueueUrl         []string `xml:"ListQueuesResult>QueueUrl"`
	ResponseMetadata ResponseMetadata
}

type Message

type Message struct {
	MessageId     string      `xml:"MessageId"`
	Body          string      `xml:"Body"`
	MD5OfBody     string      `xml:"MD5OfBody"`
	ReceiptHandle string      `xml:"ReceiptHandle"`
	Attribute     []Attribute `xml:"Attribute"`
}

type Queue

type Queue struct {
	*SQS
	Url string
}

Queue Reference to a Queue

func (*Queue) ChangeMessageVisibility

func (q *Queue) ChangeMessageVisibility(M *Message, VisibilityTimeout int) (resp *ChangeMessageVisibilityResponse, err error)

func (*Queue) Delete

func (q *Queue) Delete() (resp *DeleteQueueResponse, err error)

func (*Queue) DeleteMessage

func (q *Queue) DeleteMessage(M *Message) (resp *DeleteMessageResponse, err error)

func (*Queue) DeleteMessageBatch

func (q *Queue) DeleteMessageBatch(msgList []Message) (resp *DeleteMessageBatchResponse, err error)

DeleteMessageBatch

func (*Queue) GetQueueAttributes

func (q *Queue) GetQueueAttributes(A string) (resp *GetQueueAttributesResponse, err error)

func (*Queue) ReceiveMessage

func (q *Queue) ReceiveMessage(MaxNumberOfMessages int) (resp *ReceiveMessageResponse, err error)

ReceiveMessage

func (*Queue) ReceiveMessageWithVisibilityTimeout

func (q *Queue) ReceiveMessageWithVisibilityTimeout(MaxNumberOfMessages, VisibilityTimeoutSec int) (resp *ReceiveMessageResponse, err error)

ReceiveMessageWithVisibilityTimeout

func (*Queue) SendMessage

func (q *Queue) SendMessage(MessageBody string) (resp *SendMessageResponse, err error)

func (*Queue) SendMessageBatch

func (q *Queue) SendMessageBatch(msgList []Message) (resp *SendMessageBatchResponse, err error)

SendMessageBatch

func (*Queue) SendMessageBatchString

func (q *Queue) SendMessageBatchString(msgList []string) (resp *SendMessageBatchResponse, err error)

SendMessageBatchString

type ReceiveMessageResponse

type ReceiveMessageResponse struct {
	Messages         []Message `xml:"ReceiveMessageResult>Message"`
	ResponseMetadata ResponseMetadata
}

type ResponseMetadata

type ResponseMetadata struct {
	RequestId string
	BoxUsage  float64
}

type SQS

type SQS struct {
	aws.Auth
	aws.Region
	// contains filtered or unexported fields
}

The SQS type encapsulates operation with an SQS region.

func New

func New(auth aws.Auth, region aws.Region) *SQS

NewFrom Create A new SQS Client from an exisisting aws.Auth

func NewFrom

func NewFrom(accessKey, secretKey, region string) (*SQS, error)

NewFrom Create A new SQS Client given an access and secret Key region must be one of "us.east, us.west, eu.west"

func (*SQS) CreateQueue

func (s *SQS) CreateQueue(queueName string) (*Queue, error)

CreateQueue create a queue with a specific name

func (*SQS) CreateQueueWithTimeout

func (s *SQS) CreateQueueWithTimeout(queueName string, timeout int) (q *Queue, err error)

CreateQueue create a queue with a specific name and a timeout

func (*SQS) GetQueue

func (s *SQS) GetQueue(queueName string) (*Queue, error)

GetQueue get a reference to the given quename

func (*SQS) ListQueues

func (s *SQS) ListQueues(QueueNamePrefix string) (resp *ListQueuesResponse, err error)

func (*SQS) QueueFromArn

func (s *SQS) QueueFromArn(queueUrl string) (q *Queue)

type SendMessageBatchResponse

type SendMessageBatchResponse struct {
	SendMessageBatchResult []SendMessageBatchResultEntry `xml:"SendMessageBatchResult>SendMessageBatchResultEntry"`
	ResponseMetadata       ResponseMetadata
}

type SendMessageBatchResultEntry

type SendMessageBatchResultEntry struct {
	Id               string `xml:"Id"`
	MessageId        string `xml:"MessageId"`
	MD5OfMessageBody string `xml:"MD5OfMessageBody"`
}

type SendMessageResponse

type SendMessageResponse struct {
	MD5              string `xml:"SendMessageResult>MD5OfMessageBody"`
	Id               string `xml:"SendMessageResult>MessageId"`
	ResponseMetadata ResponseMetadata
}