Crate rustvello 

Rustvello — A distributed task library for Rust.

Rustvello provides a framework for defining, routing, and executing distributed tasks, inspired by the pynenc Python library.

Quick Start

use rustvello::prelude::*;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create app with the builder (in-memory backends by default)
    let mut app = Rustvello::builder()
        .app_id("my-app")
        .build().await?;
    Ok(())
}

Re-exports

pub use rustvello_core as core;

pub use rustvello_proto as proto;

pub use rustvello_mem as mem;mem

pub use rustvello_sqlite as sqlite;sqlite

pub use rustvello_prometheus as prometheus;prometheus

pub use rustvello_postgres as postgres;postgres

pub use rustvello_redis as redis;redis

pub use rustvello_mongo as mongodb;mongodb

pub use rustvello_mongo3 as mongodb3;mongodb3

pub use rustvello_rabbitmq as rabbitmq;rabbitmq

Modules

app

builder

logging

Logging initialization for rustvello.

orchestration

Orchestration coordinator — multi-subsystem coordination for hot-path operations.

prelude

runner

Runner implementations for Rustvello.

task_config

Task configuration overrides and resolution helpers.

trigger_builder

Fluent builder for composing trigger definitions.

Attribute Macros

task

Define a Rustvello task from a function.