diff options
| author | Benedikt Peetz <benedikt.peetz@b-peetz.de> | 2026-07-09 22:00:59 +0200 |
|---|---|---|
| committer | Benedikt Peetz <benedikt.peetz@b-peetz.de> | 2026-07-09 22:00:59 +0200 |
| commit | 620cf8fa33835c1ce1e56b1028ff6e2a6fbe0f39 (patch) | |
| tree | e97e54ff112c8e3fa9f88335bfd1275420a4d69f /crates/daemon/src/components/search.rs | |
| parent | chore: Separate daemon, client, server, and lib into crates (diff) | |
| download | atuin-620cf8fa33835c1ce1e56b1028ff6e2a6fbe0f39.zip | |
chore: Add more things
Diffstat (limited to 'crates/daemon/src/components/search.rs')
| -rw-r--r-- | crates/daemon/src/components/search.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/crates/daemon/src/components/search.rs b/crates/daemon/src/components/search.rs index bcd60cc4..91f2db17 100644 --- a/crates/daemon/src/components/search.rs +++ b/crates/daemon/src/components/search.rs @@ -12,7 +12,7 @@ use tonic::{Request, Response, Status, Streaming}; use tracing::{Level, debug, info, instrument, span, trace}; use uuid::Uuid; -use crate::atuin_daemon::{ +use crate::{ daemon::{Component, DaemonHandle}, events::DaemonEvent, generated::search::{ @@ -34,7 +34,7 @@ const FRECENCY_REFRESH_INTERVAL_SECS: u64 = 60; /// - Loads history from the database on startup /// - Updates the index when history events occur /// - Provides the Search gRPC service -pub(crate) struct SearchComponent { +pub struct SearchComponent { index: Arc<RwLock<SearchIndex>>, handle: RwLock<Option<DaemonHandle>>, loader_handle: Option<tokio::task::JoinHandle<()>>, @@ -43,7 +43,7 @@ pub(crate) struct SearchComponent { impl SearchComponent { /// Create a new search component. - pub(crate) fn new() -> Self { + pub fn new() -> Self { Self { index: Arc::new(RwLock::new(SearchIndex::new())), handle: RwLock::new(None), @@ -53,7 +53,7 @@ impl SearchComponent { } /// Get the gRPC service for this component. - pub(crate) fn grpc_service(&self) -> SearchServer<SearchGrpcService> { + pub fn grpc_service(&self) -> SearchServer<SearchGrpcService> { SearchServer::new(SearchGrpcService { index: self.index.clone(), }) @@ -276,7 +276,7 @@ impl Component for SearchComponent { } /// The gRPC service implementation. -pub(crate) struct SearchGrpcService { +pub struct SearchGrpcService { index: Arc<RwLock<SearchIndex>>, } @@ -398,7 +398,7 @@ fn convert_filter_mode( } #[cfg(not(windows))] -pub(crate) fn with_trailing_slash(s: &str) -> String { +pub fn with_trailing_slash(s: &str) -> String { if s.ends_with('/') { s.to_string() } else { |
