separate trackers, fix #695

This commit is contained in:
Alireza Ahmadi
2025-08-04 13:35:49 +02:00
parent f608f0bba0
commit e883a8e153
7 changed files with 292 additions and 288 deletions
+10
View File
@@ -49,6 +49,7 @@ type Box struct {
connection *route.ConnectionManager
router *route.Router
internalService []adapter.LifecycleService
statsTracker *StatsTracker
connTracker *ConnTracker
done chan struct{}
}
@@ -324,6 +325,10 @@ func NewBox(options Options) (*Box, error) {
return nil, common.NewError("initialize platform interface", err)
}
}
if statsTracker == nil {
statsTracker = NewStatsTracker()
}
router.AppendTracker(statsTracker)
if connTracker == nil {
connTracker = NewConnTracker()
}
@@ -387,6 +392,7 @@ func NewBox(options Options) (*Box, error) {
logFactory: logFactory,
logger: logFactory.Logger(),
internalService: internalServices,
statsTracker: statsTracker,
connTracker: connTracker,
done: make(chan struct{}),
}, nil
@@ -530,6 +536,10 @@ func (s *Box) Endpoint() adapter.EndpointManager {
return s.endpoint
}
func (s *Box) StatsTracker() *StatsTracker {
return s.statsTracker
}
func (s *Box) ConnTracker() *ConnTracker {
return s.connTracker
}