sqs

Documentation

Index

• type AwsSqsAdapter
  • func NewAwsSqsAdapter(name string, config *AwsSqsConfig) *AwsSqsAdapter
  • func (a *AwsSqsAdapter) Close() error
  • func (a *AwsSqsAdapter) Consume(queueUrl string) ([]*sqs.Message, error)
  • func (a *AwsSqsAdapter) CreateQueue(qName string) (err error)
  • func (a *AwsSqsAdapter) DeleteMessage(qName string, receiptHandle string) (err error)
  • func (a *AwsSqsAdapter) DeleteQueue(qName string) (err error)
  • func (a *AwsSqsAdapter) GetQueueUrl(qName string) (string, error)
  • func (a *AwsSqsAdapter) ListQueues() (*[]*string, error)
  • func (a *AwsSqsAdapter) Publish(message string) (err error)
  • func (a *AwsSqsAdapter) PublishQueue(qName string, message string) (err error)
  • func (a *AwsSqsAdapter) PublishQueueBatchRaw(input *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)
  • func (a *AwsSqsAdapter) PublishQueueRaw(input *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)
  • func (a *AwsSqsAdapter) Setup() (err error)
• type AwsSqsConfig

Types

type AwsSqsAdapter

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

func NewAwsSqsAdapter

func NewAwsSqsAdapter(name string, config *AwsSqsConfig) *AwsSqsAdapter

func (*AwsSqsAdapter) Close

func (a *AwsSqsAdapter) Close() error

func (*AwsSqsAdapter) Consume

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

func (*AwsSqsAdapter) CreateQueue

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

func (*AwsSqsAdapter) DeleteMessage

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

func (*AwsSqsAdapter) DeleteQueue

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

func (*AwsSqsAdapter) GetQueueUrl

func (a *AwsSqsAdapter) GetQueueUrl(qName string) (string, error)

func (*AwsSqsAdapter) ListQueues

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

func (*AwsSqsAdapter) Publish

func (a *AwsSqsAdapter) Publish(message string) (err error)

func (*AwsSqsAdapter) PublishQueue

func (a *AwsSqsAdapter) PublishQueue(qName string, message string) (err error)

func (*AwsSqsAdapter) PublishQueueBatchRaw

func (a *AwsSqsAdapter) PublishQueueBatchRaw(input *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

func (*AwsSqsAdapter) PublishQueueRaw

func (a *AwsSqsAdapter) PublishQueueRaw(input *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)

func (*AwsSqsAdapter) Setup

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

type AwsSqsConfig

type AwsSqsConfig struct {
	Endpoint            string `json:"Endpoint,omitempty" config:"Endpoint"`
	Region              string `json:"Region,omitempty" config:"Region,required"`
	AccessKeyID         string `json:"AccessKeyID,omitempty" config:"AccessKeyID"`
	SecretAccessKey     string `json:"SecretAccessKey,omitempty" config:"SecretAccessKey"`
	SessionToken        string `json:"SessionToken,omitempty" config:"SessionToken"`
	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"`

	Queue string `json:"Queue,omitempty" config:"Queue"`
}