velo 0.4.1

Velo distributed-systems runtime: active messaging, peer discovery, streaming, rendezvous, and queue backends
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

// SPDX-FileCopyrightText: Copyright (c) 2025-2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
// SPDX-License-Identifier: Apache-2.0

//! # Velo Messenger
//!
//! Active messaging layer for Velo distributed systems. Provides client, server,
//! and handler infrastructure for request-response and fire-and-forget messaging
//! patterns over pluggable transports. Includes a distributed event system.

mod client;
pub(crate) mod large_payload;
#[allow(clippy::module_inception)]
mod messenger;

pub(crate) mod common;
pub(crate) mod handlers;
pub(crate) mod server;

pub mod discovery;
pub mod events;

pub use client::builders::{
    AmSendBuilder, AmSyncBuilder, SyncResult, TypedUnaryBuilder, TypedUnaryResult, UnaryBuilder,
    UnaryResult,
};
pub use common::MessageId;
pub use discovery::PeerDiscovery;
pub use events::VeloEvents;
pub use handlers::{
    AmHandlerBuilder, AsyncExecutor, Context, DispatchMode, Handler, HandlerExecutor, SyncExecutor,
    TypedContext, TypedUnaryHandlerBuilder, UnaryHandlerBuilder, UnifiedResponse,
};
pub use messenger::{Messenger, MessengerBuilder};