sqs

type MsgHandler func(msg types.Message)

type Publisher struct {
	// contains filtered or unexported fields
}

type SQSClient interface {
	ReceiveMessage(
		ctx context.Context,
		params *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
}

type Subscriber struct {
	// contains filtered or unexported fields
}

type SubscriberConfig struct {
	SQSClient  *sqs.Client
	MsgHandler MsgHandler
	SQSConfig  pubsub.SQS
}