Engula is a storage engine that empowers engineers to build reliable and cost-effective databases with less effort and more confidence.
Engula's design goals are as follows:
- Cloud-native: unbundles different components to leverage elastic resources on the cloud
- Intelligent: optimizes its own data structures according to dynamic workloads
- Extensible: provides rich APIs and modules for users to program application logic
- Platform independent: supports flexible deployments on bare-metal servers, private and public cloud platforms
Engula is in the demo stage now. Please check the roadmap for more details.
Welcome to review the design and join the room to discuss with us. We also offer full-time jobs. For more information, please get in touch with careers@engula.com.
use std::sync::Arc;
use engula::{
Database, FileSystem, JobRuntime, LocalFileSystem, LocalJobRuntime, LocalJournal, LocalStorage,
Options, StorageOptions,
};
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let options = Options {
memtable_size: 1024,
};
let storage_options = StorageOptions::default();
let dirname = "/tmp/engula";
let _ = std::fs::remove_dir_all(dirname);
let fs = LocalFileSystem::new(dirname)?;
let fs: Arc<dyn FileSystem> = Arc::new(fs);
let job = LocalJobRuntime::new(fs.clone());
let job: Arc<dyn JobRuntime> = Arc::new(job);
let storage = LocalStorage::new(storage_options, fs, job)?;
let journal = LocalJournal::new(dirname, false)?;
let db = Database::new(options, Arc::new(journal), Arc::new(storage)).await;
for i in 0..1024u64 {
let v = i.to_be_bytes().to_vec();
db.put(v.clone(), v.clone()).await?;
let got = db.get(&v).await?;
assert_eq!(got, Some(v.clone()));
}
Ok(())
}You can run the example with:
cargo run --example hello