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
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

use async_trait::async_trait;

use crate::application::dto::{
    ClusterForwardOutcomeRow, ClusterNodeHealthRow, EndpointDiagnosticsReadModelRow,
    EndpointFailureRateTrendRow, ForwardClusterCommandRequest, ForwardClusterCommandResponse,
    HeartbeatClusterNodeRequest, InitiateCoordinatorFailoverRequest,
    InitiateCoordinatorFailoverResponse, InitiateCoordinatorHandoffRequest,
    InitiateCoordinatorHandoffResponse, ListClusterForwardOutcomesRequest,
    ListClusterNodeHealthRequest, ListEndpointDiagnosticsReadModelRequest,
    ListEndpointFailureRateTrendsRequest, ListQueueOwnershipHealthRequest,
    ListTopUnhealthyEndpointsRequest, PruneEndpointDeliveryStatusesRequest,
    PruneExpiredClusterNodesRequest, QueueOwnershipHealthRow, RebalanceQueueOwnershipRequest,
    RebalanceQueueOwnershipResponse, RegisterClusterNodeRequest, RegisterDeliveryEndpointRequest,
    RegisterDeliveryEndpointResponse, RunClusterHeartbeatSweepRequest,
    RunClusterHeartbeatSweepResponse, SetDeliveryEndpointEnabledRequest,
};
use crate::domain::errors::Result;
use crate::domain::runtime::cluster_node::ClusterNode;
use crate::domain::runtime::delivery_endpoint::DeliveryEndpoint;
use crate::domain::runtime::endpoint_delivery_status::EndpointDeliveryStatus;

#[async_trait]
pub trait ControlPlaneCommands {
    async fn register_delivery_endpoint(
        &self,
        request: RegisterDeliveryEndpointRequest,
    ) -> Result<RegisterDeliveryEndpointResponse>;
    async fn set_delivery_endpoint_enabled(
        &self,
        request: SetDeliveryEndpointEnabledRequest,
    ) -> Result<()>;
    async fn list_delivery_endpoints(&self) -> Result<Vec<DeliveryEndpoint>>;
    async fn get_endpoint_delivery_status(
        &self,
        endpoint_id: &str,
    ) -> Result<Option<EndpointDeliveryStatus>>;
    async fn list_endpoint_delivery_statuses(&self) -> Result<Vec<EndpointDeliveryStatus>>;
    async fn list_endpoint_diagnostics_read_model(
        &self,
        request: ListEndpointDiagnosticsReadModelRequest,
    ) -> Result<Vec<EndpointDiagnosticsReadModelRow>>;
    async fn list_top_unhealthy_endpoints(
        &self,
        request: ListTopUnhealthyEndpointsRequest,
    ) -> Result<Vec<EndpointDiagnosticsReadModelRow>>;
    async fn list_endpoint_failure_rate_trends(
        &self,
        request: ListEndpointFailureRateTrendsRequest,
    ) -> Result<Vec<EndpointFailureRateTrendRow>>;
    async fn prune_endpoint_delivery_statuses(
        &self,
        request: PruneEndpointDeliveryStatusesRequest,
    ) -> Result<u64>;
    async fn register_cluster_node(
        &self,
        request: RegisterClusterNodeRequest,
    ) -> Result<ClusterNode>;
    async fn heartbeat_cluster_node(
        &self,
        request: HeartbeatClusterNodeRequest,
    ) -> Result<ClusterNode>;
    async fn list_cluster_node_health(
        &self,
        request: ListClusterNodeHealthRequest,
    ) -> Result<Vec<ClusterNodeHealthRow>>;
    async fn list_queue_ownership_health(
        &self,
        request: ListQueueOwnershipHealthRequest,
    ) -> Result<Vec<QueueOwnershipHealthRow>>;
    async fn prune_expired_cluster_nodes(
        &self,
        request: PruneExpiredClusterNodesRequest,
    ) -> Result<u64>;
    async fn run_cluster_heartbeat_sweep(
        &self,
        request: RunClusterHeartbeatSweepRequest,
    ) -> Result<RunClusterHeartbeatSweepResponse>;
    async fn forward_cluster_command(
        &self,
        request: ForwardClusterCommandRequest,
    ) -> Result<ForwardClusterCommandResponse>;
    async fn initiate_coordinator_handoff(
        &self,
        request: InitiateCoordinatorHandoffRequest,
    ) -> Result<InitiateCoordinatorHandoffResponse>;
    async fn list_cluster_forward_outcomes(
        &self,
        request: ListClusterForwardOutcomesRequest,
    ) -> Result<Vec<ClusterForwardOutcomeRow>>;
    async fn initiate_coordinator_failover(
        &self,
        request: InitiateCoordinatorFailoverRequest,
    ) -> Result<InitiateCoordinatorFailoverResponse>;
    async fn rebalance_queue_ownership(
        &self,
        request: RebalanceQueueOwnershipRequest,
    ) -> Result<RebalanceQueueOwnershipResponse>;
}