Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProducerClient ¶
type ProducerClient struct {
// contains filtered or unexported fields
}
func NewProducerClient ¶
func NewProducerClient(sqsClient SQSAPI, queueUrl *string, logger *zap.Logger) *ProducerClient
func (*ProducerClient) SendMessage ¶
func (p *ProducerClient) SendMessage(ctx context.Context, body string, attributes map[string]*sqs.MessageAttributeValue) error
Send a single message
func (*ProducerClient) SendMessagesBatch ¶
func (p *ProducerClient) SendMessagesBatch(ctx context.Context, messages []*sqs.SendMessageBatchRequestEntry) error
Send messages in batches
type SQSAPI ¶
type SQSAPI interface {
SendMessageWithContext(ctx aws.Context, input *sqs.SendMessageInput, opts ...request.Option) (*sqs.SendMessageOutput, error)
SendMessageBatchWithContext(ctx aws.Context, input *sqs.SendMessageBatchInput, opts ...request.Option) (*sqs.SendMessageBatchOutput, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.