sqs

Documentation

Index

• type SQSService
  • func NewSQSService(cfgApplication *config.Config, log logger.Logger) (*SQSService, error)
  • func (s *SQSService) DeleteMessage(ctx context.Context, receiptHandle string) error
  • func (s *SQSService) ReceiveMessage(ctx context.Context) ([]model.Message, error)
  • func (s *SQSService) SendMessage(ctx context.Context, message model.Message) error

Types

type SQSService

type SQSService struct {
	Client port.SQSClientInterface
	Config *config.Config
	Log    logger.Logger
}

func NewSQSService

func NewSQSService(cfgApplication *config.Config, log logger.Logger) (*SQSService, error)

func (*SQSService) DeleteMessage

func (s *SQSService) DeleteMessage(ctx context.Context, receiptHandle string) error

func (*SQSService) ReceiveMessage

func (s *SQSService) ReceiveMessage(ctx context.Context) ([]model.Message, error)

func (*SQSService) SendMessage

func (s *SQSService) SendMessage(ctx context.Context, message model.Message) error