memsqs

Documentation

Index

• Constants
• type Client
  • func New() *Client
  • func (c *Client) ChangeMessageVisibility(params *sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)
  • func (c *Client) DeleteMessage(params *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)
  • func (c *Client) DeleteMessageBatch(params *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)
  • func (c *Client) Queue(name string) []*Message
  • func (c *Client) ReceiveMessage(params *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)
  • func (c *Client) SendMessage(params *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)
  • func (c *Client) SendMessageBatch(params *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)
  • func (c *Client) VisibleQueue(name string) []*Message
• type Message

Constants

const DefaultVisibilityTimeout time.Duration = 30 * time.Second

DefaultVisibilityTimeout is the SQS default.

Types

type Client

type Client struct {
	sync.Mutex
	sqsiface.SQSAPI
	// contains filtered or unexported fields
}

Client is an in-memory implementation of sqsiface.SQSAPI. It is NOT a complete implementation yet. Functionality will added as needed by the tests in mq-go.

func New

func New() *Client

New returns a new memsqs.Client.

func (*Client) ChangeMessageVisibility

func (c *Client) ChangeMessageVisibility(params *sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)

ChangeMessageVisibility satisfies the sqsiface.SQSAPI interface.

func (*Client) DeleteMessage

func (c *Client) DeleteMessage(params *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)

DeleteMessage satisfies the sqsiface.SQSAPI interface.

func (*Client) DeleteMessageBatch

func (c *Client) DeleteMessageBatch(params *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)

DeleteMessageBatch satisfies the sqsiface.SQSAPI interface.

func (*Client) Queue

func (c *Client) Queue(name string) []*Message

Queue provides direct access to a queue of messages.

func (*Client) ReceiveMessage

func (c *Client) ReceiveMessage(params *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)

ReceiveMessage satisfies the sqsiface.SQSAPI interface.

func (*Client) SendMessage

func (c *Client) SendMessage(params *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)

SendMessage satisfies the sqsiface.SQSAPI interface.

func (*Client) SendMessageBatch

func (c *Client) SendMessageBatch(params *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

SendMessageBatch satisfies the sqsiface.SQSAPI interface.

func (*Client) VisibleQueue

func (c *Client) VisibleQueue(name string) []*Message

VisibleQueue returns only items that are currently visible.

type Message

type Message struct {
	SQSMessage   *sqs.Message
	ReceivedTime time.Time
	VisibleAfter time.Time
}

Message wraps an sqs.Message with metadata.