queue

Documentation

Index

• func SQSQueueName(name string) func(*SQS)
• func SQSSession(session *baseAWS.Session) func(*SQS)
• func SQSSetup(ctx context.Context, options ...func(*SQS)) error
• type SQS
  • func NewSQS(options ...func(*SQS)) (*SQS, error)
  • func (s *SQS) Pull(ctx context.Context, fn func(context.Context, []byte) error) error
  • func (s *SQS) Push(ctx context.Context, content []byte) error

Functions

func SQSQueueName

func SQSQueueName(name string) func(*SQS)

SQSQueueName set the queue name.

func SQSSession

func SQSSession(session *baseAWS.Session) func(*SQS)

SQSSession set the AWS Session.

func SQSSetup

func SQSSetup(ctx context.Context, options ...func(*SQS)) error

SQSSetup is used to create the queues if not exists.

Types

type SQS

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

SQS returns a new client to interact with a SQS queue.

func NewSQS

func NewSQS(options ...func(*SQS)) (*SQS, error)

NewSQS returns a configured SQS client.

func (*SQS) Pull

func (s *SQS) Pull(ctx context.Context, fn func(context.Context, []byte) error) error

Pull a message from SQS and send it to be processed.

func (*SQS) Push

func (s *SQS) Push(ctx context.Context, content []byte) error

Push content to SQS queue.