rename file

Author: Thanh1912

sqs_health_check.go

@@ -0,0 +1,36 @@
+package sqs
+
+import (
+	"context"
+	"github.com/aws/aws-sdk-go/service/sqs"
+)
+
+type SQSHealthChecker struct {
+	Client    *sqs.SQS
+	QueueName *string
+	Service   string
+}
+
+func NewSQSHealthChecker(client *sqs.SQS, name string, queueName string) *SQSHealthChecker {
+	return &SQSHealthChecker{client, &queueName, name}
+}
+
+func (h *SQSHealthChecker) Name() string {
+	return h.Service
+}
+
+func (h *SQSHealthChecker) Check(ctx context.Context) (map[string]interface{}, error) {
+	res := make(map[string]interface{})
+	_, err := h.Client.GetQueueUrl(&sqs.GetQueueUrlInput{
+		QueueName: h.QueueName,
+	})
+	return res, err
+}
+
+func (h *SQSHealthChecker) Build(ctx context.Context, data map[string]interface{}, err error) map[string]interface{} {
+	if err == nil {
+		return data
+	}
+	data["error"] = err.Error()
+	return data
+}