INNER CODE UNIT · Rust

start

lanterndata/lantern · lantern_cli/src/daemon/mod.rs:346

pub async fn start(
    args: cli::DaemonArgs,
    logger: Option<Logger>,
    cancel_token: CancellationToken,
) -> AnyhowVoidResult {
    let logger = Arc::new(logger.unwrap_or(Logger::new("Lantern Daemon", args.log_level.value())));

    let target_databases: Vec<TargetDB> = get_target_databases(&args, logger.clone()).await?;

    let args_arc = Arc::new(args);
    let args_arc_clone = args_arc.clone();
    let embedding_channel: (
        Sender<EmbeddingProcessorArgs>,
        Receiver<EmbeddingProcessorArgs>,
    ) = mpsc::channel(1);
    let autotune_channel: (
        Sender<AutotuneProcessorArgs>,
        Receiver<AutotuneProcessorArgs>,

View source record →