sqs

Documentation

Index

• type Config
• type Message
• type SQS
  • func New(config *Config) (*SQS, error)
  • func (s *SQS) Delete(ctx context.Context, receiptHandle string) error
  • func (s *SQS) Receive(ctx context.Context) ([]*Message, error)
  • func (s *SQS) Send(ctx context.Context, m json.Marshaler) error

Types

type Config

type Config struct {
	*aws.Config

	MessageGroupId string
	QueueName      string
	QueueURL       string
}

type Message

type Message struct {
	MessageId                        string
	MessageGroupId                   string
	MessageDeduplicationId           string
	SentTimestamp                    time.Time
	SenderId                         string
	SequenceNumber                   string
	Body                             string
	ReceiptHandle                    string
	ApproximateReceiveCount          int
	ApproximateFirstReceiveTimestamp time.Time
}

type SQS

type SQS struct {
	sqsiface.SQSAPI
	// contains filtered or unexported fields
}

func New

func New(config *Config) (*SQS, error)

func (*SQS) Delete

func (s *SQS) Delete(ctx context.Context, receiptHandle string) error

func (*SQS) Receive

func (s *SQS) Receive(ctx context.Context) ([]*Message, error)

func (*SQS) Send

func (s *SQS) Send(ctx context.Context, m json.Marshaler) error