Skip to content

Commit 6ef70af

Browse files
committed
feat: add leadership package
1 parent c10b32b commit 6ef70af

File tree

8 files changed

+494
-106
lines changed

8 files changed

+494
-106
lines changed

cmd/serve.go

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ package cmd
33
import (
44
"github.com/formancehq/go-libs/v2/logging"
55
"github.com/formancehq/ledger/internal/api/common"
6+
"github.com/formancehq/ledger/internal/leadership"
67
systemstore "github.com/formancehq/ledger/internal/storage/system"
78
"net/http"
89
"net/http/pprof"
@@ -108,6 +109,7 @@ func NewServeCommand() *cobra.Command {
108109
}),
109110
bus.NewFxModule(),
110111
ballast.Module(serveConfiguration.ballastSize),
112+
leadership.NewFXModule(),
111113
api.Module(api.Config{
112114
Version: Version,
113115
Debug: service.IsDebug(cmd),
@@ -122,15 +124,15 @@ func NewServeCommand() *cobra.Command {
122124
}),
123125
fx.Decorate(func(
124126
params struct {
125-
fx.In
127+
fx.In
126128

127-
Handler chi.Router
128-
HealthController *health.HealthController
129-
Logger logging.Logger
129+
Handler chi.Router
130+
HealthController *health.HealthController
131+
Logger logging.Logger
130132

131-
MeterProvider *metric.MeterProvider `optional:"true"`
132-
Exporter *otlpmetrics.InMemoryExporter `optional:"true"`
133-
},
133+
MeterProvider *metric.MeterProvider `optional:"true"`
134+
Exporter *otlpmetrics.InMemoryExporter `optional:"true"`
135+
},
134136
) chi.Router {
135137
return assembleFinalRouter(
136138
service.IsDebug(cmd),

0 commit comments

Comments
 (0)