imbibe-querier 0.0.1

provides Querier that holds a database connection pool, and provides methods to perform various read operations on the database for imbibe
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

use serde::{Deserialize, Serialize};

use crate::QuerierError;

#[derive(Debug, thiserror::Error, Serialize, Deserialize)]
#[error("{msg}")]
pub struct QueryTarpcError {
	msg: String,
}

#[derive(Debug, thiserror::Error)]
pub(super) enum QueryTarpcErrorKind {
	#[error("timeout error: {0}")]
	Timeout(#[from] tokio::time::error::Elapsed),

	#[error("querier error: {0}")]
	Querier(#[from] QuerierError),
}

impl From<QueryTarpcErrorKind> for QueryTarpcError {
	fn from(err: QueryTarpcErrorKind) -> Self {
		Self { msg: err.to_string() }
	}
}