iq

type Config struct {
	Prefix                 string   `split_words:"true" required:"true"`
	TopicArns              []string `split_words:"true" required:"true"`
	MaxNumberOfMessages    int64    `split_words:"true" default:"10"`
	WaitTimeSecond         int64    `split_words:"true" default:"20"`
	VisibilityTimeout      int64    `split_words:"true" default:"3600"`
	DeliveryDelay          int64    `split_words:"true" default:"10"`
	MessageRetentionPeriod int64    `split_words:"true" default:"3600"`
	HandlerTimeout         int64    `split_words:"true" default:"60"`
}

type Handler interface {
	HandleMessage(ctx context.Context, msg *M) error
}

type HandlerFunc func(ctx context.Context, msg *M) error

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

type M struct {
	Notification  NotificationMessage
	ReceiptHandle string
	Body          map[string]interface{}
	ID            string
}

type MessageAttribute struct {
	Type  string `json:"Type"`
	Value string `json:"Value"`
}

type NotificationMessage struct {
	Type             string                      `json:"Type"`
	ID               string                      `json:"MessageId"`
	TopicArn         string                      `json:"TopicArn"`
	Body             string                      `json:"Message"`
	Timestamp        time.Time                   `json:"Timestamp"`
	SignatureVersion string                      `json:"SignatureVersion"`
	Signature        string                      `json:"Signature"`
	SigningCertURL   string                      `json:"SigningCertURL"`
	UnsubscribeURL   string                      `json:"UnsubscribeURL"`
	Attributes       map[string]MessageAttribute `json:"Attributes"`
}