Struct InMemoryControlledStore 

pub struct InMemoryControlledStore {
    pub graph_revisions: BTreeMap<String, u64>,
    pub node_control_revisions: BTreeMap<(String, String), u64>,
    pub settled_invocations: BTreeSet<(String, String, String)>,
    pub stop_requested_targets: BTreeSet<(String, String)>,
    pub pause_negotiating_targets: BTreeSet<(String, String)>,
    pub graph_barriers: BTreeSet<String>,
    pub target_generations: BTreeMap<(String, String), u64>,
    pub revoked_grants: BTreeSet<(String, OperationGrant)>,
    pub idempotency_log: BTreeMap<String, (AdmissionReceipt, String)>,
    pub admitted_queue: Vec<AdmissionReceipt>,
    pub next_sequence: u64,
}

In-memory controlled store implementing ControlledStore for tests and isolated execution.

Fields

graph_revisions: BTreeMap<String, u64>

node_control_revisions: BTreeMap<(String, String), u64>

settled_invocations: BTreeSet<(String, String, String)>

stop_requested_targets: BTreeSet<(String, String)>

pause_negotiating_targets: BTreeSet<(String, String)>

graph_barriers: BTreeSet<String>

target_generations: BTreeMap<(String, String), u64>

revoked_grants: BTreeSet<(String, OperationGrant)>

idempotency_log: BTreeMap<String, (AdmissionReceipt, String)>

admitted_queue: Vec<AdmissionReceipt>

next_sequence: u64

Implementations

impl InMemoryControlledStore

pub fn new() -> InMemoryControlledStore

pub fn set_graph_revision(&mut self, graph_id: impl Into<String>, revision: u64)

pub fn set_node_control_revision( &mut self, graph_id: impl Into<String>, node_id: impl Into<String>, revision: u64, )

pub fn mark_invocation_settled( &mut self, graph_id: impl Into<String>, node_id: impl Into<String>, invocation_id: impl Into<String>, )

pub fn mark_stop_requested( &mut self, graph_id: impl Into<String>, target: impl Into<String>, )

pub fn mark_pause_negotiating( &mut self, graph_id: impl Into<String>, target: impl Into<String>, )

pub fn clear_pause_negotiating(&mut self, graph_id: &str, target: &str)

pub fn set_graph_barrier(&mut self, graph_id: impl Into<String>, active: bool)

pub fn set_target_generation( &mut self, graph_id: impl Into<String>, target: impl Into<String>, generation: u64, )

pub fn revoke_grant( &mut self, principal_id: impl Into<String>, grant: OperationGrant, )

Trait Implementations

impl Clone for InMemoryControlledStore

fn clone(&self) -> InMemoryControlledStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ControlledStore for InMemoryControlledStore

fn get_graph_revision( &self, graph_id: &str, ) -> Result<Option<u64>, AdmissionConflict>

Return the current graph definition revision if the graph exists.

fn get_node_control_revision( &self, graph_id: &str, node_id: &str, ) -> Result<Option<u64>, AdmissionConflict>

Return the current control revision for the specified node.

fn is_invocation_settled( &self, graph_id: &str, node_id: &str, invocation_id: &str, ) -> Result<bool, AdmissionConflict>

Check if the invocation has already completed/settled.

fn is_stop_requested( &self, graph_id: &str, target: &str, ) -> Result<bool, AdmissionConflict>

Check if stop has already been requested for this target (node or graph).

fn is_pause_negotiating( &self, graph_id: &str, target: &str, ) -> Result<bool, AdmissionConflict>

Check if pause is currently being negotiated for this target.

fn is_graph_barrier_active( &self, graph_id: &str, ) -> Result<bool, AdmissionConflict>

Check if a graph-scope admission barrier is currently active.

fn get_target_generation( &self, graph_id: &str, target: &str, ) -> Result<Option<u64>, AdmissionConflict>

Return the target’s current lifecycle generation.

fn is_grant_revoked( &self, principal_id: &str, grant: &OperationGrant, ) -> Result<bool, AdmissionConflict>

Check if a grant has been dynamically revoked for this principal.

fn find_idempotency_record( &self, request_id: &str, ) -> Result<Option<(AdmissionReceipt, String)>, AdmissionConflict>

Look up an idempotency record by request_id.

fn record_admission( &mut self, receipt: &mut AdmissionReceipt, payload_digest: String, expected_control_revision: Option<u64>, fences: &AdmissionFences, ) -> Result<(), AdmissionConflict>

Durably commit an admitted command to the queue.

impl Debug for InMemoryControlledStore

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

Formats the value using the given formatter.

impl Default for InMemoryControlledStore

fn default() -> InMemoryControlledStore

Returns the “default value” for a type.