usp_sqs

Documentation

Index

• type SQSAdapter
  • func NewSQSAdapter(conf SQSConfig) (*SQSAdapter, chan struct{}, error)
  • func (a *SQSAdapter) Close() error
• type SQSConfig
  • func (c *SQSConfig) Validate() error

Types

type SQSAdapter

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

func NewSQSAdapter

func NewSQSAdapter(conf SQSConfig) (*SQSAdapter, chan struct{}, error)

func (*SQSAdapter) Close

func (a *SQSAdapter) Close() error

type SQSConfig

type SQSConfig struct {
	ClientOptions uspclient.ClientOptions `json:"client_options" yaml:"client_options"`
	AccessKey     string                  `json:"access_key" yaml:"access_key"`
	SecretKey     string                  `json:"secret_key,omitempty" yaml:"secret_key,omitempty"`
	QueueURL      string                  `json:"queue_url" yaml:"queue_url"`
	Region        string                  `json:"region" yaml:"region"`
}

func (*SQSConfig) Validate

func (c *SQSConfig) Validate() error