directory-segments-observer

Description

Listens to segment related events and processes them in order to update segment-subscribers entities. This service is crucial for maintaining the integrity of segment data and ensuring that all subscribers are correctly associated with their respective segments.

Data flow

Listens to Kafka events in directory_segments group.

Input

• subscription-event
• subscriber-tag
• subscriber-update
• segment
• time

Output

• segment with type = refresh for the manager-observer to catch updates and grab new meta data on it’s side

Cache

All subscribers events, regardless of their type, are put into the PendingNewSegmentSubscribersCache, which is a simple in-memory cache that stores subscribers that are pending to be added to segments. This cache is used to avoid unnecessary database queries and to ensure that all subscribers are processed correctly.