Polaris

Rust-native distributed compute and orchestration framework for scaling concurrent workloads.

Features

• 🚀 Distributed task execution across a cluster
• 📊 Intelligent scheduling (RoundRobin, LoadAware, custom)
• 🔐 Security-first with mTLS by default
• 📈 Built-in observability and Prometheus metrics
• 🔄 Automatic retries with exponential backoff
• 🌐 Multiple transports (QUIC, TLS, gRPC)
• 💾 Flexible storage backends
• 🎯 DAG support for complex workflows

Quick Start

use eshanized_polaris::prelude::*;

#[eshanized_polaris::task]
async fn compute(x: i32) -> PolarisResult<i32> {
    Ok(x * x)
}

#[tokio::main]
async fn main() -> PolarisResult<()> {
    let cluster = Cluster::builder()
        .with_local_node()
        .build()
        .await?;
    
    let task = Task::new("compute", bytes::Bytes::from("5"));
    let handle = cluster.submit(task).await?;
    let result = handle.result().await?;
    
    Ok(())
}

Installation

Add to your Cargo.toml:

[dependencies]
eshanized-polaris = "0.1"
tokio = { version = "1", features = ["full"] }

Documentation

• API Documentation
• Examples
• Main README

License

MIT - See LICENSE for details.