Struct LoggerManager 

pub struct LoggerManager { /* private fields */ }

Core logging manager that coordinates log collection and routing to sinks.

LoggerManager is the main entry point for the inklog logging system. It handles:

• Log message routing to configured sinks (console, file, database)
• Health monitoring and metrics collection
• Sink recovery on failure
• Archive service lifecycle (when S3 is enabled)
• HTTP server for health endpoints (when http feature is enabled)

Examples

use inklog::{LoggerManager, InklogConfig};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = InklogConfig::default();
    let _logger = LoggerManager::with_config(config).await?;
    Ok(())
}

Implementations

impl LoggerManager

pub async fn new() -> Result<Self, InklogError>

pub async fn with_config(config: InklogConfig) -> Result<Self, InklogError>

Creates a new LoggerManager with the given configuration.

This is the primary entry point for initializing the logging system. The configuration determines which sinks are enabled and how logs are handled.

Arguments

• config - Configuration for the logging system

Returns

A Result containing the LoggerManager or an error if initialization fails

Example

use inklog::{LoggerManager, InklogConfig};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = InklogConfig::default();
    let _logger = LoggerManager::with_config(config).await?;
    Ok(())
}

pub async fn with_watch() -> Result<Self, InklogError>

pub async fn build_detached( config: InklogConfig, ) -> Result<(Self, LoggerSubscriber, LevelFilter), InklogError>

构建LoggerManager但不安装全局订阅者。 这主要用于测试和基准测试。

pub async fn from_file<P: AsRef<Path>>(path: P) -> Result<Self, InklogError>

pub async fn load() -> Result<Self, InklogError>

pub fn builder() -> LoggerBuilder

pub async fn start_archive_service(&self) -> Result<(), InklogError>

启动S3归档服务

pub async fn stop_archive_service(&self) -> Result<(), InklogError>

停止S3归档服务

pub async fn trigger_archive(&self) -> Result<String, InklogError>

执行手动归档

pub fn get_health_status(&self) -> HealthStatus

pub fn recover_sink(&self, sink_name: &str) -> Result<(), InklogError>

pub fn trigger_recovery_for_unhealthy_sinks( &self, ) -> Result<Vec<String>, InklogError>

pub fn shutdown(&self) -> Result<(), InklogError>