cloud

type Attribute struct {
	Key   string
	Value string
	Type  string
}

type Config struct {
	Address string
	Region  string
	Profile string
	ID      string
	Secret  string
}

type Message struct {
	ID            string
	ReceiptHandle string
	Body          string
	Attributes    map[string]string
}

type MessageClient interface {
	// Creates a new long polling queue and returns its URL.
	CreateQueue(ctx context.Context, queueName string, isDLX bool) (string, error)
	// Get a queue ARN.
	QueueARN(ctx context.Context, queueURL string) (string, error)
	// Binds a DLX queue to a normal queue.
	BindDLX(ctx context.Context, queueURL, dlxARN string) error
	// Send a message to queue and returns its message ID.
	Send(ctx context.Context, req *SendRequest) (string, error)
	// Long polls given amount of messages from a queue.
	Receive(ctx context.Context, queueURL string) (*Message, error)
	// Deletes a message from a queue.
	Delete(ctx context.Context, queueURL, rcvHandle string) error
}

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

type SQSConfig struct {
	Address   string
	Region    string
	Profile   string
	AwsKey    string
	AwsSecret string
	QueueName string
}

type SendRequest struct {
	QueueURL   string
	Body       string
	Attributes []Attribute
}