sqs

type AddPermissionInput struct {
	QueueURL      string
	Region        string
	Label         string
	Actions       []string
	AWSAccountIDs []string
}

type BatchErrorEntry struct {
	ID          string `xml:"Id"`
	Code        string `xml:"Code"`
	Message     string `xml:"Message"`
	SenderFault bool   `xml:"SenderFault"`
}

type BatchResultEntry struct {
	ID string `xml:"Id"`
}

type BatchResultErrorEntry struct {
	ID          string
	Code        string
	Message     string
	SenderFault bool
}

type CancelMessageMoveTaskInput struct {
	TaskHandle string
}

type CancelMessageMoveTaskOutput struct {
	ApproximateNumberOfMessagesMoved int64
}

type ChangeMessageVisibilityBatchInput struct {
	QueueURL string
	Region   string
	Entries  []ChangeMessageVisibilityBatchRequestEntry
}

type ChangeMessageVisibilityBatchOutput struct {
	Successful []BatchResultEntry
	Failed     []BatchErrorEntry
}

type ChangeMessageVisibilityBatchRequestEntry struct {
	ID                string
	ReceiptHandle     string
	VisibilityTimeout int
}

type ChangeMessageVisibilityBatchResponse struct {
	XMLName          xml.Name                           `xml:"ChangeMessageVisibilityBatchResponse"`
	ResponseMetadata XMLResponseMetadata                `xml:"ResponseMetadata"`
	Xmlns            string                             `xml:"xmlns,attr"`
	Result           ChangeMessageVisibilityBatchResult `xml:"ChangeMessageVisibilityBatchResult"`
}

type ChangeMessageVisibilityBatchResult struct {
	Successful []BatchResultEntry `xml:"ChangeMessageVisibilityBatchResultEntry"`
	Failed     []BatchErrorEntry  `xml:"BatchResultErrorEntry"`
}

type ChangeMessageVisibilityInput struct {
	QueueURL          string
	Region            string
	ReceiptHandle     string
	VisibilityTimeout int
}

type ChangeMessageVisibilityResponse struct {
	XMLName          xml.Name            `xml:"ChangeMessageVisibilityResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
}

type CreateQueueInput struct {
	Attributes map[string]string
	Tags       map[string]string
	QueueName  string
	Endpoint   string
	// Scheme is the URL scheme ("http" or "https") to use when constructing
	// the queue URL. Defaults to "http" when empty for backwards
	// compatibility, but callers should pass "https" when the request was
	// served over TLS so the returned QueueURL matches AWS conventions.
	Scheme string
	// Region is the AWS region for ARN construction (optional; defaults to backend region).
	Region string
}

type CreateQueueOutput struct {
	QueueURL string
}

type CreateQueueResponse struct {
	XMLName           xml.Name            `xml:"CreateQueueResponse"`
	CreateQueueResult CreateQueueResult   `xml:"CreateQueueResult"`
	ResponseMetadata  XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns             string              `xml:"xmlns,attr"`
}

type CreateQueueResult struct {
	QueueURL string `xml:"QueueUrl"`
}

type DeleteMessageBatchEntry struct {
	ID            string
	ReceiptHandle string
}

type DeleteMessageBatchInput struct {
	QueueURL string
	Region   string
	Entries  []DeleteMessageBatchEntry
}

type DeleteMessageBatchOutput struct {
	Successful []DeleteMessageBatchResultEntry
	Failed     []BatchResultErrorEntry
}

type DeleteMessageBatchResponse struct {
	XMLName                  xml.Name                    `xml:"DeleteMessageBatchResponse"`
	ResponseMetadata         XMLResponseMetadata         `xml:"ResponseMetadata"`
	Xmlns                    string                      `xml:"xmlns,attr"`
	DeleteMessageBatchResult XMLDeleteMessageBatchResult `xml:"DeleteMessageBatchResult"`
}

type DeleteMessageBatchResultEntry struct {
	ID string
}

type DeleteMessageInput struct {
	QueueURL      string
	Region        string
	ReceiptHandle string
}

type DeleteMessageResponse struct {
	XMLName          xml.Name            `xml:"DeleteMessageResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
}

