sqs

package
v0.3.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2021 License: MIT Imports: 8 Imported by: 0

README

aws-sdk-go-v2-wrapper | SQS

Quick Usage

import (
	"context"

	"github.com/evalphobia/aws-sdk-go-v2-wrapper/config"
	"github.com/evalphobia/aws-sdk-go-v2-wrapper/sqs"
)

func main() {
	svc, err := sqs.New(config.Config{
		AccessKey: "<...>",
		SecretKey: "<...>",
	})
	if err != nil {
		panic(err)
	}
	ctx := context.Background()


	// create queue
	queueName := "my-queue"
	queueURL, err := svc.XCreateQueue(ctx, "my-queue")
	if err != nil {
		panic(err)
	}

	err := svc.XSendMessage(ctx, queueURL, "foo")
	if err != nil {
		panic(err)
	}

	messages, err := svc.XReceiveMessage(ctx, queueURL)
	if err != nil {
		panic(err)
	}


	err = svc.XPurgeQueue(ctx, queueURL)
	if err != nil {
		panic(err)
	}

	err = svc.XPurgeQueueByName(ctx, queueName)
	if err != nil {
		panic(err)
	}

	err = svc.XDeleteQueueByName(ctx, queueName)
	if err != nil {
		panic(err)
	}
	// ...
}

X API

Name Description
XCreateQueue creates a SQS queue.
XDeleteQueue deletes a SQS queue.
XDeleteQueueByName deletes a SQS queue by queue name.
XExistsQueue checks if the SQS queue exists or not.
XGetQueueURL gets a SQS queue url.
XListAllQueueURLs gets all of the SQS queue url.
XPurgeQueue purges message in the queue.
XPurgeQueueByName purges message in the queue by queue name.
XDeleteMessage deletes a message.
XReceiveMessage receives messages.
XReceiveMessageLongPolling receives messages by long polling.
XSendMessage sends a message.
XIsEmptyQueue checks if the queue have any message or not.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchResultErrorEntry 

type BatchResultErrorEntry struct {
	Code        string
	ID          string
	SenderFault bool

	// optional
	Message string
}

type ChangeMessageVisibilityBatchRequest 

type ChangeMessageVisibilityBatchRequest struct {
	Entries  []ChangeMessageVisibilityBatchRequestEntry
	QueueURL string
}

ChangeMessageVisibilityBatchRequest has parameters for `ChangeMessageVisibilityBatch` operation.

func (ChangeMessageVisibilityBatchRequest) ToInput 

func (r ChangeMessageVisibilityBatchRequest) ToInput() *SDK.ChangeMessageVisibilityBatchInput

type ChangeMessageVisibilityBatchRequestEntry 

type ChangeMessageVisibilityBatchRequestEntry struct {
	ID            string
	ReceiptHandle string

	// optional
	VisibilityTimeout int64
}

func (ChangeMessageVisibilityBatchRequestEntry) ToSDK 

func (r ChangeMessageVisibilityBatchRequestEntry) ToSDK() SDK.ChangeMessageVisibilityBatchRequestEntry

type ChangeMessageVisibilityBatchResult 

type ChangeMessageVisibilityBatchResult struct {
	Failed     []BatchResultErrorEntry                   `locationNameList:"BatchResultErrorEntry" type:"list" flattened:"true" required:"true"`
	Successful []ChangeMessageVisibilityBatchResultEntry `locationNameList:"ChangeMessageVisibilityBatchResultEntry" type:"list" flattened:"true" required:"true"`
}

func NewChangeMessageVisibilityBatchResult 

func NewChangeMessageVisibilityBatchResult(o *SDK.ChangeMessageVisibilityBatchResponse) *ChangeMessageVisibilityBatchResult

type ChangeMessageVisibilityBatchResultEntry 

type ChangeMessageVisibilityBatchResultEntry struct {
	ID string
}

type ChangeMessageVisibilityRequest 

type ChangeMessageVisibilityRequest struct {
	QueueURL          string
	ReceiptHandle     string
	VisibilityTimeout int64
}

ChangeMessageVisibilityRequest has parameters for `ChangeMessageVisibility` operation.

func (ChangeMessageVisibilityRequest) ToInput 

func (r ChangeMessageVisibilityRequest) ToInput() *SDK.ChangeMessageVisibilityInput

type ChangeMessageVisibilityResult 

type ChangeMessageVisibilityResult struct{}

func NewChangeMessageVisibilityResult 

func NewChangeMessageVisibilityResult(o *SDK.ChangeMessageVisibilityResponse) *ChangeMessageVisibilityResult

type CreateQueueRequest 

type CreateQueueRequest struct {
	QueueName string

	// optional
	Attributes map[string]string
	Tags       map[string]string
}

CreateQueueRequest has parameters for `CreateQueue` operation.

func (CreateQueueRequest) ToInput 

func (r CreateQueueRequest) ToInput() *SDK.CreateQueueInput

type CreateQueueResult 

type CreateQueueResult struct {
	QueueURL string
}

func NewCreateQueueResult 

func NewCreateQueueResult(o *SDK.CreateQueueResponse) *CreateQueueResult

type DeleteMessageBatchRequest 

type DeleteMessageBatchRequest struct {
	Entries  []DeleteMessageBatchRequestEntry
	QueueURL string
}

DeleteMessageBatchRequest has parameters for `DeleteMessageBatch` operation.

func (DeleteMessageBatchRequest) ToInput 

func (r DeleteMessageBatchRequest) ToInput() *SDK.DeleteMessageBatchInput

type DeleteMessageBatchRequestEntry 

type DeleteMessageBatchRequestEntry struct {
	ID            string
	ReceiptHandle string
}

func (DeleteMessageBatchRequestEntry) ToSDK 

func (r DeleteMessageBatchRequestEntry) ToSDK() SDK.DeleteMessageBatchRequestEntry

type DeleteMessageBatchResult 

type DeleteMessageBatchResult struct {
	Failed     []BatchResultErrorEntry
	Successful []DeleteMessageBatchResultEntry
}

func NewDeleteMessageBatchResult 

func NewDeleteMessageBatchResult(o *SDK.DeleteMessageBatchResponse) *DeleteMessageBatchResult

type DeleteMessageBatchResultEntry 

type DeleteMessageBatchResultEntry struct {
	ID string
}

type DeleteMessageRequest 

type DeleteMessageRequest struct {
	QueueURL      string
	ReceiptHandle string
}

DeleteMessageRequest has parameters for `DeleteMessage` operation.

func (DeleteMessageRequest) ToInput 

func (r DeleteMessageRequest) ToInput() *SDK.DeleteMessageInput

type DeleteMessageResult 

type DeleteMessageResult struct{}

func NewDeleteMessageResult 

func NewDeleteMessageResult(o *SDK.DeleteMessageResponse) *DeleteMessageResult

type DeleteQueueRequest 

type DeleteQueueRequest struct {
	QueueURL string
}

DeleteQueueRequest has parameters for `DeleteQueue` operation.

func (DeleteQueueRequest) ToInput 

func (r DeleteQueueRequest) ToInput() *SDK.DeleteQueueInput

type DeleteQueueResult 

type DeleteQueueResult struct{}

func NewDeleteQueueResult 

func NewDeleteQueueResult(o *SDK.DeleteQueueResponse) *DeleteQueueResult

type GetQueueAttributesRequest 

type GetQueueAttributesRequest struct {
	QueueURL string

	// optional
	AttributeNames []QueueAttributeName
}

GetQueueAttributesRequest has parameters for `GetQueueAttributes` operation.

func (GetQueueAttributesRequest) ToInput 

func (r GetQueueAttributesRequest) ToInput() *SDK.GetQueueAttributesInput

type GetQueueAttributesResult 

type GetQueueAttributesResult struct {
	Attributes map[string]string
}

func NewGetQueueAttributesResult 

func NewGetQueueAttributesResult(o *SDK.GetQueueAttributesResponse) *GetQueueAttributesResult

type GetQueueURLRequest 

type GetQueueURLRequest struct {
	QueueName string

	// optional
	QueueOwnerAWSAccountID string
}

GetQueueURLRequest has parameters for `GetQueueURL` operation.

func (GetQueueURLRequest) ToInput 

func (r GetQueueURLRequest) ToInput() *SDK.GetQueueUrlInput

type GetQueueURLResult 

type GetQueueURLResult struct {
	QueueURL string
}

func NewGetQueueURLResult 

func NewGetQueueURLResult(o *SDK.GetQueueUrlResponse) *GetQueueURLResult

type ListDeadLetterSourceQueuesRequest 

type ListDeadLetterSourceQueuesRequest struct {
	QueueURL string

	// optional
	MaxResults int64
	NextToken  string
}

ListDeadLetterSourceQueuesRequest has parameters for `ListDeadLetterSourceQueues` operation.

func (ListDeadLetterSourceQueuesRequest) ToInput 

func (r ListDeadLetterSourceQueuesRequest) ToInput() *SDK.ListDeadLetterSourceQueuesInput

type ListDeadLetterSourceQueuesResult 

type ListDeadLetterSourceQueuesResult struct {
	NextToken string
	QueueURLs []string
}

func NewListDeadLetterSourceQueuesResult 

func NewListDeadLetterSourceQueuesResult(o *SDK.ListDeadLetterSourceQueuesResponse) *ListDeadLetterSourceQueuesResult

type ListQueueTagsRequest 

type ListQueueTagsRequest struct {
	QueueURL string
}

ListQueueTagsRequest has parameters for `ListQueueTags` operation.

func (ListQueueTagsRequest) ToInput 

func (r ListQueueTagsRequest) ToInput() *SDK.ListQueueTagsInput

type ListQueueTagsResult 

type ListQueueTagsResult struct {
	Tags map[string]string
}

func NewListQueueTagsResult 

func NewListQueueTagsResult(o *SDK.ListQueueTagsResponse) *ListQueueTagsResult

type ListQueuesRequest 

type ListQueuesRequest struct {
	// optional
	MaxResults      int64
	NextToken       string
	QueueNamePrefix string
}

ListQueuesRequest has parameters for `ListQueues` operation.

func (ListQueuesRequest) ToInput 

func (r ListQueuesRequest) ToInput() *SDK.ListQueuesInput

type ListQueuesResult 

type ListQueuesResult struct {
	NextToken string
	QueueURLs []string
}

func NewListQueuesResult 

func NewListQueuesResult(o *SDK.ListQueuesResponse) *ListQueuesResult

type Message 

type Message struct {
	Attributes             map[string]string
	Body                   string
	MD5OfBody              string
	MD5OfMessageAttributes string
	MessageAttributes      map[string]MessageAttributeValue
	MessageID              string
	ReceiptHandle          string
}

type MessageAttributeValue 

type MessageAttributeValue struct {
	DataType string

	// optional
	BinaryValue []byte
	StringValue string

	// Not implemented. Reserved for future use.
	BinaryListValues [][]byte
	StringListValues []string
}

func (MessageAttributeValue) ToSDK 

func (r MessageAttributeValue) ToSDK() SDK.MessageAttributeValue

type MessageSystemAttributeValue 

type MessageSystemAttributeValue struct {
	DataType string

	// optional
	BinaryValue []byte
	StringValue string

	// Not implemented. Reserved for future use.
	BinaryListValues [][]byte
	StringListValues []string
}

func (MessageSystemAttributeValue) ToSDK 

func (r MessageSystemAttributeValue) ToSDK() SDK.MessageSystemAttributeValue

type PurgeQueueRequest 

type PurgeQueueRequest struct {
	QueueURL string
}

PurgeQueueRequest has parameters for `PurgeQueue` operation.

func (PurgeQueueRequest) ToInput 

func (r PurgeQueueRequest) ToInput() *SDK.PurgeQueueInput

type PurgeQueueResult 

type PurgeQueueResult struct{}

func NewPurgeQueueResult 

func NewPurgeQueueResult(o *SDK.PurgeQueueResponse) *PurgeQueueResult

type QueueAttributeName 

type QueueAttributeName string
const (
	QueueAttributeNameAll                                   QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameAll)
	QueueAttributeNamePolicy                                QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNamePolicy)
	QueueAttributeNameVisibilityTimeout                     QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameVisibilityTimeout)
	QueueAttributeNameMaximumMessageSize                    QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameMaximumMessageSize)
	QueueAttributeNameMessageRetentionPeriod                QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameMessageRetentionPeriod)
	QueueAttributeNameApproximateNumberOfMessages           QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameApproximateNumberOfMessages)
	QueueAttributeNameApproximateNumberOfMessagesNotVisible QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameApproximateNumberOfMessagesNotVisible)
	QueueAttributeNameCreatedTimestamp                      QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameCreatedTimestamp)
	QueueAttributeNameLastModifiedTimestamp                 QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameLastModifiedTimestamp)
	QueueAttributeNameQueueArn                              QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameQueueArn)
	QueueAttributeNameApproximateNumberOfMessagesDelayed    QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameApproximateNumberOfMessagesDelayed)
	QueueAttributeNameDelaySeconds                          QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameDelaySeconds)
	QueueAttributeNameReceiveMessageWaitTimeSeconds         QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameReceiveMessageWaitTimeSeconds)
	QueueAttributeNameRedrivePolicy                         QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameRedrivePolicy)
	QueueAttributeNameFifoQueue                             QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameFifoQueue)
	QueueAttributeNameContentBasedDeduplication             QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameContentBasedDeduplication)
	QueueAttributeNameKmsMasterKeyID                        QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameKmsMasterKeyId)
	QueueAttributeNameKmsDataKeyReusePeriodSeconds          QueueAttributeName = QueueAttributeName(SDK.QueueAttributeNameKmsDataKeyReusePeriodSeconds)
)

type ReceiveMessageRequest 

type ReceiveMessageRequest struct {
	QueueURL string

	AttributeNames          []QueueAttributeName
	MaxNumberOfMessages     int64
	MessageAttributeNames   []string
	ReceiveRequestAttemptID string
	VisibilityTimeout       int64
	WaitTimeSeconds         int64

	// set if you want to force to use short polling
	UseShortPolling bool
}

ReceiveMessageRequest has parameters for `ReceiveMessage` operation.

func (ReceiveMessageRequest) ToInput 

func (r ReceiveMessageRequest) ToInput() *SDK.ReceiveMessageInput

type ReceiveMessageResult 

type ReceiveMessageResult struct {
	Messages []Message
}

func NewReceiveMessageResult 

func NewReceiveMessageResult(o *SDK.ReceiveMessageResponse) *ReceiveMessageResult

type SQS 

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

SQS has SQS client.

func New 

func New(conf config.Config) (*SQS, error)

New returns initialized *SQS.

func (*SQS) ChangeMessageVisibility 

func (svc *SQS) ChangeMessageVisibility(ctx context.Context, r ChangeMessageVisibilityRequest) (*ChangeMessageVisibilityResult, error)

ChangeMessageVisibility executes `ChangeMessageVisibility` operation.

func (*SQS) ChangeMessageVisibilityBatch 

func (svc *SQS) ChangeMessageVisibilityBatch(ctx context.Context, r ChangeMessageVisibilityBatchRequest) (*ChangeMessageVisibilityBatchResult, error)

ChangeMessageVisibilityBatch executes `ChangeMessageVisibilityBatch` operation.

func (*SQS) CreateQueue 

func (svc *SQS) CreateQueue(ctx context.Context, r CreateQueueRequest) (*CreateQueueResult, error)

CreateQueue executes `CreateQueue` operation.

func (*SQS) DeleteMessage 

func (svc *SQS) DeleteMessage(ctx context.Context, r DeleteMessageRequest) (*DeleteMessageResult, error)

DeleteMessage executes `DeleteMessage` operation.

func (*SQS) DeleteMessageBatch 

func (svc *SQS) DeleteMessageBatch(ctx context.Context, r DeleteMessageBatchRequest) (*DeleteMessageBatchResult, error)

DeleteMessageBatch executes `DeleteMessageBatch` operation.

func (*SQS) DeleteQueue 

func (svc *SQS) DeleteQueue(ctx context.Context, r DeleteQueueRequest) (*DeleteQueueResult, error)

DeleteQueue executes `DeleteQueue` operation.

func (*SQS) Errorf 

func (svc *SQS) Errorf(format string, v ...interface{})

Errorf logging error information.

func (*SQS) GetClient 

func (svc *SQS) GetClient() *SDK.Client

GetClient gets original SDK client.

func (*SQS) GetQueueAttributes 

func (svc *SQS) GetQueueAttributes(ctx context.Context, r GetQueueAttributesRequest) (*GetQueueAttributesResult, error)

GetQueueAttributes executes `GetQueueAttributes` operation.

func (*SQS) GetQueueURL 

func (svc *SQS) GetQueueURL(ctx context.Context, r GetQueueURLRequest) (*GetQueueURLResult, error)

GetQueueURL executes `GetQueueURL` operation.

func (*SQS) Infof 

func (svc *SQS) Infof(format string, v ...interface{})

Infof logging information.

func (*SQS) ListDeadLetterSourceQueues 

func (svc *SQS) ListDeadLetterSourceQueues(ctx context.Context, r ListDeadLetterSourceQueuesRequest) (*ListDeadLetterSourceQueuesResult, error)

ListDeadLetterSourceQueues executes `ListDeadLetterSourceQueues` operation.

func (*SQS) ListQueueTags 

func (svc *SQS) ListQueueTags(ctx context.Context, r ListQueueTagsRequest) (*ListQueueTagsResult, error)

ListQueueTags executes `ListQueueTags` operation.

func (*SQS) ListQueues 

func (svc *SQS) ListQueues(ctx context.Context, r ListQueuesRequest) (*ListQueuesResult, error)

ListQueues executes `ListQueues` operation.

func (*SQS) PurgeQueue 

func (svc *SQS) PurgeQueue(ctx context.Context, r PurgeQueueRequest) (*PurgeQueueResult, error)

PurgeQueue executes `PurgeQueue` operation.

func (*SQS) RawAddPermission 

func (svc *SQS) RawAddPermission(ctx context.Context, in *SDK.AddPermissionInput) (*SDK.AddPermissionResponse, error)

RawAddPermission executes `AddPermission` raw operation.

func (*SQS) RawChangeMessageVisibility 

func (svc *SQS) RawChangeMessageVisibility(ctx context.Context, in *SDK.ChangeMessageVisibilityInput) (*SDK.ChangeMessageVisibilityResponse, error)

RawChangeMessageVisibility executes `ChangeMessageVisibility` raw operation.

func (*SQS) RawChangeMessageVisibilityBatch 

func (svc *SQS) RawChangeMessageVisibilityBatch(ctx context.Context, in *SDK.ChangeMessageVisibilityBatchInput) (*SDK.ChangeMessageVisibilityBatchResponse, error)

RawChangeMessageVisibilityBatch executes `ChangeMessageVisibilityBatch` raw operation.

func (*SQS) RawCreateQueue 

func (svc *SQS) RawCreateQueue(ctx context.Context, in *SDK.CreateQueueInput) (*SDK.CreateQueueResponse, error)

RawCreateQueue executes `CreateQueue` raw operation.

func (*SQS) RawDeleteMessage 

func (svc *SQS) RawDeleteMessage(ctx context.Context, in *SDK.DeleteMessageInput) (*SDK.DeleteMessageResponse, error)

RawDeleteMessage executes `DeleteMessage` raw operation.

func (*SQS) RawDeleteMessageBatch 

func (svc *SQS) RawDeleteMessageBatch(ctx context.Context, in *SDK.DeleteMessageBatchInput) (*SDK.DeleteMessageBatchResponse, error)

RawDeleteMessageBatch executes `DeleteMessageBatch` raw operation.

func (*SQS) RawDeleteQueue 

func (svc *SQS) RawDeleteQueue(ctx context.Context, in *SDK.DeleteQueueInput) (*SDK.DeleteQueueResponse, error)

RawDeleteQueue executes `DeleteQueue` raw operation.

func (*SQS) RawGetQueueAttributes 

func (svc *SQS) RawGetQueueAttributes(ctx context.Context, in *SDK.GetQueueAttributesInput) (*SDK.GetQueueAttributesResponse, error)

RawGetQueueAttributes executes `GetQueueAttributes` raw operation.

func (*SQS) RawGetQueueUrl 

func (svc *SQS) RawGetQueueUrl(ctx context.Context, in *SDK.GetQueueUrlInput) (*SDK.GetQueueUrlResponse, error)

RawGetQueueUrl executes `GetQueueUrl` raw operation.

func (*SQS) RawListDeadLetterSourceQueues 

func (svc *SQS) RawListDeadLetterSourceQueues(ctx context.Context, in *SDK.ListDeadLetterSourceQueuesInput) (*SDK.ListDeadLetterSourceQueuesResponse, error)

RawListDeadLetterSourceQueues executes `ListDeadLetterSourceQueues` raw operation.

func (*SQS) RawListQueueTags 

func (svc *SQS) RawListQueueTags(ctx context.Context, in *SDK.ListQueueTagsInput) (*SDK.ListQueueTagsResponse, error)

RawListQueueTags executes `ListQueueTags` raw operation.

func (*SQS) RawListQueues 

func (svc *SQS) RawListQueues(ctx context.Context, in *SDK.ListQueuesInput) (*SDK.ListQueuesResponse, error)

RawListQueues executes `ListQueues` raw operation.

func (*SQS) RawPurgeQueue 

func (svc *SQS) RawPurgeQueue(ctx context.Context, in *SDK.PurgeQueueInput) (*SDK.PurgeQueueResponse, error)

RawPurgeQueue executes `PurgeQueue` raw operation.

func (*SQS) RawReceiveMessage 

func (svc *SQS) RawReceiveMessage(ctx context.Context, in *SDK.ReceiveMessageInput) (*SDK.ReceiveMessageResponse, error)

RawReceiveMessage executes `ReceiveMessage` raw operation.

func (*SQS) RawRemovePermission 

func (svc *SQS) RawRemovePermission(ctx context.Context, in *SDK.RemovePermissionInput) (*SDK.RemovePermissionResponse, error)

RawRemovePermission executes `RemovePermission` raw operation.

func (*SQS) RawSendMessage 

func (svc *SQS) RawSendMessage(ctx context.Context, in *SDK.SendMessageInput) (*SDK.SendMessageResponse, error)

RawSendMessage executes `SendMessage` raw operation.

func (*SQS) RawSendMessageBatch 

func (svc *SQS) RawSendMessageBatch(ctx context.Context, in *SDK.SendMessageBatchInput) (*SDK.SendMessageBatchResponse, error)

RawSendMessageBatch executes `SendMessageBatch` raw operation.

func (*SQS) RawSetQueueAttributes 

func (svc *SQS) RawSetQueueAttributes(ctx context.Context, in *SDK.SetQueueAttributesInput) (*SDK.SetQueueAttributesResponse, error)

RawSetQueueAttributes executes `SetQueueAttributes` raw operation.

func (*SQS) RawTagQueue 

func (svc *SQS) RawTagQueue(ctx context.Context, in *SDK.TagQueueInput) (*SDK.TagQueueResponse, error)

RawTagQueue executes `TagQueue` raw operation.

func (*SQS) RawUntagQueue 

func (svc *SQS) RawUntagQueue(ctx context.Context, in *SDK.UntagQueueInput) (*SDK.UntagQueueResponse, error)

RawUntagQueue executes `UntagQueue` raw operation.

func (*SQS) ReceiveMessage 

func (svc *SQS) ReceiveMessage(ctx context.Context, r ReceiveMessageRequest) (*ReceiveMessageResult, error)

ReceiveMessage executes `ReceiveMessage` operation.

func (*SQS) SendMessage 

func (svc *SQS) SendMessage(ctx context.Context, r SendMessageRequest) (*SendMessageResult, error)

SendMessage executes `SendMessage` operation.

func (*SQS) SendMessageBatch 

func (svc *SQS) SendMessageBatch(ctx context.Context, r SendMessageBatchRequest) (*SendMessageBatchResult, error)

SendMessageBatch executes `SendMessageBatch` operation.

func (*SQS) SetLogger 

func (svc *SQS) SetLogger(logger log.Logger)

SetLogger sets logger.

func (*SQS) SetQueueAttributes 

func (svc *SQS) SetQueueAttributes(ctx context.Context, r SetQueueAttributesRequest) (*SetQueueAttributesResult, error)

SetQueueAttributes executes `SetQueueAttributes` operation.

func (*SQS) XCreateQueue 

func (svc *SQS) XCreateQueue(ctx context.Context, queueName string) (queueURL string, err error)

XCreateQueue creates a SQS queue.

func (*SQS) XDeleteMessage 

func (svc *SQS) XDeleteMessage(ctx context.Context, queueURL, receiptHandle string) error

XDeleteMessage deletes a message.

func (*SQS) XDeleteQueue 

func (svc *SQS) XDeleteQueue(ctx context.Context, queueURL string) error

XDeleteQueue deletes a SQS queue.

func (*SQS) XDeleteQueueByName 

func (svc *SQS) XDeleteQueueByName(ctx context.Context, queueName string) error

XDeleteQueueByName delete a SQS queue by queue name.

func (*SQS) XExistsQueue 

func (svc *SQS) XExistsQueue(ctx context.Context, queueName string) (bool, error)

XExistsQueue checks if the SQS queue exists or not.

func (*SQS) XGetQueueURL 

func (svc *SQS) XGetQueueURL(ctx context.Context, queueName string) (queueURL string, err error)

XGetQueueURL gets a SQS queue url.

func (*SQS) XIsEmptyQueue 

func (svc *SQS) XIsEmptyQueue(ctx context.Context, queueURL string) (bool, error)

XIsEmptyQueue checks if the queue does not have any message.

func (*SQS) XListAllQueueURLs 

func (svc *SQS) XListAllQueueURLs(ctx context.Context, queuePrefix string) (queueURLs []string, err error)

XListAllQueueURLs lists all of the SQS queue url.

func (*SQS) XPurgeQueue 

func (svc *SQS) XPurgeQueue(ctx context.Context, queueURL string) error

XPurgeQueue purges messages of the queue.

func (*SQS) XPurgeQueueByName 

func (svc *SQS) XPurgeQueueByName(ctx context.Context, queueName string) error

XPurgeQueueByName purges messages of the queue by queue name.

func (*SQS) XReceiveMessage 

func (svc *SQS) XReceiveMessage(ctx context.Context, queueURL string) ([]Message, error)

XReceiveMessage receives messages.

func (*SQS) XReceiveMessageLongPolling 

func (svc *SQS) XReceiveMessageLongPolling(ctx context.Context, queueURL string, waitSec int64) ([]Message, error)

XReceiveMessageLongPolling receives messages with long polling.

func (*SQS) XSendMessage 

func (svc *SQS) XSendMessage(ctx context.Context, queueURL, message string) error

XSendMessage sends a message.

func (*SQS) XSendMessageBatch 

func (svc *SQS) XSendMessageBatch(ctx context.Context, queueURL string, messages []string) (XSendMessageBatchResult, error)

XSendMessageBatch sends messages.

type SendMessageBatchRequest 

type SendMessageBatchRequest struct {
	Entries  []SendMessageBatchRequestEntry
	QueueURL string
}

SendMessageBatchRequest has parameters for `SendMessageBatch` operation.

func (SendMessageBatchRequest) ToInput 

func (r SendMessageBatchRequest) ToInput() *SDK.SendMessageBatchInput

type SendMessageBatchRequestEntry 

type SendMessageBatchRequestEntry struct {
	ID          string
	MessageBody string

	// for FIFO
	MessageDeduplicationID string
	MessageGroupID         string

	DelaySeconds            int64
	MessageAttributes       map[string]MessageAttributeValue
	MessageSystemAttributes map[string]MessageSystemAttributeValue
}

func (SendMessageBatchRequestEntry) ToSDK 

func (r SendMessageBatchRequestEntry) ToSDK() SDK.SendMessageBatchRequestEntry

type SendMessageBatchResult 

type SendMessageBatchResult struct {
	Failed     []BatchResultErrorEntry
	Successful []SendMessageBatchResultEntry
}

func NewSendMessageBatchResult 

func NewSendMessageBatchResult(o *SDK.SendMessageBatchResponse) *SendMessageBatchResult

type SendMessageBatchResultEntry 

type SendMessageBatchResultEntry struct {
	ID               string
	MD5OfMessageBody string
	MessageID        string

	// for FIFO
	SequenceNumber string

	MD5OfMessageAttributes       string
	MD5OfMessageSystemAttributes string
}

type SendMessageRequest 

type SendMessageRequest struct {
	MessageBody string
	QueueURL    string

	// for FIFO
	MessageDeduplicationID string
	MessageGroupID         string

	DelaySeconds            int64
	MessageAttributes       map[string]MessageAttributeValue
	MessageSystemAttributes map[string]MessageSystemAttributeValue
}

SendMessageRequest has parameters for `SendMessage` operation.

func (SendMessageRequest) ToInput 

func (r SendMessageRequest) ToInput() *SDK.SendMessageInput

type SendMessageResult 

type SendMessageResult struct {
	MD5OfMessageAttributes       string
	MD5OfMessageBody             string
	MD5OfMessageSystemAttributes string
	MessageID                    string

	// for FIFO
	SequenceNumber string
}

func NewSendMessageResult 

func NewSendMessageResult(o *SDK.SendMessageResponse) *SendMessageResult

type SetQueueAttributesRequest 

type SetQueueAttributesRequest struct {
	Attributes map[string]string
	QueueURL   string
}

SetQueueAttributesRequest has parameters for `SetQueueAttributes` operation.

func (SetQueueAttributesRequest) ToInput 

func (r SetQueueAttributesRequest) ToInput() *SDK.SetQueueAttributesInput

type SetQueueAttributesResult 

type SetQueueAttributesResult struct{}

func NewSetQueueAttributesResult 

func NewSetQueueAttributesResult(o *SDK.SetQueueAttributesResponse) *SetQueueAttributesResult

type XSendMessageBatchResult 

type XSendMessageBatchResult struct {
	// `[]int` contains slice index of success/fail messages
	Success []int
	Failed  []int

	FailEntries []BatchResultErrorEntry
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.