sqs

Documentation

Index

• type AwsClient
• type Queue
  • func NewQueue(client AwsClient, queueUrl string, attributes, tags map[string]string) Queue
  • func (e Queue) GetAttributes() map[string]string
  • func (e Queue) GetName() string
  • func (e Queue) GetTagValue(tag string) string
  • func (e Queue) GetTags() map[string]string
• type SqsRepository
  • func NewSqsRepository(ctx context.Context, client AwsClient) *SqsRepository
  • func (r *SqsRepository) GetQueueTags(queueUrl string) (map[string]string, error)
  • func (r *SqsRepository) GetRegion() ptypes.AwsRegion
  • func (r *SqsRepository) ListQueuesAll() ([]Queue, error)
  • func (r *SqsRepository) ListQueuesByInput(query *sqs.ListQueuesInput) ([]Queue, error)

Types

type AwsClient

type AwsClient interface {
	GetRegion() ptypes.AwsRegion
	GetAccountID() ptypes.AwsAccountID
	SQS() *sqs.Client
}

type Queue

type Queue struct {
	service.AbstractResource
	QueueUrl   string
	Attributes map[string]string
	Tags       map[string]string
}

func NewQueue

func NewQueue(client AwsClient, queueUrl string, attributes, tags map[string]string) Queue

func (Queue) GetAttributes

func (e Queue) GetAttributes() map[string]string

func (Queue) GetName

func (e Queue) GetName() string

func (Queue) GetTagValue

func (e Queue) GetTagValue(tag string) string

func (Queue) GetTags

func (e Queue) GetTags() map[string]string

type SqsRepository

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

func NewSqsRepository

func NewSqsRepository(ctx context.Context, client AwsClient) *SqsRepository

func (*SqsRepository) GetQueueTags

func (r *SqsRepository) GetQueueTags(queueUrl string) (map[string]string, error)

func (*SqsRepository) GetRegion

func (r *SqsRepository) GetRegion() ptypes.AwsRegion

func (*SqsRepository) ListQueuesAll

func (r *SqsRepository) ListQueuesAll() ([]Queue, error)

func (*SqsRepository) ListQueuesByInput

func (r *SqsRepository) ListQueuesByInput(query *sqs.ListQueuesInput) ([]Queue, error)