Skip to content

Commit 2f9c87a

Browse files
committed
Refactor health check
1 parent edf97d3 commit 2f9c87a

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

health_checker.go

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,17 @@ type HealthChecker struct {
1111
Service string
1212
}
1313

14-
func NewHealthChecker(client *sqs.SQS, queueName string) *HealthChecker {
15-
return NewSQSHealthChecker(client, queueName, "sqs")
14+
func NewHealthChecker(client *sqs.SQS, queueName string, options...string) *HealthChecker {
15+
var name string
16+
if len(options) > 0 && len(options[0]) > 0 {
17+
name = options[0]
18+
} else {
19+
name = "sqs"
20+
}
21+
return NewSQSHealthChecker(client, name, queueName)
1622
}
1723
func NewSQSHealthChecker(client *sqs.SQS, name string, queueName string) *HealthChecker {
18-
return &HealthChecker{client, &queueName, name}
24+
return &HealthChecker{Client: client, QueueName: &queueName, Service: name}
1925
}
2026

2127
func (h *HealthChecker) Name() string {

0 commit comments

Comments
 (0)