-
Sub-task
-
Resolution: Done
-
Major
-
None
Add the endpoint /api/pipelines/{id}}/signals
It will take a JSON body with the the data required for the signal. Similar to DSSignal
Example
{"id": "1","type": "execute-snapshot","data": "{ \"data-collections\": [ \"inventory.products\"],\"type\": \"INCREMENTAL\"}"}
This will then get the pipeline name and search for service with name <pipeline_name>-api.
Then a call to http://<pipeline_name>-api:8080/api/signals will be done to effectively send the signal to DS instance.