db9s 2026.10.1

k9s-style terminal UI to browse, query, and edit Postgres, MongoDB and RabbitMQ
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
47
48
49
50
51
52
53
54
55

pub mod amqp;
pub mod mongo;
pub mod postgres;
pub mod rabbitmq;
#[cfg(test)]
mod tests;

use crate::value::Row;
use anyhow::Result;
use async_trait::async_trait;

#[derive(Debug, Clone)]
pub struct QueryResult {
    pub columns: Vec<String>,
    pub rows: Vec<Row>,
    pub affected: Option<u64>,
}

/// Uniform interface over a database backend, browsable k9s-style:
/// database -> container (table/collection) -> rows/documents.
#[async_trait]
pub trait DataSource: Send + Sync {
    /// Message brokers (rows = messages): `/` publishes, `d` purges, edit is disabled.
    fn is_queue(&self) -> bool {
        false
    }

    async fn list_databases(&self) -> Result<Vec<String>>;

    /// Tables for postgres, collections for mongo.
    async fn list_containers(&self, database: &str) -> Result<Vec<String>>;

    async fn fetch_rows(
        &self,
        database: &str,
        container: &str,
        limit: i64,
        offset: i64,
    ) -> Result<QueryResult>;

    /// Raw query: SQL for postgres, a mongo shell-ish JSON filter `{"find": ...}` not required —
    /// for mongo this runs an aggregation pipeline given as a JSON array string, or a plain
    /// filter document JSON for a `find`.
    async fn run_query(&self, database: &str, container: &str, raw: &str) -> Result<QueryResult>;

    async fn delete_row(&self, database: &str, container: &str, row: &Row) -> Result<()>;

    async fn update_row(
        &self,
        database: &str,
        container: &str,
        original: &Row,
        edited: &Row,
    ) -> Result<()>;
}