Struct Cluster 

pub struct Cluster { /* private fields */ }

Main cluster handle

Implementations

impl Cluster

pub fn builder() -> ClusterBuilder

Create a new cluster builder

pub async fn connect<I, S>(seeds: I) -> Result<Cluster, PolarisError>

where I: IntoIterator<Item = S>, S: AsRef<str>,

Connect to an existing cluster

Example

let cluster = Cluster::connect(["10.0.0.1:7001", "10.0.0.2:7001"]).await?;

pub async fn submit(&self, task: Task) -> Result<TaskHandle, PolarisError>

Submit a task to the cluster

Example

let task = Task::new("my_task", Bytes::from("payload"));
let handle = cluster.submit(task).await?;
let result = handle.result().await?;

pub async fn submit_batch( &self, tasks: Vec<Task>, ) -> Result<Vec<TaskHandle>, PolarisError>

Submit multiple tasks and collect results

Example

let tasks = vec![
    Task::new("task1", Bytes::from("input1")),
    Task::new("task2", Bytes::from("input2")),
];
let results = cluster.submit_batch(tasks).await?;

pub fn map<T, I>(&self, tasks: I) -> MapBuilder<T>

where I: IntoIterator<Item = Task>,

Map over a list of tasks

Submit multiple tasks and collect their results in parallel.

Example

let tasks = vec![
    Task::new("task1", Bytes::from("input1")),
    Task::new("task2", Bytes::from("input2")),
];
 
let results = cluster.map(tasks)
    .with_retry(5)
    .await_impl()
    .await?;

pub fn task_status(&self, task_id: TaskId) -> Option<TaskStatus>

Get task status

pub fn stats(&self) -> ClusterStats

Get cluster statistics

pub async fn shutdown(&self) -> Result<(), PolarisError>

Shutdown the cluster gracefully

Trait Implementations

impl Clone for Cluster

fn clone(&self) -> Cluster

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Cluster

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.