awssqs

Documentation

Index

• Variables
• type Queue
• type QueueDetails
• type SQSQueue
  • func NewSQSQueue(sqssvc *sqs.SQS, logger lager.Logger) *SQSQueue
  • func (s *SQSQueue) Create(queueName string, queueDetails QueueDetails) (string, error)
  • func (s *SQSQueue) Delete(queueName string) error
  • func (s *SQSQueue) Describe(queueName string) (QueueDetails, error)
  • func (s *SQSQueue) Modify(queueName string, queueDetails QueueDetails) error

Variables

var (
	ErrQueueDoesNotExist = errors.New("sqs queue does not exist")
)

Types

type Queue

type Queue interface {
	Describe(queueName string) (QueueDetails, error)
	Create(queueName string, queueDetails QueueDetails) (string, error)
	Modify(queueName string, queueDetails QueueDetails) error
	Delete(queueName string) error
}

type QueueDetails

type QueueDetails struct {
	QueueURL                      string
	QueueArn                      string
	DelaySeconds                  string
	MaximumMessageSize            string
	MessageRetentionPeriod        string
	Policy                        string
	ReceiveMessageWaitTimeSeconds string
	VisibilityTimeout             string
}

type SQSQueue

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

func NewSQSQueue

func NewSQSQueue(
	sqssvc *sqs.SQS,
	logger lager.Logger,
) *SQSQueue

func (*SQSQueue) Create

func (s *SQSQueue) Create(queueName string, queueDetails QueueDetails) (string, error)

func (*SQSQueue) Delete

func (s *SQSQueue) Delete(queueName string) error

func (*SQSQueue) Describe

func (s *SQSQueue) Describe(queueName string) (QueueDetails, error)

func (*SQSQueue) Modify

func (s *SQSQueue) Modify(queueName string, queueDetails QueueDetails) error