Differenciate between RW and RO postgress connections

Author: gorbak25

crates/corro-pg/src/lib.rs

@@ -556,21 +556,23 @@ pub async fn start(
     let server = TcpListener::bind(pg.bind_addr).await?;
     let (tls_acceptor, ssl_required) = setup_tls(pg).await?;
     let local_addr = server.local_addr()?;
+    let conn_gauge = persistent_gauge!("corro.api.active.streams",
+    "source" => "postgres",
+    "protocol" => "pg",
+    "readonly" => readonly.to_string(),
+    );
 
     tokio::spawn(async move {
         loop {
             let (tcp_conn, remote_addr) = match server.accept().preemptible(&mut tripwire).await {
                 Outcome::Completed(res) => res?,
                 Outcome::Preempted(_) => break,
             };
-            let mut conn = CountedTcpStream::wrap(
-                tcp_conn,
-                persistent_gauge!("corro.api.active.streams", "source" => "postgres", "protocol" => "pg"),
-            );
+            let mut conn = CountedTcpStream::wrap(tcp_conn, conn_gauge.clone());
             let tls_acceptor = tls_acceptor.clone();
             debug!("Accepted a PostgreSQL connection (from: {remote_addr})");
 
-            counter!("corro.api.connection.count", "protocol" => "pg").increment(1);
+            counter!("corro.api.connection.count", "protocol" => "pg", "readonly" => readonly.to_string()).increment(1);
 
             let agent = agent.clone();
             tokio::spawn(async move {