sqs_service

Documentation

Index

• func New() (sdk.QueueService, error)
• func NewWithClient(client sqsiface.SQSAPI) sdk.QueueService
• type SQSQueueService
  • func (s *SQSQueueService) Complete(queue string, leaseId string) error
  • func (s *SQSQueueService) Receive(options sdk.ReceiveOptions) ([]sdk.NitricTask, error)
  • func (s *SQSQueueService) Send(queue string, task sdk.NitricTask) error
  • func (s *SQSQueueService) SendBatch(queue string, tasks []sdk.NitricTask) (*sdk.SendBatchResponse, error)

Functions

func New

func New() (sdk.QueueService, error)

func NewWithClient

func NewWithClient(client sqsiface.SQSAPI) sdk.QueueService

Types

type SQSQueueService

type SQSQueueService struct {
	sdk.UnimplementedQueuePlugin
	// contains filtered or unexported fields
}

func (*SQSQueueService) Complete

func (s *SQSQueueService) Complete(queue string, leaseId string) error

Completes a previously popped queue item

func (*SQSQueueService) Receive

func (s *SQSQueueService) Receive(options sdk.ReceiveOptions) ([]sdk.NitricTask, error)

func (*SQSQueueService) Send

func (s *SQSQueueService) Send(queue string, task sdk.NitricTask) error

func (*SQSQueueService) SendBatch

func (s *SQSQueueService) SendBatch(queue string, tasks []sdk.NitricTask) (*sdk.SendBatchResponse, error)