# README
Queue
A package that provides queue implementations for Redis, SQS, Memory and No-op.
| Name | Example url |
|---|---|
| Redis | redis://localhost:6380/key |
| SQS | https://sqs-host.amazonaws.com/account/name |
| Memory | memory:// |
| No-op | noop:// |
Licence
The MIT License (MIT)
Copyright (c) 2022 Scott Barr
See LICENSE
# Functions
BatchMessages splits a []Message slice into batches of a given size.
BuildMessageFromSQSEventsMessage converts an events.SQSMessage into a Message.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
NewSQSFIFOQueue returna a new SQSQueue configued to interact with a FIFO queue.
NewSQSQuere returns a new SQSQueue.
No description provided by the author
# Constants
SQSDefaultMaxMessages is used to take the maximum messages permitted.
SQSDefaultWaitTime is to specify the maximum time permitted to listen for messages from SQS.
SQSQueueAttributeTrace is the optional SQS Message attribute that holds a trace ID.
SQSTypeString is used to state the data type of an SQS Message attribute.
# Structs
ChannelQueue is a queue that manages messages over a channel.
No description provided by the author
Message is carries message data to and from queue implementations.
No description provided by the author
RedisQueue works with a Redis instance to satisfy most of the Queue unterface, except.
RedisQueue works with a Redis instance to satisfy most of the Queue unterface, except.
SQSQueue is provides access to AWS SQS.
No description provided by the author
# Interfaces
No description provided by the author
BatchEnqueuer is an interface for queueing batches of messages.
Enqueuer is an interface for queueing messages.
Queue is the complete interface for a read/write, relaible QuUeue.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author