11package io .split .engine .segments ;
22
33import io .split .engine .common .FetchOptions ;
4- import io .split .storages .DefinitionsCacheConsumer ;
4+ import io .split .storages .SegmentsProvider ;
55import io .split .storages .RuleBasedSegmentCacheConsumer ;
66import io .split .storages .SegmentCacheProducer ;
77import org .slf4j .Logger ;
@@ -36,14 +36,14 @@ public class SegmentSynchronizationTaskImp implements SegmentSynchronizationTask
3636 private final SegmentCacheProducer _segmentCacheProducer ;
3737 private final ScheduledExecutorService _scheduledExecutorService ;
3838 private final TelemetryListener _telemetryListener ;
39- private final DefinitionsCacheConsumer _definitionsCacheConsumer ;
39+ private final SegmentsProvider _segmentsProvider ;
4040 private final RuleBasedSegmentCacheConsumer _ruleBasedSegmentCacheConsumer ;
4141
4242 private ScheduledFuture <?> _scheduledFuture ;
4343
4444 public SegmentSynchronizationTaskImp (SegmentChangeFetcher segmentChangeFetcher , long refreshEveryNSeconds , int numThreads ,
4545 SegmentCacheProducer segmentCacheProducer , TelemetryListener telemetryListener ,
46- DefinitionsCacheConsumer definitionsCacheConsumer , ExecutorFactory executorFactory ,
46+ SegmentsProvider segmentsProvider , ExecutorFactory executorFactory ,
4747 ThreadFactory threadFactory ,
4848 RuleBasedSegmentCacheConsumer ruleBasedSegmentCacheConsumer ) {
4949 _segmentChangeFetcher = Objects .requireNonNull (segmentChangeFetcher );
@@ -57,7 +57,7 @@ public SegmentSynchronizationTaskImp(SegmentChangeFetcher segmentChangeFetcher,
5757
5858 _segmentCacheProducer = Objects .requireNonNull (segmentCacheProducer );
5959 _telemetryListener = Objects .requireNonNull (telemetryListener );
60- _definitionsCacheConsumer = Objects .requireNonNull (definitionsCacheConsumer );
60+ _segmentsProvider = Objects .requireNonNull (segmentsProvider );
6161 _ruleBasedSegmentCacheConsumer = Objects .requireNonNull (ruleBasedSegmentCacheConsumer );
6262 }
6363
@@ -201,7 +201,7 @@ private void initialize(String segmentName) {
201201 }
202202
203203 private Set <String > getSegmentNames () {
204- Set <String > names = new HashSet <>(_definitionsCacheConsumer .getSegments ());
204+ Set <String > names = new HashSet <>(_segmentsProvider .getSegments ());
205205 names .addAll (_ruleBasedSegmentCacheConsumer .getSegments ());
206206
207207 return names ;
0 commit comments