Struct WorkflowProjection 

pub struct WorkflowProjection { /* private fields */ }

Implementations

impl WorkflowProjection

pub fn new(turn_id: TurnId) -> Self

pub fn graph(&self) -> &WorkflowGraph

pub fn into_graph(self) -> WorkflowGraph

pub fn revision(&self) -> u64

pub fn summary(&self) -> &WorkflowSummary

pub fn find_node(&self, id: &str) -> Option<&WorkflowNode>

pub fn descendant_pending_permissions(&self, flow_node_id: &str) -> usize

pub fn permission_request_for_node( &self, node_id: &str, ) -> Option<&WorkflowPermissionRequest>

pub fn permission_group_progress( &self, group_id: &PermissionGroupId, ) -> Option<(usize, usize)>

pub fn apply_batch<'a>( &mut self, events: impl IntoIterator<Item = &'a Event>, ) -> ProjectionDelta

pub fn apply_event(&mut self, event: &Event) -> ProjectionDelta

pub fn apply_stream_frame(&mut self, frame: &StreamFrame) -> ProjectionDelta

pub fn apply_stream_frame_at( &mut self, frame: &StreamFrame, override_ts: Option<DateTime<Utc>>, ) -> ProjectionDelta

pub fn interrupt_pending_permissions(&mut self) -> ProjectionDelta

pub fn apply_permission_request( &mut self, payload: &PermissionRequestAudit, state: WorkflowPermissionState, ) -> ProjectionDelta

pub fn apply_permission_request_with_identity( &mut self, identity: WorkflowPermissionIdentity, payload: &PermissionRequestAudit, state: WorkflowPermissionState, ) -> ProjectionDelta

pub fn apply_permission_requests( &mut self, requests: impl IntoIterator<Item = (WorkflowPermissionIdentity, PermissionRequestAudit, WorkflowPermissionState)>, ) -> ProjectionDelta

pub fn apply_permission_group( &mut self, payload: &PermissionGroupAudit, resolved: bool, ) -> ProjectionDelta

Methods from Deref<Target = WorkflowGraph>

pub fn find_node(&self, id: &str) -> Option<&WorkflowNode>

pub fn descendant_pending_permissions(&self, flow_node_id: &str) -> usize

Trait Implementations

impl Clone for WorkflowProjection

fn clone(&self) -> WorkflowProjection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowProjection

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

Formats the value using the given formatter.

impl Deref for WorkflowProjection

type Target = WorkflowGraph

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<'de> Deserialize<'de> for WorkflowProjection

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<WorkflowGraph> for WorkflowProjection

fn from(graph: WorkflowGraph) -> Self

Converts to this type from the input type.

impl From<WorkflowProjection> for WorkflowGraph

fn from(projection: WorkflowProjection) -> Self

Converts to this type from the input type.

impl PartialEq for WorkflowProjection

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for WorkflowProjection

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.