imbibe 0.0.1

a cosmos chain indexer
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
46

use imbibe::config;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
	let config = tokio::task::spawn_blocking(config::get_configuration).await??;

	#[cfg(not(feature = "disable-telemetry"))]
	imbibe_telemetry::make_tracing_subscriber(
		config.app.name,
		config.telemetry.trace_exporter,
		core::time::Duration::from_millis(config.telemetry.timeout_millis),
		tracing_subscriber::EnvFilter::try_from_default_env()
			.unwrap_or_else(|_| tracing_subscriber::EnvFilter::new("info")),
	)
	.and_then(imbibe_telemetry::init_subscriber)?;

	#[cfg(feature = "persistence")]
	let pool = imbibe_persistence::pool::establish_pool(config.db.db_url, config.db.max_conn).await?;

	#[cfg(feature = "indexer")]
	let indexer_handle = {
		let indexer = imbibe::indexer::run(
			config.indexer.tm_ws_url,
			pool.clone(),
			config.indexer.batch,
			config.indexer.workers,
		);

		tokio::spawn(indexer)
	};

	#[cfg(feature = "tarpc-querier")]
	let tarpc_querier_handle = {
		let tarpc_querier = imbibe::tarpc_querier::run(pool, config.querier.listen);

		tokio::spawn(tarpc_querier)
	};

	#[cfg(feature = "indexer")]
	indexer_handle.await??;

	#[cfg(feature = "tarpc-querier")]
	tarpc_querier_handle.await??;

	Ok(())
}