types

type DequeueOptions struct {
	WaitTimeSeconds int
	BatchSize       int
	DeleteMessage   bool
	ParseFunc       func(body string) (any, error)
}

type DequeuedMessage struct {
	MessageId               string
	ReceiptHandle           string
	Body                    string
	ReceivedAt              time.Time
	ApproximateReceiveCount int
}

type EnqueueOptions struct {
	MessageGroupId  string
	DeduplicationId string
	Attributes      map[string]string
}

type QueueMessage[T any] struct {
	MessageId     string
	ReceiptHandle string
	Payload       T
	ReceivedAt    time.Time
}