Struct StandaloneServer 

pub struct StandaloneServer;

Standalone d-engine server for independent deployment

Implementations

impl StandaloneServer

pub async fn run(shutdown_rx: Receiver<()>) -> Result<(), Error>

Run server with configuration from environment.

Reads CONFIG_PATH environment variable or uses default configuration. Data directory is determined by config’s cluster.db_root_dir setting. Blocks until shutdown signal is received.

Arguments

• shutdown_rx - Shutdown signal receiver

Example

// Set config path via environment variable
std::env::set_var("CONFIG_PATH", "/etc/d-engine/production.toml");

let (shutdown_tx, shutdown_rx) = watch::channel(());
StandaloneServer::run(shutdown_rx).await?;

pub async fn run_with( config_path: &str, shutdown_rx: Receiver<()>, ) -> Result<(), Error>

Run server with explicit configuration file.

Reads configuration from specified file path. Data directory is determined by config’s cluster.db_root_dir setting. Blocks until shutdown signal is received.

Arguments

• config_path - Path to configuration file
• shutdown_rx - Shutdown signal receiver

Example

let (shutdown_tx, shutdown_rx) = watch::channel(());
StandaloneServer::run_with("config/node1.toml", shutdown_rx).await?;

pub async fn run_custom<SE, SM>( storage_engine: Arc<SE>, state_machine: Arc<SM>, shutdown_rx: Receiver<()>, config_path: Option<&str>, ) -> Result<(), Error>

where SE: StorageEngine + Debug + 'static, SM: StateMachine + Debug + 'static,

Run server with custom storage engine and state machine.

Advanced API for users providing custom storage implementations. Blocks until shutdown signal is received.

Arguments

• config - Node configuration
• storage_engine - Custom storage engine implementation
• state_machine - Custom state machine implementation
• shutdown_rx - Shutdown signal receiver

Example

let storage = Arc::new(MyCustomStorage::new()?);
let sm = Arc::new(MyCustomStateMachine::new()?);

let (shutdown_tx, shutdown_rx) = watch::channel(());
StandaloneServer::run_custom(storage, sm, shutdown_rx, Some("config.toml")).await?;