sqs

package module

v0.0.0-...-29f6b9d Latest Latest Go to latest Published: Aug 28, 2021 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kerma/sqscli

Links

Open Source Insights

README ¶

SQS CLI

Usage:
  sqs [command]

Available Commands:
  completion  generate the autocompletion script for the specified shell
  download    Download messages from queue
  help        Help about any command
  ls          list queues
  mv          Move messages from one queue to another
  send        Send a message to queue

Flags:
  -h, --help   help for sqs

Use "sqs [command] --help" for more information about a command.

Install

go install github.com/kerma/sqscli/cmd/sqs

Why?

Because scripting awscli calls together is not so nice. This is much nicer:

$ sqs ls                                                   

NAME                     MESSAGES  IN-FLIGHT  TIMEOUT  MAX  DEAD-LETTER-TARGET
prod-incoming            10        4          120      1    prod-incoming_errors
stage-incoming           1         1          120      5    stage-incoming_errors

Moving messages from one queue to another is not directly possible using AWS Console or CLI. mv helps here:

$ sqs mv prod-incoming_errors prod-incoming --limit 10

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type QueueInfo ¶

type QueueInfo struct {
	QueueName          string
	QueueUrl           string
	NumberOfMessages   int
	MessagesNotVisible int
	VisibilityTimeout  int
	DeadLetterTarget   string
	MaxReceiveCount    int
}

func (*QueueInfo) String ¶

func (o *QueueInfo) String() string

type QueueUrl ¶

type QueueUrl string

func (*QueueUrl) Name ¶

func (q *QueueUrl) Name() string

type Sqs ¶

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

func New ¶

func New(s *session.Session) *Sqs

func (*Sqs) Download ¶

func (s *Sqs) Download(src, dst string, count int, del bool) (int, error)

func (*Sqs) GetQueueUrl ¶

func (s *Sqs) GetQueueUrl(name string) (string, error)

func (*Sqs) Info ¶

func (i *Sqs) Info(queueNames []string) ([]*QueueInfo, error)

func (*Sqs) List ¶

func (s *Sqs) List() ([]QueueUrl, error)

func (*Sqs) Move ¶

func (i *Sqs) Move(src, dst string, limit int) (int, error)

func (*Sqs) Send ¶

func (s *Sqs) Send(dst, body string, attributes map[string]string) (string, error)

Source Files ¶

View all Source files

main.go

Directories ¶

Path	Synopsis
cmd
sqs

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL