sqs

package
v1.17.1 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2021 License: MIT Imports: 11 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	AttributeAll                                   = "All"
	AttributeApproximateNumberOfMessages           = "ApproximateNumberOfMessages"
	AttributeApproximateNumberOfMessagesDelayed    = "ApproximateNumberOfMessagesDelayed"
	AttributeApproximateNumberOfMessagesNotVisible = "ApproximateNumberOfMessagesNotVisible"
	AttributeCreatedTimestamp                      = "CreatedTimestamp"
	AttributeDelaySeconds                          = "DelaySeconds"
	AttributeLastModifiedTimestamp                 = "LastModifiedTimestamp"
	AttributeMaximumMessageSize                    = "MaximumMessageSize"
	AttributeMessageRetentionPeriod                = "MessageRetentionPeriod"
	AttributePolicy                                = "Policy"
	AttributeQueueArn                              = "QueueArn"
	AttributeReceiveMessageWaitTimeSeconds         = "ReceiveMessageWaitTimeSeconds"
	AttributeRedrivePolicy                         = "RedrivePolicy"
	AttributeVisibilityTimeout                     = "VisibilityTimeout"
	AttributeKmsMasterKeyId                        = "KmsMasterKeyId" // nolint
	AttributeKmsDataKeyReusePeriodSeconds          = "KmsDataKeyReusePeriodSeconds"
	AttributeFifoQueue                             = "FifoQueue"
	AttributeContentBasedDeduplication             = "ContentBasedDeduplication"

	AttributeRedrivePolicyDeadLetterTargetArn = "deadLetterTargetArn"
	AttributeRedrivePolicyMaxReceiveCount     = "maxReceiveCount"
)

Attribute names for SQS. ref: https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_GetQueueAttributes.html

Variables

This section is empty.

Functions

This section is empty.

Types

type AttributesResponse added in v1.8.4 

type AttributesResponse struct {
	ApproximateNumberOfMessages           int
	ApproximateNumberOfMessagesDelayed    int
	ApproximateNumberOfMessagesNotVisible int
	CreatedTimestamp                      int
	DelaySeconds                          int
	LastModifiedTimestamp                 int
	MaximumMessageSize                    int
	MessageRetentionPeriod                int
	QueueArn                              string
	ReceiveMessageWaitTimeSeconds         int
	RedrivePolicy                         string
	VisibilityTimeout                     int
}

AttributesResponse contains attributes from GetQueueAttributes.

func NewAttributesResponse added in v1.8.4 

func NewAttributesResponse(apiResponse map[string]*string) AttributesResponse

type FailedResults added in v1.16.0 

type FailedResults struct {
	Send   []*SDK.BatchResultErrorEntry
	Delete []*SDK.BatchResultErrorEntry
}

FailedResults contains failed results of batch request.

type Message added in v0.9.2 

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

Message is SQS Message wrapper struct.

func NewMessage added in v0.9.2 

func NewMessage(msg *SDK.Message) *Message

NewMessage returns initialized *Message.

func (*Message) Body added in v0.9.2 

func (m *Message) Body() string

Body returns message body.

func (*Message) GetMessageID added in v0.9.2 

func (m *Message) GetMessageID() *string

GetMessageID returns pointer of message id.

func (*Message) GetReceiptHandle added in v0.9.2 

func (m *Message) GetReceiptHandle() *string

GetReceiptHandle returns pointer of ReceiptHandle.

func (*Message) String added in v0.9.2 

func (m *Message) String() string

type Queue 

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

Queue is SQS Queue wrapper struct.

func NewQueue 

func NewQueue(svc *SQS, name string, url string) *Queue

NewQueue returns initialized *Queue.

func (*Queue) AddDeleteList 

func (q *Queue) AddDeleteList(msg interface{})

AddDeleteList adds a message to the delete spool.

func (*Queue) AddMessage 

func (q *Queue) AddMessage(message string)

AddMessage adds message to the send spool. This assumes a Standard SQS Queue and not a FifoQueue

func (*Queue) AddMessageJSONMarshal added in v1.0.0 

func (q *Queue) AddMessageJSONMarshal(message interface{}) error

AddMessageJSONMarshal adds message to the send pool with encoding json data.

func (*Queue) AddMessageMap 

func (q *Queue) AddMessageMap(message map[string]interface{}) error

AddMessageMap adds message to the send pool from map data.

func (*Queue) AddMessageWithGroupID added in v1.13.2 

func (q *Queue) AddMessageWithGroupID(message string, messageGroupID string)

AddMessageWithGroupID adds a message to the send spool but adds the required attributes for a SQS FIFO Queue. This assumes the SQS FIFO Queue has ContentBasedDeduplication enabled.

func (*Queue) AutoDelete 

func (q *Queue) AutoDelete(b bool)

AutoDelete sets auto delete flag.

func (*Queue) ChangeMessageVisibility added in v1.0.3 

func (q *Queue) ChangeMessageVisibility(msg *Message, timeoutInSeconds int) error