type DeleteQueueInput struct {
	QueueURL string
	Region   string
}

type DeleteQueueResponse struct {
	XMLName          xml.Name            `xml:"DeleteQueueResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
}

type GetQueueAttributesInput struct {
	QueueURL       string
	Region         string
	AttributeNames []string
}

type GetQueueAttributesOutput struct {
	Attributes map[string]string
}

type GetQueueAttributesResponse struct {
	XMLName                  xml.Name                 `xml:"GetQueueAttributesResponse"`
	ResponseMetadata         XMLResponseMetadata      `xml:"ResponseMetadata"`
	Xmlns                    string                   `xml:"xmlns,attr"`
	GetQueueAttributesResult GetQueueAttributesResult `xml:"GetQueueAttributesResult"`
}

type GetQueueAttributesResult struct {
	Attributes []XMLAttribute `xml:"Attribute"`
}

type GetQueueURLInput struct {
	QueueName string
	Region    string
}

type GetQueueURLOutput struct {
	QueueURL string
}

type GetQueueURLResponse struct {
	XMLName           xml.Name            `xml:"GetQueueUrlResponse"`
	GetQueueURLResult GetQueueURLResult   `xml:"GetQueueUrlResult"`
	ResponseMetadata  XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns             string              `xml:"xmlns,attr"`
}

type GetQueueURLResult struct {
	QueueURL string `xml:"QueueUrl"`
}

type Handler struct {
	Backend StorageBackend

	Endpoint      string
	DefaultRegion string
	// contains filtered or unexported fields
}

type InFlightMessage struct {
	VisibleAt     time.Time `json:"visibleAt"`
	Msg           *Message  `json:"msg"`
	ReceiptHandle string    `json:"receiptHandle"`
	// Generation matches the Queue.receiveGeneration at the time of receive.
	// Used to detect stale receipt handles when a message is re-received after
	// a visibility timeout expires and the generation counter advances.
	Generation uint64 `json:"generation"`
}

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

type InvalidParameterError struct {
	Message string
}

type Janitor struct {
	Backend  *InMemoryBackend
	Interval time.Duration
}

type ListDeadLetterSourceQueuesInput struct {
	QueueURL   string
	Region     string
	NextToken  string
	MaxResults int
}

type ListDeadLetterSourceQueuesOutput struct {
	NextToken string
	QueueURLs []string
}

type ListMessageMoveTasksInput struct {
	SourceArn  string
	MaxResults int32
}

type ListMessageMoveTasksOutput struct {
	Results []MessageMoveTask
}

type ListQueueTagsInput struct {
	QueueURL string
	Region   string
}

type ListQueueTagsOutput struct {
	Tags *tags.Tags
}

type ListQueueTagsResponse struct {
	XMLName          xml.Name            `xml:"ListQueueTagsResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
	Result           ListQueueTagsResult `xml:"ListQueueTagsResult"`
}

type ListQueueTagsResult struct {
	Tags []TagEntry `xml:"Tag"`
}

type ListQueuesInput struct {
	QueueNamePrefix string
	NextToken       string
	Region          string
	MaxResults      int
}

type ListQueuesOutput struct {
	NextToken string
	QueueURLs []string
}

