go__sqs_demo/back/services/redriver/types.go

package redriver

type MessageAttributes struct {
	ApproximateFirstReceiveTimestamp int32  `json:"approximate_first_receive_timestamp,omitempty"`
	ApproximateReceiveCount          int32  `json:"approximate_receive_count,omitempty"`
	SenderId                         string `json:"sender_id,omitempty"` // SenderId may be an IAM user or role
	SentTimestamp                    int32  `json:"sent_timestamp,omitempty"`
	SequenceNumber                   int32  `json:"sequence_number,omitempty"`
}

type Message struct {
	Attributes             *MessageAttributes `json:"attributes,omitempty"`
	Body                   string             `json:"body,omitempty"`                      // Body is not url-encoded
	Md5OfBody              string             `json:"md5_of_body,omitempty"`               // Md5OfBody hold an MD5 digest of the non-URL-encoded message body string.
	Md5OfMessageAttributes string             `json:"md5_of_message_attributes,omitempty"` // Md5OfMessageAttributes holds an MD5 digest of the non-URL-encoded message attribute string. You can use this attribute to verify that Amazon SQS received the message correctly. Amazon SQS URL-decodes the message before creating the MD5 digest. For information about MD5, see RFC1321 (https://www.ietf.org/rfc/rfc1321.txt).
	MessageId              string             `json:"message_id,omitempty"`                // MessageId is opaque.
	ReceiptHandle          string             `json:"receipt_handle,omitempty"`            // ReceiptHandle is an identifier associated with the act of receiving the message. A new receipt handle is returned every time you receive a message. When deleting a message, you provide the last received receipt handle to delete the message.
}

type NameRedriveBody struct {
	Id            string `json:"id,omitempty"`
	ReceiptHandle string `json:"receipt_handle,omitempty"`
}

type QueueInfo struct {
	// Name is the queue name, for both human and machine use
	Name       string               `json:"name,omitempty"`
	Url        string               `json:"url,omitempty"`
	Attributes *QueueInfoAttributes `json:"attributes,omitempty"`
}

type QueueInfoAttributes struct {
	// ApproximateNumberOfMessages holds the approximate number of messages available for retrieval from the queue.
	ApproximateNumberOfMessages int32 `json:"approximate_number_of_messages,omitempty"`
	// ApproximateNumberOfMessagesDelayed holds he approximate number of messages in the queue that are delayed and not available for reading immediately. This can happen when the queue is configured as a delay queue or when a message has been sent with a delay parameter.
	ApproximateNumberOfMessagesDelayed int32 `json:"approximate_number_of_messages_delayed,omitempty"`
	// ApproximateNumberOfMessagesNotVisible holds the approximate number of messages that are in flight. Messages are considered to be in flight if they have been sent to a client but have not yet been deleted or have not yet reached the end of their visibility window.
	ApproximateNumberOfMessagesNotVisible int32 `json:"approximate_number_of_messages_not_visible,omitempty"`
	// CreatedTimestamp holds the time when the queue was created in seconds (epoch time).
	CreatedTimestamp int32 `json:"created_timestamp,omitempty"`
	// DelaySeconds holds the default delay on the queue in seconds.
	DelaySeconds int32 `json:"delay_seconds,omitempty"`
	// LastModifiedTimestamp holds the time when the queue was last changed in seconds (epoch time).
	LastModifiedTimestamp int32 `json:"last_modified_timestamp,omitempty"`
	// MaximumMessageSize holds the limit of how many bytes a message can contain before Amazon SQS rejects it.
	MaximumMessageSize int32 `json:"maximum_message_size,omitempty"`
	// MessageRetentionPeriod holds the length of time, in seconds, for which Amazon SQS retains a message. When you change a queue's attributes, the change can take up to 60 seconds for most of the attributes to propagate throughout the Amazon SQS system. Changes made to the MessageRetentionPeriod attribute can take up to 15 minutes and will impact existing messages in the queue potentially causing them to be expired and deleted if the MessageRetentionPeriod is reduced below the age of existing messages.
	MessageRetentionPeriod int32 `json:"message_retention_period,omitempty"`

	QueueARN string `json:"queue_arn,omitempty"`
	// ReceiveMessageWaitTimeSeconds holds the length of time, in seconds, for which the ReceiveMessage action waits for a message to arrive.
	ReceiveMessageWaitTimeSeconds int32 `json:"receive_message_wait_time_seconds,omitempty"`
	// VisibilityTimeout holds the number of seconds a message remains hidden after being received. Max 43200.
	VisibilityTimeout int32 `json:"visibility_timeout,omitempty"`

	RedrivePolicy      *QueueInfoAttributesRedrivePolicy      `json:"redrive_policy,omitempty"`
	RedriveAllowPolicy *QueueInfoAttributesRedriveAllowPolicy `json:"redrive_allow_policy,omitempty"`
}

// QueueInfoAttributesRedriveAllowPolicy describes the permissions for the dead-letter queue redrive permission and which source queues can specify dead-letter queues.
type QueueInfoAttributesRedriveAllowPolicy struct {
	// RedrivePermission defines which source queues can specify the current queue as the dead-letter queue.
	RedrivePermission string   `json:"redrivePermission,omitempty"`
	SourceQueueARNs   []string `json:"sourceQueueArns,omitempty"`
}

// QueueInfoAttributesRedrivePolicy holds the parameters for the dead-letter queue functionality of the source queue
type QueueInfoAttributesRedrivePolicy struct {
	// DeadLetterTargetARN holds the Amazon Resource Name (ARN) of the dead-letter queue to which Amazon SQS moves messages after the value of maxReceiveCount is exceeded.
	DeadLetterTargetARN string `json:"deadLetterTargetArn,omitempty"`
	// MaxReceiveCount holds the number of times a message is delivered to the source queue before being moved to the dead-letter queue. Default 10. When the ReceiveCount for a message exceeds the maxReceiveCount for a queue, Amazon SQS moves the message to the dead-letter-queue.
	MaxReceiveCount int32 `json:"maxReceiveCount,omitempty"`
}

// Error is a general error response format
type Error struct {
	// Message is a free-form string describing the error.
	Message string `json:"message,omitempty"`
}