Versions in this module Expand all Collapse all v0 v0.1.0 Jan 11, 2025 Changes in this version + var NewSQSReceiverFunc = func() (awsinterfaces.SQSReceiver, *session.Session, error) + var NewSQSSenderFunc = func() (awsinterfaces.SQSSender, error) + func NewBatchedTopic(queueURL string, timeout ...time.Duration) (batching.Batcher, error) + func NewServer(queueURL string, cl int, retryTimeout int64, opts ...Option) (msg.Server, error) + func NewTopic(queueURL string) (msg.Topic, error) + type ErrThrottleServer struct + Duration time.Duration + Message string + func (e ErrThrottleServer) Error() string + type MessageWriter struct + func (w *MessageWriter) Attributes() *msg.Attributes + func (w *MessageWriter) Close() error + func (w *MessageWriter) SetDelay(delay time.Duration) + func (w *MessageWriter) Write(p []byte) (int, error) + type Option func(*Server) error + func WithCustomRetryer(r request.Retryer) Option + func WithRetries(delay time.Duration, max int) Option + func WithRetryJitter(retryJitter int64) Option + type Server struct + QueueURL string + Svc awsinterfaces.SQSReceiver + func (s *Server) Serve(r msg.Receiver) error + func (s *Server) Shutdown(ctx context.Context) error + type Topic struct + Batcher batching.Batcher + QueueURL string + Svc awsinterfaces.SQSSender + func (t *Topic) NewWriter(ctx context.Context) msg.MessageWriter
Go to main page