type ListQueuesResponse struct {
	XMLName          xml.Name            `xml:"ListQueuesResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
	ListQueuesResult ListQueuesResult    `xml:"ListQueuesResult"`
}

type ListQueuesResult struct {
	NextToken string   `xml:"NextToken,omitempty"`
	QueueURLs []string `xml:"QueueUrl"`
}

type Message struct {
	VisibleAt                    time.Time                        `json:"visibleAt,omitzero"`
	MessageAttributes            map[string]MessageAttributeValue `json:"messageAttributes,omitempty"`
	Attributes                   map[string]string                `json:"attributes,omitempty"`
	MessageDeduplicationID       string                           `json:"messageDeduplicationID,omitempty"`
	MessageGroupID               string                           `json:"messageGroupID,omitempty"`
	SequenceNumber               string                           `json:"sequenceNumber,omitempty"`
	MessageID                    string                           `json:"messageID"`
	ReceiptHandle                string                           `json:"receiptHandle"`
	MD5OfBody                    string                           `json:"md5OfBody"`
	MD5OfMessageAttributes       string                           `json:"md5OfMessageAttributes,omitempty"`
	MD5OfMessageSystemAttributes string                           `json:"md5OfMessageSystemAttributes,omitempty"`
	Body                         string                           `json:"body"`

	SentTimestamp                    int64 `json:"sentTimestamp"`
	ApproximateFirstReceiveTimestamp int64 `json:"approximateFirstReceiveTimestamp"`
	ApproximateReceiveCount          int   `json:"approximateReceiveCount"`
	// contains filtered or unexported fields
}

type MessageAttributeValue struct {
	DataType    string `json:"dataType"`
	StringValue string `json:"stringValue"`
	BinaryValue []byte `json:"binaryValue,omitempty"`
}

type MessageMoveTask struct {
	// ApproximateNumberOfMessagesToMove is the total messages when the task started.
	// nil when not yet determined.
	ApproximateNumberOfMessagesToMove *int64
	// MaxNumberOfMessagesPerSecond is nil when no rate limit was set.
	MaxNumberOfMessagesPerSecond *int32
	// FailureReason is populated when Status is FAILED.
	FailureReason  *string
	TaskHandle     string
	SourceArn      string
	DestinationArn string
	Status         MoveTaskStatus
	// ApproximateNumberOfMessagesMoved is always present (not a pointer), matching
	// the AWS SDK ListMessageMoveTasksResultEntry.ApproximateNumberOfMessagesMoved.
	ApproximateNumberOfMessagesMoved int64
	// StartedTimestamp is always present (Unix epoch ms), matching the AWS SDK.
	StartedTimestamp int64
}

type MetricEmitter interface {
	EmitMetric(namespace, name string, value float64, unit string) error
}

type MetricEmitterFunc func(namespace, name string, value float64, unit string) error

type MoveTaskStatus string

type Provider struct{}

type PurgeQueueInput struct {
	QueueURL string
	Region   string
}

type PurgeQueueResponse struct {
	XMLName          xml.Name            `xml:"PurgeQueueResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
}

type Queue struct {
	Attributes  map[string]string
	Permissions map[string]*QueuePermissionEntry

	Tags             *tags.Tags
	DeduplicationIDs map[string]time.Time

	Name   string
	URL    string
	Region string

	MaxReceiveCount int

	IsFIFO bool
	// contains filtered or unexported fields
}

type QueueInfo struct {
	Name   string
	URL    string
	IsFIFO bool
}

type QueuePermissionEntry struct {
	AWSAccountIDs []string `json:"awsAccountIDs"`
	Actions       []string `json:"actions"`
}

type ReceiveMessageInput struct {
	QueueURL string
	Region   string
	// ReceiveRequestAttemptID enables FIFO exactly-once retry: repeating a receive
	// with the same ID within 5 minutes returns the original message set.
	ReceiveRequestAttemptID string
	AttributeNames          []string
	MessageAttributeNames   []string
	MaxNumberOfMessages     int
	VisibilityTimeout       int
	WaitTimeSeconds         int
}

type ReceiveMessageOutput struct {
	Messages []*Message
}

type ReceiveMessageResponse struct {
	XMLName              xml.Name             `xml:"ReceiveMessageResponse"`
	ResponseMetadata     XMLResponseMetadata  `xml:"ResponseMetadata"`
	Xmlns                string               `xml:"xmlns,attr"`
	ReceiveMessageResult ReceiveMessageResult `xml:"ReceiveMessageResult"`
}

type ReceiveMessageResult struct {
	Messages []XMLMessage `xml:"Message"`
}

type RemovePermissionInput struct {
	QueueURL string
	Region   string
	Label    string
}

type SendMessageBatchEntry struct {
	MessageAttributes       map[string]MessageAttributeValue
	MessageSystemAttributes map[string]MessageAttributeValue
	ID                      string
	MessageBody             string
	MessageGroupID          string
	MessageDeduplicationID  string
	DelaySeconds            int
}

type SendMessageBatchInput struct {
	QueueURL string
	Region   string
	Entries  []SendMessageBatchEntry
}

type SendMessageBatchOutput struct {
	Successful []SendMessageBatchResultEntry
	Failed     []BatchResultErrorEntry
}

