Crate eshanized_polaris_core 

Polaris Core

Core runtime and implementation for the Polaris distributed compute framework.

This crate provides the fundamental building blocks for distributed task execution:

• Task model and lifecycle management
• Node discovery and registration
• Pluggable schedulers
• Network transport (QUIC/TLS/gRPC)
• State replication
• Observability and metrics

Architecture

┌─────────────────────────────────────────────────────────┐
│                    Cluster API                          │
├─────────────────────────────────────────────────────────┤
│  Scheduler  │  Task Manager  │  Node Registry           │
├─────────────────────────────────────────────────────────┤
│         Network Layer (QUIC/TLS/gRPC)                   │
├─────────────────────────────────────────────────────────┤
│    Storage (In-Memory / RocksDB / Sled)                 │
└─────────────────────────────────────────────────────────┘

Example

use polaris_core::prelude::*;

// Create a cluster
let cluster = Cluster::builder()
    .with_local_node()
    .build()
    .await?;

// Submit a task
let result = cluster.submit(my_task).await?;

Re-exports

pub use errors::PolarisError;

pub use errors::PolarisResult;

pub use prelude::*;

Modules

cluster

Cluster management and orchestration.

config

Configuration types for Polaris clusters and nodes.

dag

Directed Acyclic Graph (DAG) support for task dependencies.

errors

Error types for Polaris.

executor

Task execution engine with worker pool.

net

Network transport implementations.

node

Node model and lifecycle management.

observability

Observability and metrics collection.

prelude

Convenient re-exports for common types and traits.

scheduler

Task scheduling implementations.

security

Security utilities for mTLS and authentication.

serialization

Serialization utilities for task payloads and network messages.

storage

Storage backends for persisting cluster state.

task

Task model and lifecycle management.