Struct ClusterStore 

pub struct ClusterStore { /* private fields */ }

Cluster-backed store that reads from the in-memory Raft state machine and writes through Raft consensus with full propagation tracking.

All state feeds into the in-memory data structure (Raft SM). API reads come from memory (eventually consistent by default). Writes are not complete until confirmed propagated across the entire cluster.

Implementations

impl ClusterStore

pub fn new(raft: Arc<RaftCluster>) -> Self

pub fn with_propagation_timeout(self, timeout: Duration) -> Self

Set the maximum time to wait for full propagation on writes.

pub async fn get_job(&self, id: &str) -> Option<Job>

pub async fn list_jobs(&self) -> Vec<Job>

pub async fn get_allocation(&self, id: &Uuid) -> Option<Allocation>

pub async fn list_allocations(&self) -> Vec<Allocation>

pub async fn list_allocations_for_job(&self, job_id: &str) -> Vec<Allocation>

pub async fn get_node_meta(&self, id: &NodeId) -> Option<NodeMeta>

pub async fn list_nodes(&self) -> Vec<NodeMeta>

pub async fn get_job_history(&self, job_id: &str) -> Vec<JobVersionEntry>

Get job version history.

pub async fn list_events( &self, kind: Option<&EventKind>, since: Option<DateTime<Utc>>, ) -> Vec<Event>

List events with optional filtering.

pub async fn list_releases(&self) -> Vec<Release>

List all releases.

pub async fn get_release(&self, id: &Uuid) -> Option<Release>

Get a specific release.

pub async fn list_sources(&self) -> Vec<Source>

List all sources.

pub async fn get_source(&self, id: &Uuid) -> Option<Source>

Get a specific source.

pub async fn get_source_by_name(&self, name: &str) -> Option<Source>

Get a source by name.

pub async fn state(&self) -> ClusterState

Get the full cluster state (for adapter/convergence reads).

pub async fn is_leader(&self) -> bool

Check if this node is the Raft leader.

pub async fn get_job_linearizable(&self, id: &str) -> Result<Option<Job>>

Linearizable read — confirms leadership first. Use for operations that absolutely need the latest state (rare).

pub async fn put_job(&self, job: Job) -> Result<WriteResult<Job>>

Submit a job. Waits for full cluster propagation.

pub async fn update_job_status( &self, job_id: &str, status: JobStatus, ) -> Result<WriteResult<Job>>

Update job status. Waits for full cluster propagation.

pub async fn put_allocation( &self, alloc: Allocation, ) -> Result<WriteResult<Allocation>>

Submit an allocation. Waits for full cluster propagation.

pub async fn update_allocation_state( &self, alloc_id: Uuid, state: AllocationState, task_states: HashMap<String, TaskState>, ) -> Result<WriteResult<Allocation>>

Update allocation state. Waits for full cluster propagation.

pub async fn register_node(&self, meta: NodeMeta) -> Result<WriteResult<()>>

Register a node in the cluster.

pub async fn advertise_chunk(&self, hash: String, node_id: NodeId) -> Result<()>

Advertise a chunk in the content-addressed data index.

pub async fn emit_event(&self, event: Event) -> Result<()>

Emit an event into the cluster event ring.

pub async fn rollback_job( &self, job_id: &str, version: u64, ) -> Result<WriteResult<Job>>

Rollback a job to a previous version.

pub async fn put_release( &self, release: Release, ) -> Result<WriteResult<Release>>

Create a release.

pub async fn update_release_status( &self, release_id: Uuid, status: ReleaseStatus, ) -> Result<WriteResult<Release>>

Update release status.

pub async fn drain_node(&self, node_id: NodeId) -> Result<()>

Drain a node (set ineligible + emit event).

pub async fn set_node_eligibility( &self, node_id: NodeId, eligible: bool, ) -> Result<()>

Set node scheduling eligibility.

pub async fn put_source(&self, source: Source) -> Result<WriteResult<Source>>

Create a source.

pub async fn update_source( &self, source_id: Uuid, status: SourceStatus, last_rev: Option<String>, last_error: Option<String>, managed_jobs: Option<HashMap<String, String>>, ) -> Result<WriteResult<Source>>

Update source status, revision, error, and managed jobs.

pub async fn delete_source(&self, source_id: Uuid) -> Result<()>

Delete a source.