type SendMessageBatchResponse struct {
	XMLName                xml.Name                  `xml:"SendMessageBatchResponse"`
	ResponseMetadata       XMLResponseMetadata       `xml:"ResponseMetadata"`
	Xmlns                  string                    `xml:"xmlns,attr"`
	SendMessageBatchResult XMLSendMessageBatchResult `xml:"SendMessageBatchResult"`
}

type SendMessageBatchResultEntry struct {
	ID                           string
	MessageID                    string
	MD5OfBody                    string
	MD5OfMessageAttributes       string
	MD5OfMessageSystemAttributes string
	SequenceNumber               string
}

type SendMessageInput struct {
	MessageAttributes map[string]MessageAttributeValue
	// MessageSystemAttributes carries reserved system attributes from the
	// caller (currently only AWSTraceHeader). They are stored on the message
	// and surfaced via ReceiveMessage when the consumer asks for them by name.
	MessageSystemAttributes map[string]MessageAttributeValue
	QueueURL                string
	Region                  string
	MessageBody             string
	MessageGroupID          string
	MessageDeduplicationID  string
	DelaySeconds            int
}

type SendMessageOutput struct {
	MessageID                    string
	MD5OfBody                    string
	MD5OfMessageAttributes       string
	MD5OfMessageSystemAttributes string
	SequenceNumber               string
}

type SendMessageResponse struct {
	XMLName           xml.Name            `xml:"SendMessageResponse"`
	SendMessageResult SendMessageResult   `xml:"SendMessageResult"`
	ResponseMetadata  XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns             string              `xml:"xmlns,attr"`
}

type SendMessageResult struct {
	MD5OfMessageBody       string `xml:"MD5OfMessageBody"`
	MD5OfMessageAttributes string `xml:"MD5OfMessageAttributes,omitempty"`
	MessageID              string `xml:"MessageId"`
}

type SetQueueAttributesInput struct {
	Attributes map[string]string
	QueueURL   string
	Region     string
}

type SetQueueAttributesResponse struct {
	XMLName          xml.Name            `xml:"SetQueueAttributesResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
}

type Settings struct{}

type StartMessageMoveTaskInput struct {
	SourceArn                    string
	DestinationArn               string
	MaxNumberOfMessagesPerSecond int32
}

type StartMessageMoveTaskOutput struct {
	TaskHandle string
}

type StorageBackend interface {
	CreateQueue(input *CreateQueueInput) (*CreateQueueOutput, error)
	DeleteQueue(input *DeleteQueueInput) error
	ListQueues(input *ListQueuesInput) (*ListQueuesOutput, error)
	GetQueueURL(input *GetQueueURLInput) (*GetQueueURLOutput, error)
	GetQueueAttributes(input *GetQueueAttributesInput) (*GetQueueAttributesOutput, error)
	SetQueueAttributes(input *SetQueueAttributesInput) error
	SendMessage(input *SendMessageInput) (*SendMessageOutput, error)
	ReceiveMessage(input *ReceiveMessageInput) (*ReceiveMessageOutput, error)
	DeleteMessage(input *DeleteMessageInput) error
	ChangeMessageVisibility(input *ChangeMessageVisibilityInput) error
	SendMessageBatch(input *SendMessageBatchInput) (*SendMessageBatchOutput, error)
	DeleteMessageBatch(input *DeleteMessageBatchInput) (*DeleteMessageBatchOutput, error)
	PurgeQueue(input *PurgeQueueInput) error
	TagQueue(input *TagQueueInput) error
	UntagQueue(input *UntagQueueInput) error
	ListQueueTags(input *ListQueueTagsInput) (*ListQueueTagsOutput, error)
	ChangeMessageVisibilityBatch(
		input *ChangeMessageVisibilityBatchInput,
	) (*ChangeMessageVisibilityBatchOutput, error)
	ListDeadLetterSourceQueues(
		input *ListDeadLetterSourceQueuesInput,
	) (*ListDeadLetterSourceQueuesOutput, error)
	AddPermission(input *AddPermissionInput) error
	RemovePermission(input *RemovePermissionInput) error
	StartMessageMoveTask(input *StartMessageMoveTaskInput) (*StartMessageMoveTaskOutput, error)
	CancelMessageMoveTask(input *CancelMessageMoveTaskInput) (*CancelMessageMoveTaskOutput, error)
	ListMessageMoveTasks(input *ListMessageMoveTasksInput) (*ListMessageMoveTasksOutput, error)
	ListAll() []QueueInfo
}

type TagEntry struct {
	Key   string `xml:"Key"`
	Value string `xml:"Value"`
}

type TagQueueInput struct {
	Tags     *tags.Tags
	QueueURL string
	Region   string
}

type TagQueueResponse struct {
	XMLName          xml.Name            `xml:"TagQueueResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
}

