move failed post cache init to EFS service

This commit is contained in:
ionutboangiu
2025-11-19 15:55:15 +02:00
committed by Dan Christian Bogos
parent 4714fb783b
commit 3179af0839
2 changed files with 1 additions and 2 deletions

View File

@@ -69,6 +69,7 @@ func (s *ExportFailoverService) Start(_ *utils.SyncedChan, registry *servmanager
s.srv, _ = engine.NewServiceWithPing(s.efS, utils.EfSv1, utils.V1Prfx)
cl.RpcRegister(s.srv)
cms.AddInternalConn(utils.EFs, s.srv)
efs.InitFailedPostCache(s.cfg.EFsCfg().FailedPostsTTL, s.cfg.EFsCfg().FailedPostsStaticTTL)
return
}

View File

@@ -21,7 +21,6 @@ package services
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/efs"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/servmanager"
"github.com/cgrates/cgrates/utils"
@@ -59,7 +58,6 @@ func (s *LoggerService) Start(_ *utils.SyncedChan, registry *servmanager.Service
}
cm := cms.(*ConnManagerService).ConnManager()
utils.Logger = engine.NewExportLogger(context.TODO(), s.cfg.GeneralCfg().DefaultTenant, cm, s.cfg)
efs.InitFailedPostCache(s.cfg.EFsCfg().FailedPostsTTL, s.cfg.EFsCfg().FailedPostsStaticTTL)
return nil
}