sqs

Documentation

Index

• type SqsAdapter
  • func NewSqsAdapter(name string, config *SqsConfig) *SqsAdapter
  • func (a *SqsAdapter) Close() error
  • func (a *SqsAdapter) Consume(queueUrl string) ([]*sqs.Message, error)
  • func (a *SqsAdapter) CreateQueue(qName string) (err error)
  • func (a *SqsAdapter) DeleteMessage(qName, receiptHandle string) (err error)
  • func (a *SqsAdapter) DeleteQueue(qName string) (err error)
  • func (a *SqsAdapter) ListQueues() (*[]*string, error)
  • func (a *SqsAdapter) Publish(qName, message string) (err error)
  • func (a *SqsAdapter) Setup() (err error)
• type SqsConfig

Types

type SqsAdapter

type SqsAdapter struct {
	*adapter.BaseAdapter
	// contains filtered or unexported fields
}

func NewSqsAdapter

func NewSqsAdapter(name string, config *SqsConfig) *SqsAdapter

func (*SqsAdapter) Close

func (a *SqsAdapter) Close() error

func (*SqsAdapter) Consume

func (a *SqsAdapter) Consume(queueUrl string) ([]*sqs.Message, error)

func (*SqsAdapter) CreateQueue

func (a *SqsAdapter) CreateQueue(qName string) (err error)

func (*SqsAdapter) DeleteMessage

func (a *SqsAdapter) DeleteMessage(qName, receiptHandle string) (err error)

func (*SqsAdapter) DeleteQueue

func (a *SqsAdapter) DeleteQueue(qName string) (err error)

func (*SqsAdapter) ListQueues

func (a *SqsAdapter) ListQueues() (*[]*string, error)

func (*SqsAdapter) Publish

func (a *SqsAdapter) Publish(qName, message string) (err error)

func (*SqsAdapter) Setup

func (a *SqsAdapter) Setup() (err error)

type SqsConfig

type SqsConfig struct {
	Endpoint            string `json:"Endpoint,omitempty,omitempty" config:"Endpoint"`
	Region              string `json:"Region,omitempty" config:"Region,required"`
	AccessKeyID         string `json:"AwsAccessKeyID,omitempty" config:"AwsAccessKeyID"`
	SecretAccessKey     string `json:"AwsSecretAccessKey,omitempty" config:"AwsSecretAccessKey"`
	SessionToken        string `json:"AwsSessionToken,omitempty" config:"AwsSessionToken"`
	MaxNumberOfMessages int64  `json:"MaxNumberOfMessages" config:"MaxNumberOfMessages"`
	WaitTimeSeconds     int64  `json:"WaitTimeSeconds" config:"WaitTimeSeconds"`
	VisibilityTimeout   int64  `json:"VisibilityTimeout" config:"VisibilityTimeout"`
	SharedCredentials   bool   `json:"SharedCredentials,omitempty" config:"SharedCredentials"`
}