dequeuer

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

type AsyncMessageHandlerConfig struct {
	ClusterUID string
	Bucket     string
	APIName    string
	TargetURL  string
}

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

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

type BatchMessageHandlerConfig struct {
	APIName   string
	JobID     string
	QueueURL  string
	Region    string
	TargetURL string
}

type MessageHandler interface {
	Handle(*sqs.Message) error
}

type QueueAttributes struct {
	VisibleMessages   int
	InvisibleMessages int
	HasRedrivePolicy  bool
}

type RequestEvent struct {
	StatusCode int
	Duration   time.Duration
}

type RequestEventHandler interface {
	HandleEvent(event RequestEvent)
}

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

type SQSDequeuerConfig struct {
	Region           string
	QueueURL         string
	StopIfNoMessages bool
	Workers          int
}