type TaggedQueueInfo struct {
	Tags map[string]string
	ARN  string
}

type UntagQueueInput struct {
	QueueURL string
	Region   string
	TagKeys  []string
}

type UntagQueueResponse struct {
	XMLName          xml.Name            `xml:"UntagQueueResponse"`
	ResponseMetadata XMLResponseMetadata `xml:"ResponseMetadata"`
	Xmlns            string              `xml:"xmlns,attr"`
}

type XMLAttribute struct {
	Name  string `xml:"Name"`
	Value string `xml:"Value"`
}

type XMLDeleteMessageBatchFailedEntry struct {
	ID          string `xml:"Id"`
	Code        string `xml:"Code"`
	Message     string `xml:"Message"`
	SenderFault bool   `xml:"SenderFault"`
}

type XMLDeleteMessageBatchResult struct {
	Successful []XMLDeleteMessageBatchResultEntry `xml:"DeleteMessageBatchResultEntry"`
	Failed     []XMLDeleteMessageBatchFailedEntry `xml:"BatchResultErrorEntry"`
}

type XMLDeleteMessageBatchResultEntry struct {
	ID string `xml:"Id"`
}

type XMLError struct {
	Detail  XMLErrorDetail `xml:"Detail"`
	Type    string         `xml:"Type"`
	Code    string         `xml:"Code"`
	Message string         `xml:"Message"`
}

type XMLErrorDetail struct{}

type XMLErrorResponse struct {
	XMLName   xml.Name `xml:"ErrorResponse"`
	Error     XMLError `xml:"Error"`
	Xmlns     string   `xml:"xmlns,attr"`
	RequestID string   `xml:"RequestId"`
}

type XMLMessage struct {
	MessageID              string                `xml:"MessageId"`
	ReceiptHandle          string                `xml:"ReceiptHandle"`
	MD5OfBody              string                `xml:"MD5OfBody"`
	MD5OfMessageAttributes string                `xml:"MD5OfMessageAttributes,omitempty"`
	Body                   string                `xml:"Body"`
	Attributes             []XMLAttribute        `xml:"Attribute"`
	MessageAttributes      []XMLMessageAttribute `xml:"MessageAttribute"`
}

type XMLMessageAttribute struct {
	Name  string                   `xml:"Name"`
	Value XMLMessageAttributeValue `xml:"Value"`
}

type XMLMessageAttributeValue struct {
	DataType    string `xml:"DataType"`
	StringValue string `xml:"StringValue,omitempty"`
	BinaryValue string `xml:"BinaryValue,omitempty"` // base64-encoded raw bytes
}

type XMLResponseMetadata struct {
	RequestID string `xml:"RequestId"`
}

type XMLSendMessageBatchFailedEntry struct {
	ID          string `xml:"Id"`
	Code        string `xml:"Code"`
	Message     string `xml:"Message"`
	SenderFault bool   `xml:"SenderFault"`
}

type XMLSendMessageBatchResult struct {
	Successful []XMLSendMessageBatchResultEntry `xml:"SendMessageBatchResultEntry"`
	Failed     []XMLSendMessageBatchFailedEntry `xml:"BatchResultErrorEntry"`
}

type XMLSendMessageBatchResultEntry struct {
	ID                     string `xml:"Id"`
	MessageID              string `xml:"MessageId"`
	MD5OfMessageBody       string `xml:"MD5OfMessageBody"`
	MD5OfMessageAttributes string `xml:"MD5OfMessageAttributes,omitempty"`
}