sqs

type ConsumerError struct {
	MsgID string
	Value error
}

type MessageSinkConfig struct {
	Client   Queue
	QueueURL *string
}

type MessageSourceConfig struct {
	// WaitSeconds is the wait time in seconds to wait between API polling requests.
	// If used, will make fewer requests per day which results in smaller AWS bill.
	// Defaults to 0 which effectively disables this.
	WaitSeconds time.Duration
	Client      Queue
	QueueURL    string
}

type Queue interface {
	ReceiveMessage(*awsSQS.ReceiveMessageInput) (*awsSQS.ReceiveMessageOutput, error)
	DeleteMessage(*awsSQS.DeleteMessageInput) (*awsSQS.DeleteMessageOutput, error)
	SendMessage(*awsSQS.SendMessageInput) (*awsSQS.SendMessageOutput, error)
}