sqs

Documentation

Index

• func New(queue string, opts ...swarm.Option) (swarm.Broker, error)
• type Client
  • func NewSQS(queue string, opts ...swarm.Option) (*Client, error)
  • func (cli *Client) Ack(digest string) error
  • func (cli Client) Ask() ([]swarm.Bag, error)
  • func (cli *Client) Enq(bag swarm.Bag) error
• type SQS

Functions

func New

func New(queue string, opts ...swarm.Option) (swarm.Broker, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewSQS

func NewSQS(queue string, opts ...swarm.Option) (*Client, error)

func (*Client) Ack

func (cli *Client) Ack(digest string) error

func (Client) Ask

func (cli Client) Ask() ([]swarm.Bag, error)

Deq dequeues message from broker

func (*Client) Enq

func (cli *Client) Enq(bag swarm.Bag) error

Enq enqueues message to broker

type SQS

type SQS interface {
	GetQueueUrl(context.Context, *sqs.GetQueueUrlInput, ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)
	SendMessage(context.Context, *sqs.SendMessageInput, ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)
	ReceiveMessage(context.Context, *sqs.ReceiveMessageInput, ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
	DeleteMessage(context.Context, *sqs.DeleteMessageInput, ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)
}

SQS