INNER CODE UNIT · Rust

db_change_listener

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

async fn db_change_listener(
    args: Arc<cli::DaemonArgs>,
    embedding_tx: Sender<EmbeddingProcessorArgs>,
    autotune_tx: Sender<AutotuneProcessorArgs>,
    logger: Arc<Logger>,
    cancel_token: CancellationToken,
) -> AnyhowVoidResult {
    logger.info("Setting up triggers");
    let (client, mut connection) =
        tokio_postgres::connect(args.master_db.as_ref().unwrap(), NoTls).await?;

    let client = Arc::new(client);
    let client_ref = client.clone();
    let cancel_token_clone = cancel_token.clone();
    let logger_clone = logger.clone();
    let ping_logger = logger.clone();

    let full_table_name = get_full_table_name(&args.master_db_schema, &args.databases_table);

View source record →