Skip to content

Commit aba9b10

Browse files
chore: remove health check function
1 parent 1c55592 commit aba9b10

2 files changed

Lines changed: 0 additions & 6 deletions

File tree

publisher/kafka.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ package publisher
33
import (
44
"encoding/json"
55
"fmt"
6-
"github.com/goto/raccoon/health"
76
"strings"
87

98
"gopkg.in/confluentinc/confluent-kafka-go.v1/kafka"
@@ -39,8 +38,6 @@ func NewKafka() (*Kafka, error) {
3938
flushInterval: config.PublisherKafka.FlushInterval,
4039
topicFormat: config.EventDistribution.PublisherPattern,
4140
}
42-
//register the health check of connection to kafka broker
43-
health.Register("kafka-broker", k.HealthCheck)
4441
return k, nil
4542
}
4643

services/mqtt/service.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@ import (
44
"context"
55
"errors"
66
"fmt"
7-
"github.com/goto/raccoon/health"
87
"os"
98

109
"github.com/goto/raccoon/collection"
@@ -41,8 +40,6 @@ func NewMQTTService(collector collection.Collector, ctx context.Context) *Servic
4140
consumers = append(consumers, NewConsumer(mqttClient))
4241
}
4342
s := &Service{Collector: collector, consumers: consumers}
44-
//register the health check of connection to broker
45-
health.Register("mqtt-broker", s.HealthCheck)
4643

4744
return s
4845
}

0 commit comments

Comments
 (0)