Struct EvidentSource 

pub struct EvidentSource { /* private fields */ }

The main entrypoint for connecting to an EvidentSource server.

EvidentSource manages the gRPC connection and provides methods for:

• Listing available databases (DatabaseCatalog trait)
• Creating and deleting databases
• Connecting to a specific database for operations

Example

use evidentsource_client::EvidentSource;
use evidentsource_core::domain::DatabaseName;

// Connect to the server
let es = EvidentSource::connect_to_server("http://localhost:50051").await?;

// List all databases
let mut databases = es.list_databases();
while let Some(name) = databases.next().await {
    println!("Database: {}", name);
}

// Connect to a specific database
let db_name = DatabaseName::new("my-db")?;
let conn = es.connect(&db_name).await?;

// Use the connection for operations
let latest = conn.latest_database().await?;
println!("Latest revision: {}", latest.revision());

Implementations

impl EvidentSource

pub fn builder(addr: &str) -> EvidentSourceBuilder

Create a builder for configuring and connecting to an EvidentSource server.

Example

use evidentsource_client::EvidentSource;
use std::time::Duration;

let es = EvidentSource::builder("http://localhost:50051")
    .connect_timeout(Duration::from_secs(10))
    .connect()
    .await?;

pub async fn connect_to_server(addr: &str) -> Result<Self, Error>

Connect to an EvidentSource server without authentication.

This only works if the server has allow_anonymous=true.

Arguments

• addr - The server address (e.g., http://localhost:50051 or https://api.example.com)

Example

let es = EvidentSource::connect_to_server("http://localhost:50051").await?;

pub async fn connect_with_auth( addr: &str, credentials: Credentials, ) -> Result<Self, Error>

Connect to an EvidentSource server with authentication credentials.

Arguments

• addr - The server address (e.g., http://localhost:50051 or https://api.example.com)
• credentials - Authentication credentials (BearerToken, DevMode, or None)

Examples

use evidentsource_client::{EvidentSource, Credentials, DevModeCredentials};

// With bearer token (production - requires TLS)
let es = EvidentSource::connect_with_auth(
    "https://api.example.com:50051",
    Credentials::BearerToken(my_jwt_token),
).await?;

// With DevMode credentials (local development)
let es = EvidentSource::connect_with_auth(
    "http://localhost:50051",
    Credentials::DevMode(
        DevModeCredentials::new("dev-user@example.com")
            .with_email("dev@example.com")
            .with_display_name("Developer")
    ),
).await?;

pub fn from_client(client: EvidentSourceClient) -> Self

Create an EvidentSource instance from an existing client.

pub async fn connect( &self, database: &DatabaseName, ) -> Result<Connection, DatabaseError>

Connect to a specific database.

This returns a Connection that maintains a live subscription to database updates and implements DatabaseProvider and DatabaseConnection.

Arguments

• database - The name of the database to connect to

Example

let db_name = DatabaseName::new("my-db")?;
let conn = es.connect(&db_name).await?;

pub fn client(&self) -> &EvidentSourceClient

Get a reference to the underlying gRPC client.

This provides access to low-level operations not exposed through the high-level API.

pub fn client_mut(&mut self) -> &mut EvidentSourceClient

Get a mutable reference to the underlying gRPC client.

Trait Implementations

impl Clone for EvidentSource

fn clone(&self) -> EvidentSource

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl DatabaseCatalog for EvidentSource

type Identity = DatabaseIdentityImpl

The type returned when creating a database.

fn list_databases(&self) -> impl Stream<Item = DatabaseName>

List all databases in the catalog.

fn create_database( &self, name: DatabaseName, ) -> impl Future<Output = Result<Self::Identity, DatabaseError>>

Create a new database with the given name.

fn delete_database( &self, name: DatabaseName, ) -> impl Future<Output = Result<(), DatabaseError>>

Delete a database by name.

impl Debug for EvidentSource

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.