MCPcopy Create free account
hub / github.com/Rustixir/darkbird / connect

Method connect

src/darkbird/persistent_worker.rs:45–70  ·  view source on GitHub ↗
(db_name: DatabaseName, cfg_string: String)

Source from the content-addressed store, hash-verified

43
44impl Persistent {
45 pub async fn connect(db_name: DatabaseName, cfg_string: String) -> Result<Persistent, ()> {
46 match db_name {
47 DatabaseName::Scylla => {
48 let persistent = match Persistent::connect_to_scylla(cfg_string).await {
49 Ok(persistent) => persistent,
50 Err(e) => {
51 eprintln!("{}", e.to_string());
52 return Err(());
53 }
54 };
55
56 Ok(persistent)
57 }
58 DatabaseName::Postgres => {
59 let persistent = match Persistent::connect_to_postgres(cfg_string).await {
60 Ok(persistent) => persistent,
61 Err(e) => {
62 eprintln!("{}", e.to_string());
63 return Err(());
64 }
65 };
66
67 Ok(persistent)
68 }
69 }
70 }
71
72 async fn connect_to_postgres(cfg_string: String) -> Result<Persistent, Error> {
73 let (client, connection) = match tokio_postgres::connect(&cfg_string, NoTls).await {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected