Crate rivvend 

Rivven Server Daemon (rivvend)

High-performance distributed event streaming server with support for both standalone and clustered deployment modes.

Deployment Modes

• Standalone: Single-node mode, zero configuration required
• Cluster: Multi-node mode with SWIM membership, Raft consensus, and ISR replication

Quick Start

# Standalone mode
rivvend

# Cluster mode
rivvend --mode cluster --node-id node-1 --seeds node-2:9093

Re-exports

pub use auth_handler::AuthenticatedHandler;

pub use auth_handler::ConnectionAuth;

pub use cli::Cli;

pub use cli::DeploymentMode;

pub use cluster_server::ClusterServer;

pub use cluster_server::RequestRouter;

pub use cluster_server::ServerStats;

pub use cluster_server::ServerStatus;

pub use cluster_server::ShutdownHandle;

pub use group_coordinator::GroupCoordinator;

pub use partitioner::StickyPartitioner;

pub use partitioner::StickyPartitionerConfig;

pub use raft_api::create_raft_router;

pub use raft_api::start_raft_api_server;

pub use raft_api::RaftApiState;

pub use rate_limiter::ConnectionGuard;

pub use rate_limiter::ConnectionResult;

pub use rate_limiter::RateLimitConfig;

pub use rate_limiter::RateLimiter;

pub use rate_limiter::RequestResult;

pub use secure_server::ConnectionSecurityContext;

pub use secure_server::SecureServer;

pub use secure_server::SecureServerBuilder;

pub use secure_server::SecureServerConfig;

pub use dashboard::create_dashboard_router;

pub use dashboard::DashboardData;

pub use dashboard::DashboardState;

pub use raft_api::start_raft_api_server_with_dashboard;

pub use raft_api::DashboardConfig;

Modules

auth_handler

Authenticated Request Handler

cli

CLI argument parsing for Rivven server

cluster_server

Cluster-aware server implementation

dashboard

Web Dashboard for Rivven

framing

Shared connection framing for length-prefixed wire messages

group_coordinator

Group Coordinator — broker-side consumer group management

handler

Request handling — split into submodules by concern

partitioner

Sticky Partitioner

protocol

Protocol types re-exported from rivven-protocol

raft_api

Raft HTTP API endpoints

rate_limiter

Rate limiting and DoS protection for the Rivven server

secure_server

Secure Server with TLS/mTLS Support