Versions in this module Expand all Collapse all v1 v1.40.0 Nov 22, 2024 v1.39.0 Nov 11, 2024 Changes in this version + type MsgHandler func(msg types.Message) + type Publisher struct + func NewPublisher(sqsClient *sqs.Client, queueURL string) *Publisher + func (p *Publisher) Publish(ctx context.Context, msg *sqs.SendMessageInput) (*sqs.SendMessageOutput, error) + type SQSClient interface + ReceiveMessage func(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error) + type Subscriber struct + func NewSubscriber(c SubscriberConfig) *Subscriber + func (s *Subscriber) Subscribe(ctx context.Context) chan error + func (s *Subscriber) Unsubscribe() error + type SubscriberConfig struct + MsgHandler MsgHandler + SQSClient *sqs.Client + SQSConfig pubsub.SQS
Go to main page