rustvello-core 0.1.5

Core traits and types for the Rustvello distributed task library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

//! Core traits and types for the Rustvello distributed task system.
//!
//! This crate defines the abstract interfaces that all backend implementations
//! must satisfy:
//! - [`Broker`] — message routing between producers and runners
//! - [`Orchestrator`] — invocation lifecycle and status management
//! - [`StateBackend`] — persistence of invocations and results
//! - [`Runner`] — task execution engine
//! - [`ClientDataStore`] — external storage for large serialized values
//!
//! See `rustvello-mem` for in-memory implementations (testing),
//! `rustvello-sqlite` for SQLite (single-host production),
//! `rustvello-redis` for Redis, `rustvello-postgres` for PostgreSQL,
//! `rustvello-mongo` / `rustvello-mongo3` for MongoDB, and
//! `rustvello-rabbitmq` for RabbitMQ.

pub mod broker;
pub mod call;
pub mod client_data_store;
pub mod context;
pub mod error;
pub mod invocation;
pub mod logging;
pub mod middleware;
pub mod observability;
pub mod orchestrator;
pub mod reconnectable;
pub mod runner;
pub mod serializer;
pub mod state_backend;
pub mod task;
pub mod trigger;
pub mod workflow;

pub mod prelude {
    pub use crate::broker::Broker;
    pub use crate::call::Call;
    pub use crate::client_data_store::{ClientDataStore, ClientDataStoreManager};
    pub use crate::context::{
        get_invocation_context, get_runner_context, InvocationContext, RunnerContext,
    };
    pub use crate::error::{RustvelloError, RustvelloResult};
    pub use crate::invocation::{Invocation, InvocationHandle, SyncInvocation};
    pub use crate::orchestrator::{
        Orchestrator, OrchestratorBlocking, OrchestratorConcurrency, OrchestratorQuery,
        OrchestratorRecovery, OrchestratorStatus,
    };
    pub use crate::runner::Runner;
    pub use crate::serializer::{SerdeSerializer, Serializer};
    pub use crate::state_backend::StateBackend;
    pub use crate::task::{
        CrossLanguageSafe, DynTask, ForeignTask, Task, TaskDefinition, TaskModule, TaskRegistry,
    };
    pub use crate::trigger::{TriggerManager, TriggerStore};
    pub use rustvello_proto::prelude::*;
}