sqs

Documentation

Overview

Package sqs provides a Vice implementation for Amazon Simple Queue Service.

Index

• func RegionFromURL(url string) string
• type MultiTransport
  • func NewMulti(writers, batchSize int, batchInterval time.Duration) *MultiTransport
  • func (t *MultiTransport) Done() chan struct{}
  • func (t *MultiTransport) ErrChan() <-chan error
  • func (t *MultiTransport) Receive(name string) <-chan []byte
  • func (t *MultiTransport) Send(name string) chan<- []byte
  • func (t *MultiTransport) Stop()
• type Transport
  • func New(batchSize int, batchInterval time.Duration) *Transport
  • func (t *Transport) Done() chan struct{}
  • func (t *Transport) ErrChan() <-chan error
  • func (t *Transport) Receive(name string) <-chan []byte
  • func (t *Transport) Send(name string) chan<- []byte
  • func (t *Transport) Stop()

Functions

func RegionFromURL

func RegionFromURL(url string) string

RegionFromURL parses an sqs url and returns the aws region

Types

type MultiTransport

type MultiTransport struct {
	NewService func(region string) (sqsiface.SQSAPI, error)
	// contains filtered or unexported fields
}

MultiTransport is a vice.Transport for Amazon's SQS

func NewMulti

func NewMulti(writers, batchSize int, batchInterval time.Duration) *MultiTransport

NewMulti returns a new transport with multiple sqs writers Credentials are automatically sourced using the AWS SDK credential chain, for more info see the AWS SDK docs: https://godoc.org/github.com/aws/aws-sdk-go#hdr-Configuring_Credentials

func (*MultiTransport) Done

func (t *MultiTransport) Done() chan struct{}

Done gets a channel which is closed when the transport has successfully stopped.

func (*MultiTransport) ErrChan

func (t *MultiTransport) ErrChan() <-chan error

ErrChan gets the channel on which errors are sent.

func (*MultiTransport) Receive

func (t *MultiTransport) Receive(name string) <-chan []byte

Receive gets a channel on which to receive messages with the specified name. The name is the queue's url

func (*MultiTransport) Send

func (t *MultiTransport) Send(name string) chan<- []byte

Send gets a channel on which messages with the specified name may be sent. The name is the queue's URL

func (*MultiTransport) Stop

func (t *MultiTransport) Stop()

Stop stops the transport. The channel returned from Done() will be closed when the transport has stopped.

type Transport

type Transport struct {
	NewService func(region string) (sqsiface.SQSAPI, error)
	// contains filtered or unexported fields
}

Transport is a vice.Transport for Amazon's SQS

func New

func New(batchSize int, batchInterval time.Duration) *Transport

New returns a new transport Credentials are automatically sourced using the AWS SDK credential chain, for more info see the AWS SDK docs: https://godoc.org/github.com/aws/aws-sdk-go#hdr-Configuring_Credentials

func (*Transport) Done

func (t *Transport) Done() chan struct{}

Done gets a channel which is closed when the transport has successfully stopped.

func (*Transport) ErrChan

func (t *Transport) ErrChan() <-chan error

ErrChan gets the channel on which errors are sent.

func (*Transport) Receive

func (t *Transport) Receive(name string) <-chan []byte

Receive gets a channel on which to receive messages with the specified name. The name is the queue's url

func (*Transport) Send

func (t *Transport) Send(name string) chan<- []byte

Send gets a channel on which messages with the specified name may be sent. The name is the queue's URL

func (*Transport) Stop

func (t *Transport) Stop()

Stop stops the transport. The channel returned from Done() will be closed when the transport has stopped.