stasis-rs 0.1.0

Durable AI orchestration framework with runtime jobs, lineage, and memory integration
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use async_trait::async_trait;

use crate::domain::errors::Result;
use crate::domain::runtime::cluster_node::ClusterForwardCommand;
use crate::ports::outbound::runtime::cluster_command_forwarder::ClusterCommandForwarder;

#[derive(Clone, Default)]
pub struct NoopClusterCommandForwarder;

#[async_trait]
impl ClusterCommandForwarder for NoopClusterCommandForwarder {
    async fn forward(&self, _command: ClusterForwardCommand) -> Result<bool> {
        Ok(true)
    }
}