sqs

Documentation

Index

• Constants
• type Queue
  • func NewQueue(url *http.URL) *Queue
  • func (self *Queue) Close() (err os.Error)
  • func (self *Queue) Delete(id *aws.Signer, mid string) (err os.Error)
  • func (self *Queue) DeleteQueue(id *aws.Signer) (err os.Error)
  • func (self *Queue) Peek(id *aws.Signer, vt int) (body []byte, msgid string, err os.Error)
  • func (self *Queue) Push(id *aws.Signer, body []byte) (err os.Error)
• type SQSError
• type Service
  • func NewService(url *http.URL) *Service
  • func (self *Service) Close() (err os.Error)
  • func (self *Service) CreateQueue(id *aws.Signer, name string, dvtimeout int) (mq *Queue, err os.Error)
  • func (self *Service) ListQueues(id *aws.Signer, prefix string) (mq []string, err os.Error)

Constants

const (
	DEFAULT_HASH     = crypto.SHA256
	MAX_MESSAGE_SIZE = 64 * 1024
)

const (
	DEFAULT_VERSION = "2009-02-01"
)

Types

type Queue

type Queue struct {
	URL *http.URL
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(url *http.URL) *Queue

func (*Queue) Close

func (self *Queue) Close() (err os.Error)

Closes the underlying connection

func (*Queue) Delete

func (self *Queue) Delete(id *aws.Signer, mid string) (err os.Error)

Note: 0 is a valid timeout!!

func (*Queue) DeleteQueue

func (self *Queue) DeleteQueue(id *aws.Signer) (err os.Error)

func (*Queue) Peek

func (self *Queue) Peek(id *aws.Signer, vt int) (body []byte, msgid string, err os.Error)

Note: 0 is a valid timeout!!

func (*Queue) Push

func (self *Queue) Push(id *aws.Signer, body []byte) (err os.Error)

type SQSError

type SQSError struct {
	Type    string
	Code    string
	Message string
	// <Detail?>
	RequestId string
}

type Service

type Service struct {
	URL *http.URL
	// contains filtered or unexported fields
}

func NewService

func NewService(url *http.URL) *Service

func (*Service) Close

func (self *Service) Close() (err os.Error)

Closes the underlying connection

func (*Service) CreateQueue

func (self *Service) CreateQueue(id *aws.Signer, name string, dvtimeout int) (mq *Queue, err os.Error)

Create a queue, returning the Queue object.

func (*Service) ListQueues

func (self *Service) ListQueues(id *aws.Signer, prefix string) (mq []string, err os.Error)