SubscriptionEngine
final class SubscriptionEngine (View source)
| internal | implementation detail of the catchup. See {@see \Neos\ContentRepository\Core\ContentRepository::handle()} and {@see \Neos\ContentRepository\Core\Service\ContentRepositoryMaintainer} |
This is the internal core for the catchup
All functionality is low level and well encapsulated and abstracted by the {\Neos\ContentRepository\Core\Service\ContentRepositoryMaintainer} It presents the only API way to interact with catchup and offers more maintenance tasks.
This implementation is heavily inspired and adjusted from the event-sourcing package of "patchlevel": https://github.com/patchlevel/event-sourcing/
Methods
__construct(EventStoreInterface $eventStore, SubscriptionStoreInterface $subscriptionStore, Subscribers $subscribers, EventNormalizer $eventNormalizer, PerformanceTracerInterface|null $performanceTracer, LoggerInterface|null $logger = null)
No description
boot(SubscriptionEngineCriteria|null $criteria = null, Closure|null $progressCallback = null, int|null $batchSize = null)
No description
catchUpActive(SubscriptionEngineCriteria|null $criteria = null, Closure|null $progressCallback = null, int|null $batchSize = null)
No description
reactivate(SubscriptionEngineCriteria|null $criteria = null, Closure|null $progressCallback = null, int|null $batchSize = null)
No description
Details
__construct(EventStoreInterface $eventStore, SubscriptionStoreInterface $subscriptionStore, Subscribers $subscribers, EventNormalizer $eventNormalizer, PerformanceTracerInterface|null $performanceTracer, LoggerInterface|null $logger = null)
No description
Result
setup(SubscriptionEngineCriteria|null $criteria = null)
No description
ProcessedResult
boot(SubscriptionEngineCriteria|null $criteria = null, Closure|null $progressCallback = null, int|null $batchSize = null)
No description
ProcessedResult
catchUpActive(SubscriptionEngineCriteria|null $criteria = null, Closure|null $progressCallback = null, int|null $batchSize = null)
No description
ProcessedResult
reactivate(SubscriptionEngineCriteria|null $criteria = null, Closure|null $progressCallback = null, int|null $batchSize = null)
No description
Result
reset(SubscriptionEngineCriteria|null $criteria = null)
No description
SubscriptionStatusCollection
subscriptionStatus(SubscriptionEngineCriteria|null $criteria = null)
No description