queue

Documentation

Index

• func New(provider resource.AwsResourceResolver) (queuespb.QueuesServer, error)
• func NewWithClient(provider resource.AwsResourceResolver, client sqsiface.SQSAPI) queuespb.QueuesServer
• type SQSQueueService
  • func (s *SQSQueueService) Complete(ctx context.Context, req *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)
  • func (s *SQSQueueService) Dequeue(ctx context.Context, req *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)
  • func (s *SQSQueueService) Enqueue(ctx context.Context, req *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, error)

Functions

func New

func New(provider resource.AwsResourceResolver) (queuespb.QueuesServer, error)

func NewWithClient

func NewWithClient(provider resource.AwsResourceResolver, client sqsiface.SQSAPI) queuespb.QueuesServer

Types

type SQSQueueService

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

func (*SQSQueueService) Complete

func (s *SQSQueueService) Complete(ctx context.Context, req *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)

Completes a previously popped queue item

func (*SQSQueueService) Dequeue

func (s *SQSQueueService) Dequeue(ctx context.Context, req *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)

func (*SQSQueueService) Enqueue

func (s *SQSQueueService) Enqueue(ctx context.Context, req *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, error)