Skip to content

Commit dada525

Browse files
committed
update to latest changes, mainly config.Load()
1 parent f14a7bd commit dada525

File tree

2 files changed

+10
-3
lines changed

2 files changed

+10
-3
lines changed

cmd/opampsupervisor/main.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,17 +30,18 @@ func runInteractive() error {
3030
cfg, err := config.Load(*configFlag)
3131
if err != nil {
3232
logger.Error(err.Error())
33-
os.Exit(-1)
34-
return
33+
return err
3534
}
3635

3736
supervisor, err := supervisor.NewSupervisor(logger, cfg)
3837
if err != nil {
38+
logger.Error(err.Error())
3939
return err
4040
}
4141

4242
err = supervisor.Start()
4343
if err != nil {
44+
logger.Error(err.Error())
4445
return err
4546
}
4647

cmd/opampsupervisor/supervisor/supervisor_windows.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import (
99
"flag"
1010
"fmt"
1111

12+
"github.com/open-telemetry/opentelemetry-collector-contrib/cmd/opampsupervisor/supervisor/config"
1213
"go.uber.org/zap"
1314
"go.uber.org/zap/zapcore"
1415
"golang.org/x/sys/windows"
@@ -69,7 +70,12 @@ func (ws *windowsService) start(elog *eventlog.Log) error {
6970

7071
logger, _ := zap.NewDevelopment(zap.WrapCore(withWindowsCore(elog)))
7172

72-
sup, err := NewSupervisor(logger, *configFlag)
73+
cfg, err := config.Load(*configFlag)
74+
if err != nil {
75+
return fmt.Errorf("load config: %w", err)
76+
}
77+
78+
sup, err := NewSupervisor(logger, cfg)
7379
if err != nil {
7480
return fmt.Errorf("new supervisor: %w", err)
7581
}

0 commit comments

Comments
 (0)