This service is responsible for storing flow snapshots.
Snapshot is a feature of the OIH platform, which provides flows components a possibility to store some
state between executions. A typical use case is to store some
timestamp and use it to query records from a certain system, created after this
timestamp, so that you would not need to query full list of records each time.
It connects to the RabbitMQ queue, which is in turn subscribed for the
snapshot events, fired by flow components. The service consume the messages from the queue and writes it to the DB. The snapshots are then accessible via REST API.
- Interacts with IAM to introspect provided IAM token.
snapshotevents from flow components via RabbitMQ.
- Component Orchestrator queries the service and provides snapshots to each flow component.