cala-server 0.13.15

Server to sync other cala deployments
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

mod config;
mod error;

use job::Jobs;
use sqlx::PgPool;

use cala_ledger::CalaLedger;

pub use config::*;
pub use error::*;

pub struct CalaApp {
    _pool: PgPool,
    ledger: CalaLedger,
    _jobs: job::Jobs,
}

impl CalaApp {
    pub(crate) async fn run(
        pool: PgPool,
        config: AppConfig,
        ledger: CalaLedger,
    ) -> Result<Self, ApplicationError> {
        let mut jobs = Jobs::init(
            job::JobSvcConfig::builder()
                .pool(pool.clone())
                .poller_config(config.jobs)
                .clock(ledger.clock().clone())
                .build()
                .expect("JobSvcConfig"),
        )
        .await?;
        jobs.start_poll().await?;

        Ok(Self {
            _pool: pool,
            ledger,
            _jobs: jobs,
        })
    }

    pub fn ledger(&self) -> &CalaLedger {
        &self.ledger
    }
}