reduce filter loop to 300ms

This commit is contained in:
Andrea Maria Piana 2024-08-23 14:45:09 +01:00
parent f95892564a
commit f1f4186f2b
1 changed files with 1 additions and 1 deletions

View File

@ -67,7 +67,7 @@ func newFilterManager(ctx context.Context, logger *zap.Logger, cfg *Config, onNe
mgr.node = node mgr.node = node
mgr.onlineChecker = onlinechecker.NewDefaultOnlineChecker(false).(*onlinechecker.DefaultOnlineChecker) mgr.onlineChecker = onlinechecker.NewDefaultOnlineChecker(false).(*onlinechecker.DefaultOnlineChecker)
mgr.node.SetOnlineChecker(mgr.onlineChecker) mgr.node.SetOnlineChecker(mgr.onlineChecker)
mgr.filterSubBatchDuration = 5 * time.Second mgr.filterSubBatchDuration = 300 * time.Millisecond
mgr.incompleteFilterBatch = make(map[string]filterConfig) mgr.incompleteFilterBatch = make(map[string]filterConfig)
mgr.filterConfigs = make(appFilterMap) mgr.filterConfigs = make(appFilterMap)
mgr.waitingToSubQueue = make(chan filterConfig, 100) mgr.waitingToSubQueue = make(chan filterConfig, 100)