Skip to content

Commit 6f0701a

Browse files
authored
Fix heartbeat job not registering in main file (#150)
1 parent 43f3db9 commit 6f0701a

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

main.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,11 @@ import (
44
"context"
55
"fmt"
66
"hostlink/app"
7+
"hostlink/app/jobs/heartbeatjob"
78
"hostlink/app/jobs/metricsjob"
89
"hostlink/app/jobs/registrationjob"
910
"hostlink/app/jobs/taskjob"
11+
"hostlink/app/services/heartbeat"
1012
"hostlink/app/services/metrics"
1113
"hostlink/app/services/taskfetcher"
1214
"hostlink/app/services/taskreporter"
@@ -78,6 +80,14 @@ func main() {
7880
}
7981
metricsJob := metricsjob.New()
8082
metricsJob.Register(ctx, metricsReporter, metricsReporter)
83+
84+
heartbeatSvc, err := heartbeat.New()
85+
if err != nil {
86+
log.Printf("failed to initialize heartbeat service: %v", err)
87+
return
88+
}
89+
heartbeatJob := heartbeatjob.New()
90+
heartbeatJob.Register(ctx, heartbeatSvc)
8191
}()
8292

8393
log.Fatal(e.Start(fmt.Sprintf(":%s", appconf.Port())))

0 commit comments

Comments
 (0)