diff options
| author | Ellie Huxtable <ellie@atuin.sh> | 2026-04-11 01:32:24 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2026-04-11 01:32:24 +0100 |
| commit | 7e47f4df6ceb0fe7e32c166776e4e3b960039b67 (patch) | |
| tree | 5e512c17c6c9d36c6e347a579a9baacc56832817 /crates/atuin-daemon/src/client.rs | |
| parent | chore: Prepare 18.14.0-beta.1 release (#3393) (diff) | |
| download | atuin-7e47f4df6ceb0fe7e32c166776e4e3b960039b67.zip | |
feat: add history tail for live monitoring view (#3389)
Useful for watching what agents are doing, or viewing live info from
other machines. Regardless I am liking it for debugging
## Checks
- [ ] I am happy for maintainers to push small adjustments to this PR,
to speed up the review cycle
- [ ] I have checked that there are no existing pull requests for the
same thing
Diffstat (limited to 'crates/atuin-daemon/src/client.rs')
| -rw-r--r-- | crates/atuin-daemon/src/client.rs | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/crates/atuin-daemon/src/client.rs b/crates/atuin-daemon/src/client.rs index 2f492f6b..5f4ce20f 100644 --- a/crates/atuin-daemon/src/client.rs +++ b/crates/atuin-daemon/src/client.rs @@ -23,7 +23,8 @@ use crate::control::{ use crate::events::DaemonEvent; use crate::history::{ EndHistoryReply, EndHistoryRequest, ShutdownRequest, StartHistoryReply, StartHistoryRequest, - StatusReply, StatusRequest, history_client::HistoryClient as HistoryServiceClient, + StatusReply, StatusRequest, TailHistoryReply, TailHistoryRequest, + history_client::HistoryClient as HistoryServiceClient, }; use crate::search::{ FilterMode as RpcFilterMode, SearchContext as RpcSearchContext, SearchRequest, SearchResponse, @@ -140,6 +141,14 @@ impl HistoryClient { Ok(self.client.status(StatusRequest {}).await?.into_inner()) } + pub async fn tail_history(&mut self) -> Result<tonic::Streaming<TailHistoryReply>> { + Ok(self + .client + .tail_history(TailHistoryRequest {}) + .await? + .into_inner()) + } + pub async fn shutdown(&mut self) -> Result<bool> { let resp = self.client.shutdown(ShutdownRequest {}).await?.into_inner(); Ok(resp.accepted) |
