WIP

Cargo.toml

@@ -9,6 +9,7 @@ members = [
     "crates/bonsaidb-server",
     "crates/bonsaidb-keystorage-s3",
     "crates/bonsaidb-utils",
+    "crates/bonsaidb-jobs",
     "examples/*",
     "book/book-examples",
     "xtask",

crates/bonsaidb-jobs/Cargo.toml

@@ -0,0 +1,23 @@
+[package]
+name = "bonsaidb-jobs"
+version = "0.2.0"
+authors = ["Jonathan Johnson <[email protected]>"]
+edition = "2021"
+description = "Persistent job queueing and scheduling for BonsaiDb."
+repository = "https://github.com/khonsulabs/bonsaidb"
+license = "MIT OR Apache-2.0"
+keywords = ["bonsaidb", "job", "queue"]
+categories = ["config"]
+readme = "./README.md"
+homepage = "https://bonsaidb.io/"
+rust-version = "1.58"
+
+[dependencies]
+bonsaidb-core = { version = "0.2.0", path = "../bonsaidb-core" }
+serde = { version = "1", features = ["derive"] }
+
+[dev-dependencies]
+tokio = { version = "=1.16.1", features = ["full"] }
+bonsaidb-core = { version = "0.2.0", path = "../bonsaidb-core", features = [
+    "test-util",
+] }

crates/bonsaidb-jobs/src/lib.rs

@@ -0,0 +1,36 @@
+use bonsaidb_core::{
+    arc_bytes::serde::Bytes,
+    keyvalue::Timestamp,
+    schema::{Authority, Collection, CollectionName, SchemaName, Schematic},
+};
+use serde::{Deserialize, Serialize};
+
+pub fn define_collections(schematic: &mut Schematic) -> Result<(), bonsaidb_core::Error> {
+    schematic.define_collection::<Queue>()?;
+    schematic.define_collection::<Job>()?;
+
+    Ok(())
+}
+
+#[derive(Collection, Debug, Serialize, Deserialize)]
+#[collection(name = "queues", authority = "bonsaidb", core = bonsaidb_core)]
+pub struct Queue {
+    pub owner: QueueOwner,
+    pub name: String,
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+pub enum QueueOwner {
+    Collection(CollectionName),
+    Authority(Authority),
+    Schema(SchemaName),
+    Backend,
+}
+
+#[derive(Collection, Debug, Serialize, Deserialize)]
+#[collection(name = "jobs", authority = "bonsaidb", core = bonsaidb_core)]
+pub struct Job {
+    pub queue_id: u64,
+    pub payload: Bytes,
+    pub enqueued_at: Timestamp,
+}