seokjin0414 opened a new pull request, #2781:
URL: https://github.com/apache/iggy/pull/2781
## Summary
Closes #2417.
- Add `POST /sinks/{key}/restart` and `POST /sources/{key}/restart` API
endpoints
- Implement `stop_connector()`, `start_connector()`, `restart_connector()`
on SinkManager and SourceManager
- Add `tokio::sync::watch` shutdown channel to sink consume loop for
graceful cancellation
- Store `Arc<Container>` and task handles in Manager for lifecycle control
- Extend RuntimeContext with `iggy_clients` and `state_path` for restart
resource access
- Replace direct shutdown in main.rs with Manager-based `stop_connector()`
calls
## Design
- **Sink restart**: shutdown signal via watch channel → await task handles
(5s timeout) → FFI `iggy_sink_close` → FFI `iggy_sink_open` with new config →
spawn new consume tasks
- **Source restart**: cleanup flume sender → await forwarding tasks (5s
timeout) → FFI `iggy_source_close` → load state → FFI `iggy_source_open` with
new config → spawn new handler
- Container (shared library) is NOT reloaded — only closed/reopened with new
config and plugin ID
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
