sqs_service

Documentation

Index

• Constants
• func New(provider core.AwsProvider) (queue.QueueService, error)
• func NewWithClient(provider core.AwsProvider, client sqsiface.SQSAPI) queue.QueueService
• type SQSQueueService
  • func (s *SQSQueueService) Complete(ctx context.Context, q string, leaseId string) error
  • func (s *SQSQueueService) Receive(ctx context.Context, options queue.ReceiveOptions) ([]queue.NitricTask, error)
  • func (s *SQSQueueService) Send(ctx context.Context, queueName string, task queue.NitricTask) error
  • func (s *SQSQueueService) SendBatch(ctx context.Context, queueName string, tasks []queue.NitricTask) (*queue.SendBatchResponse, error)

Constants

const (
	// ErrCodeNoSuchTagSet - AWS API neglects to include a constant for this error code.
	ErrCodeNoSuchTagSet = "NoSuchTagSet"
	ErrCodeAccessDenied = "AccessDenied"
)

Functions

func New

func New(provider core.AwsProvider) (queue.QueueService, error)

func NewWithClient

func NewWithClient(provider core.AwsProvider, client sqsiface.SQSAPI) queue.QueueService

Types

type SQSQueueService

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

func (*SQSQueueService) Complete

func (s *SQSQueueService) Complete(ctx context.Context, q string, leaseId string) error

Completes a previously popped queue item

func (*SQSQueueService) Receive

func (s *SQSQueueService) Receive(ctx context.Context, options queue.ReceiveOptions) ([]queue.NitricTask, error)

func (*SQSQueueService) Send

func (s *SQSQueueService) Send(ctx context.Context, queueName string, task queue.NitricTask) error

func (*SQSQueueService) SendBatch

func (s *SQSQueueService) SendBatch(ctx context.Context, queueName string, tasks []queue.NitricTask) (*queue.SendBatchResponse, error)