Struct LogService 

pub struct LogService { /* private fields */ }

Implementations

impl LogService

pub fn new( store: Arc<LogStore>, provider_service: Arc<ProviderService>, repository: Arc<Repository>, event_bus: Arc<dyn EventBus>, ) -> Self

pub async fn run_log_tree( self: &Arc<Self>, pipeline_id: &str, run_number: i64, ) -> DomainResult<RunLogTree>

pub async fn open_document( self: &Arc<Self>, pipeline_id: &str, run_number: i64, node_id: &str, retry: bool, ) -> DomainResult<RunLogDocument>

pub async fn read_lines( &self, pipeline_id: &str, run_number: i64, node_id: &str, revision: i64, start: u32, count: u32, max_line_units: u32, ) -> DomainResult<LogLinesPage>

pub async fn search( &self, pipeline_id: &str, run_number: i64, node_id: &str, revision: i64, session_id: &str, query: &LogSearchQuery, ) -> DomainResult<LogSearchResult>

pub async fn prepare_export( self: &Arc<Self>, pipeline_id: &str, run_number: i64, node_id: &str, revision: i64, ) -> DomainResult<LogExport>

pub async fn stats(&self) -> LogCacheStats

pub async fn clear(&self) -> DomainResult<()>

pub async fn shutdown(&self)