ChangeMessageVisibility sends the request to AWS api to change visibility of the message.

func (*Queue) ClearFailedResults added in v1.16.0 

func (q *Queue) ClearFailedResults()

ClearFailedResults resets failed results of batch request.

func (*Queue) CountMessage 

func (q *Queue) CountMessage() (visible int, invisible int, err error)

CountMessage sends request to AWS api to counts left messages in the Queue.

func (*Queue) DeleteListItems 

func (q *Queue) DeleteListItems() error

DeleteListItems executes delete operation in the delete spool.

func (*Queue) DeleteMessage 

func (q *Queue) DeleteMessage(msg *Message) error

DeleteMessage sends the request to AWS api to delete the message.

func (*Queue) DeleteMessageWithReceipt added in v1.13.2 

func (q *Queue) DeleteMessageWithReceipt(msgReceipt string) error

DeleteMessageWithReceipt sends the request to AWS api to delete the message.

func (*Queue) Fetch 

func (q *Queue) Fetch(num int) ([]*Message, error)

Fetch fetches message list from the queue with limit.

func (*Queue) FetchBody 

func (q *Queue) FetchBody(num int) []string

FetchBody fetches only the body of messages. ** cannot handle deletion manually as lack of MessageId and ReceiptHandle **

func (*Queue) FetchBodyOne 

func (q *Queue) FetchBodyOne() string

FetchBodyOne fetches the body of a single message. ** cannot handle deletion manually as lack of MessageId and ReceiptHandle **

func (*Queue) FetchOne 

func (q *Queue) FetchOne() (*Message, error)

FetchOne fetches a single message.

func (*Queue) GetAttributes added in v1.8.4 

func (q *Queue) GetAttributes() (AttributesResponse, error)

GetAttributes sends request to AWS api to get the queue's attributes. `AttributeNames` will be set as `All`.

func (*Queue) GetFailedResults added in v1.16.0 

func (q *Queue) GetFailedResults() FailedResults

GetFailedResults gets failed results of batch request.

func (*Queue) Purge 

func (q *Queue) Purge() error

Purge deletes all messages in the Queue.

func (*Queue) Send 

func (q *Queue) Send() error

Send sends messages in the send spool

func (*Queue) SendSingleMessage added in v1.16.1 

func (q *Queue) SendSingleMessage(message string) (string, error)

SendSingleMessage sends a message directly to the SQS immediately and bypasses the spool and batch submits.

func (*Queue) SetExpire 

func (q *Queue) SetExpire(sec int)

SetExpire sets visibility timeout for message.

func (*Queue) SetWaitTimeSeconds added in v1.13.2 

func (q *Queue) SetWaitTimeSeconds(sec int)

SetWaitTimeSeconds sets wait time timeout for message. Setting this value allows for a long polling workflow.

type SQS added in v1.0.0 

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

SQS has SQS client and Queue list.

func New added in v1.0.0 

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

New returns initialized *SQS.

func NewFromSession added in v1.17.0 

func NewFromSession(sess *session.Session) *SQS

NewFromSession returns initialized *SQS from aws.Session.

func (*SQS) CreateQueue added in v1.0.0 

func (svc *SQS) CreateQueue(in *SDK.CreateQueueInput) error

CreateQueue creates new SQS Queue.

func (*SQS) CreateQueueWithName added in v1.0.0 

func (svc *SQS) CreateQueueWithName(name string) error

CreateQueueWithName creates new SQS Queue by given name

func (*SQS) DeleteQueue added in v1.0.0 

func (svc *SQS) DeleteQueue(name string) error

DeleteQueue detes the SQS Queue.

func (*SQS) Errorf added in v1.0.0 

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

Errorf logging error information.

func (*SQS) GetClient added in v1.17.1 

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

GetClient gets aws client.

func (*SQS) GetQueue added in v1.0.0 

func (svc *SQS) GetQueue(name string) (*Queue, error)

GetQueue gets SQS Queue.

func (*SQS) GetQueueAttributes added in v1.8.4 

func (svc *SQS) GetQueueAttributes(url string, attributes ...string) (AttributesResponse, error)

GetQueueAttributes gets the queue's attributes.

func (*SQS) Infof added in v1.0.0 

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

Infof logging information.

func (*SQS) IsExistQueue added in v1.0.0 

func (svc *SQS) IsExistQueue(name string) (bool, error)

IsExistQueue checks if the Queue already exists or not.

func (*SQS) ListAllQueues added in v1.8.2 

func (svc *SQS) ListAllQueues() ([]string, error)

ListQueues gets all of SQS queue list.

func (*SQS) ListQueues added in v1.8.2 

func (svc *SQS) ListQueues(prefix string) ([]string, error)

ListQueues gets SQS queues list.

func (*SQS) SetLogger added in v1.0.0 

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

SetLogger sets logger.

func (*SQS) SetPrefix added in v1.3.1 

func (svc *SQS) SetPrefix(prefix string)

SetPrefix sets prefix.

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.