Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewServer ¶
NewServer creates and initializes a new Server using queueURL to a SQS queue `cl` represents the number of concurrent message receives (10 msgs each).
AWS credentials (AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY) are assumed to be set as environment variables.
SQS_ENDPOINT can be set as an environment variable in order to override the aws.Client's Configured Endpoint
Types ¶
type ErrThrottleServer ¶
ErrThrottleServer signals that the server should sleep for the duration time before resuming work.
func (ErrThrottleServer) Error ¶
func (e ErrThrottleServer) Error() string
type MessageWriter ¶
type MessageWriter struct {
msg.MessageWriter
// contains filtered or unexported fields
}
MessageWriter writes data to a SQS Queue.
func (*MessageWriter) Attributes ¶
func (w *MessageWriter) Attributes() *msg.Attributes
Attributes returns the msg.Attributes associated with the MessageWriter
func (*MessageWriter) Close ¶
func (w *MessageWriter) Close() error
Close converts it's buffered data and attributes to an SQS message and publishes it to a queue.
Once a MessageWriter is closed, it cannot be used again.
func (*MessageWriter) SetDelay ¶
func (w *MessageWriter) SetDelay(delay time.Duration)
SetDelay sets a delay on the Message. The delay must be between 0 and 900 seconds, according to the aws sdk.
type Option ¶
Option is the signature that modifies a `Server` to set some configuration
func WithCustomRetryer ¶
WithCustomRetryer sets a custom `Retryer` to use on the SQS client.
func WithRetries ¶
WithRetries makes the `Server` retry on credential errors until `max` attempts with `delay` seconds between requests. This is needed in scenarios where credentials are automatically generated and the program starts before AWS finishes propagating them
func WithRetryJitter ¶
WithRetryJitter sets a value for Jitter on the VisibilityTimeout. With jitter applied every message that needs to be retried will have a visibility timeout in the interval: [(visibilityTimeout - jitter), visibilityTimeout + jitter)]
type Server ¶
type Server struct {
// AWS QueueURL
QueueURL string
// Concrete instance of SQSAPI
Svc sqsiface.SQSAPI
// contains filtered or unexported fields
}
Server represents a msg.Server for receiving messages from an AWS SQS Queue.
func (*Server) Serve ¶
Serve continuously receives messages from an SQS queue, creates a message, and calls Receive on `r`. Serve is blocking and will not return until Shutdown is called on the Server.
NewServer should be used prior to running Serve.
Source Files