producer

Documentation

Index

• type ProducerClient
  • func NewProducerClient(sqsClient SQSAPI, queueUrl *string, logger *zap.Logger) *ProducerClient
  • func (p *ProducerClient) SendMessage(ctx context.Context, body string, ...) error
  • func (p *ProducerClient) SendMessagesBatch(ctx context.Context, messages []*sqs.SendMessageBatchRequestEntry) error
• type SQSAPI

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)
}