sqs

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 17, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package sqs interacts with pkg/aws/sqs methods and types

Index

Constants

View Source
const (

	// ErrNoPointerParameterAllowed is used when a ptr parameter is not allowed
	ErrNoPointerParameterAllowed = "NoPointerParameterAllowed"

	// ErrEmptyParameter is used when a required parameter is empty
	ErrEmptyParameter = "EmptyParameter"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type SQS

type SQS struct {
	*sqs.SQS
}

SQS embeds *sqs.SQS and is used to call sqs methods on high level

func New

func New(svc *aws.Session) (*SQS, error)

New returns a *SQS given a *aws.Session

func (*SQS) CreateQueue

func (svc *SQS) CreateQueue(queueName string) error

CreateQueue creates a new queue given its name

func (*SQS) GetQueueAttributes

func (svc *SQS) GetQueueAttributes(queueUrl string) (*sqs.GetQueueAttributesOutput, error)

GetQueueAttributes returns *sqs.GetQueueAttributesOutput and error is nil if queue exists

func (*SQS) SendMessage

func (svc *SQS) SendMessage(input interface{}, queueUrl string) error

SendMessage sends a new message on a sns queue given an input and a valid queue url

Jump to

Keyboard shortcuts

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