feat: Adds the compactor for the all target (#2875)

grafana · Dec 21, 2023 · ba25f23 · ba25f23
1 parent e6b1693
commit ba25f23
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/pkg/phlare/modules.go b/pkg/phlare/modules.go
@@ -192,6 +192,10 @@ func (f *Phlare) initQueryScheduler() (services.Service, error) {
 func (f *Phlare) initCompactor() (serv services.Service, err error) {
 	f.Cfg.Compactor.ShardingRing.Common.ListenPort = f.Cfg.Server.HTTPListenPort
 
+	if f.storageBucket == nil {
+		return nil, nil
+	}
+
 	f.Compactor, err = compactor.NewMultitenantCompactor(f.Cfg.Compactor, f.storageBucket, f.Overrides, log.With(f.logger, "component", "compactor"), f.reg)
 	if err != nil {
 		return

diff --git a/pkg/phlare/phlare.go b/pkg/phlare/phlare.go
@@ -304,7 +304,7 @@ func (f *Phlare) setupModuleManager() error {
 
 	// Add dependencies
 	deps := map[string][]string{
-		All: {Ingester, Distributor, QueryScheduler, QueryFrontend, Querier, StoreGateway, Admin, TenantSettings},
+		All: {Ingester, Distributor, QueryScheduler, QueryFrontend, Querier, StoreGateway, Admin, TenantSettings, Compactor},
 
 		Server:            {GRPCGateway},
 		API:               {Server},